Партии очереди Laravel: как цепорить несколько партий ⇐ Php

[Anonymous]

У меня есть серия партий, которые необходимо запускать в цепочке (в правильном порядке), и я пытаюсь найти способ связать их все вместе и в конечном итоге дать пользователю уведомление о том, что все завершено.
Я в настоящее время использую следующее: < /p>
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();
< /code>
Это нормально ... но основным недостатком является то, что он делает несколько партий. = "https://i.sstatic.net/v3hna.png"/>
Я больше не могу взаимодействовать с партией, т.е. $ 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();
< /code>
Обновление 1 - bus :: chail () < /h2>
Спасибо @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();


Цепочка с вложенными партиями < /h3>
Один вариант использования для цепи с вложенными партиями - позволить нам выполнять некоторые обычные задания, а затем работать с обработанными данными, прежде чем запустить Партия. PrettyPrint-Override ">$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 () s. Чтобы связать работу каждого ребенка обратно с родителем (который мы можем отобразить в пользовательском интерфейсе и треке как один), я буду добавлять столбец в таблицу базы данных 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