Вот текущая настройка
- У меня есть веб-приложение.
- Есть работники сельдерея.
- В веб-приложении есть ресурс, который называется набором данных.
- Каждый набор данных имеет уникальный идентификатор.
- Пользователь может добавить файл в набор данных, чтобы добавить больше данных. Для этого API запустит задачу сельдерея.
Теперь мы хотим, чтобы пользователь мог добавить несколько файлов одновременно и реализовать очередь на уровне набора данных. Мы хотим добавить только один файл за один раз в набор данных, и эти задачи должны выполняться последовательно на уровне набора данных.
Задача сельдерея, которую мы имеем, выполняется для нескольких рабочих и выполняется одновременно. Но я хочу, чтобы сельдерей действовал как традиционная очередь FIFO на уровне набора данных. В противном случае он должен быть параллельным для всех наборов данных, как сейчас.
Должна ли постоянная очередь быть реализована вне задачи сельдерея? Или я могу сделать это в сельдерее?