Пакеты очереди Laravel: как объединить несколько пакетов в цепочку ⇐ Php

[Anonymous]

У меня есть серия пакетов, которые необходимо запустить в цепочке (в правильном порядке), и я пытаюсь найти способ связать их все вместе и в конечном итоге уведомить пользователя о том, что все выполнено.
В настоящее время я использую следующее:
Bus::batch(new \App\Jobs\TestBatchJob())
->allowFailures()
->name('test-batch-1')
->then(function(\Illuminate\Bus\Batch $batch) {
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-2')
->then(function (\Illuminate\Bus\Batch $batch){
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-3')
->then(function (\Illuminate\Bus\Batch $batch){
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-4')
->then(function (\Illuminate\Bus\Batch $batch){
// Batch Chain Finishes Here.
\Illuminate\Support\Facades\Auth::user()->notify(...);
})
->dispatch();
})
->dispatch();
})
->dispatch();
})
->dispatch();

Это нормально... но основным недостатком является то, что он создает несколько пакетов.


Я больше не могу взаимодействовать с пакетом, т. е. $batch->cancel(), и любой индикатор прогресса на интерфейсе больше не работает.
/>Мне нужно убедиться, что первая партия заданий выполнена, прежде чем начинать вторую, но я хочу каким-то образом связать все партии вместе. Что-то вроде этого (не работает), возможно, объясняет мою идею.
Bus::batch(new \App\Jobs\TestBatchJob())
->allowFailures()
->name('test-batch-1')
->then(function(\Illuminate\Bus\Batch $batch){
$batch->add(new \App\Jobs\TestBatchJob2());
})
->dispatch();

Обновление 1 — Bus::Chain()
Спасибо @boolfalse за эту идею. Я попробовал несколько вещей.
Базовая цепочка — не работает
Вы можете создавать пакеты в цепочке, но они по-прежнему выполняются параллельно. Метод цепочки шин (с пакетами) полезен только в том случае, если пакет находится в самом конце набора связанных заданий.
Обратите внимание, что цепочка обнаруживает сбой только при создании пакета, а не при выполнении заданий внутри него.
Bus::chain([
function(){
Bus::batch(new TestBatchJob())->name('batch-1')->dispatch();
},
function(){
Bus::batch(new TestBatchJob())->name('batch-2')->dispatch();
},
function(){
Bus::batch(new TestBatchJob())->name('batch-3')->dispatch();
},
])->dispatch();


Цепочка с вложенными пакетами
Одним из вариантов использования цепочки с вложенными пакетами является возможность запускать некоторые обычные задания, а затем работать с обработанными данными перед запуском пакета.
Для запуска пакетов в цепочке, мы должны использовать метод then в цепочке.
$model = Model::create();
Bus::chain([
new TestBatchJob($model), // Run first on its own
function() use($model){
$model->doSomething(); // Amend the model prior to next batch
Bus::batch(new TestBatchJob($model)) // Run second on its own, using up-to-date model.
->name('batch-2')
->then(function(){
Bus::batch(new TestBatchJob())->name('batch-3')->dispatch(); // run third on its own
})
->dispatch();
}
])->dispatch();

Обновление 2 — Решение для базы данных
На данный момент я возвращаюсь к исходному решению вложенных функций then(). Чтобы связать каждое дочернее задание обратно с родительским (которое мы можем отображать в пользовательском интерфейсе и отслеживать как одно), я добавлю столбец в таблицу job_batches базы данных, чтобы связать дочерние пакеты.
$batch = Bus::batch(new \App\Jobs\TestBatchJob())
->name('test-batch-1')
->then(function(Batch $parentBatch) {
$parent = $parentBatch->id;
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-2')
->then(function (Batch $batch) use($parent){
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-3')
->then(function(Batch $batch) use($parent){
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-3')
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();

return JobBatch::query()->find($batch->id);


Подробнее здесь: https://stackoverflow.com/questions/711 ... le-batches