В моем проекте есть две работы, которые регулярно загружают файлы XML из нескольких доменов, а затем анализируют их, чтобы обнаружить измененные узлы. Эти узлы затем индивидуально сохраняются в базе данных и ставятся в очередь для обработки еще одним заданием, где они отправляются через веб-крючок в другое приложение.
Внешний API поддерживает несколько узлов из разных источников, отправляемых в одном запросе. , Таким образом, в webhook Job я хотел бы иметь возможность извлекать до определенного количества сообщений из очереди.
Есть ли способ сделать это с системой очередей Laravel? Я не смог найти его в документации.
Для ясности приведу простой пример:
Три отдельных файла загружаются дважды. Две версии трех файлов сравниваются, и измененные узлы извлекаются. Файл 1 имеет 7 изменений, Файл 2 имеет 8, Файл 3 имеет 4. Внешний API поддерживает до 10 изменений. Затем я хотел бы отправить первый вызов webhook: 7 из файла 1, плюс первые 3 изменения из файла 2, затем во второй webhook: оставшиеся 5 изменений из файла 2 и 4 изменения из файла 3.