Можно ли в Laravel группировать очереди?

Question

[verygoodboy]

• Допустим user_12 имеет в системе 100 файлов. Он хочет отправить эти файлы. Для этого мы используем очереди. Скрипт проходит по файлам и в очередь падает 100 файлов.
  
• В это самое время, одновременно с user_12, user_77, также имеющий 100 файлов, также отправляет их в очередь.
  
• В это самое время может быть еще много пользователей которые могут отправить в очередь свои n файлов.
  

Вопрос. Есть ли такая возможность у Laravel или как правильно организовать отправку заданий в очередь, чтобы сначала выполнились задания для user_12, потом для user_77 а потом для всех остальных по очереди.
Иными словами, как сделать так, чтобы задания от разных пользователей не перемешивались в очереди? Могут ли пользователи со своими заданиями стоять в очереди и как это реализовать?

Comments

[Дмитрий]

Job chaining? https://laravel.com/docs/10.x/queues#job-chaining

Answer 1

[JhaoDa]

Чем вам мешает, что они перемешиваются?

Но да, можно — https://laravel.com/docs/10.x/queues#job-batching

Comments

[verygoodboy]

Просто если у пользователя много заданий то он буде долго ждать пока они выполнятся. А если в этот момент в очередь еще влезут другие пользователи со своими заданиями, то время ожидания до конца выполнения всех заданий может растянуться.

[JhaoDa]

verygoodboy, так воркеров насыпьте побольше.

[verygoodboy]

Я однажды пользовался сервисом для анализа текста. Создал задание и нажал на кнопку анализировать. В результате на экране появилось сообщение, что я стою 10 в очереди на анализ текста. Вот я пытаюсь понять как такое организовать при этом пользователь должен стоять в очереди со своими заданиями.

[JhaoDa]

verygoodboy, из коробки — никак. Только делать механизм приоритезации. Батчиг — чисто техническая фича для логической группировки.

[verygoodboy]

JhaoDa, ясно, что-то буду думать над механизмом. Правильно ли я понимаю алгоритм Bus::batch. Я передаю в Bus::batch([...]) массив со списком jobs пользователя и все это улетает в очередь. Если с какой-то джобой из этого массива пошло что-то не так, то в ->catch(function (Batch $batch, Throwable $e) это можно поймать и обработать?