Как правильно организовать задачи в очереди?

Question

[Dmitriy]

Задача такая:
Паршу CSV, получается массив из массивов.
После того как спарсил, из этих данных надо создать модель - Platform, далее для каждой Platform взять по АПИ данные и создать SubModels с этими данными.

$platforms = array;
GetDataFromApi::dispatch($platforms);

В job'e я через foreach передаю Platform по АПИ, получаю ответ и создаю SubModel.
Проблема появилась, что у меня появилась ошибка beanstalkd notfound в логах лары.

И есть еще одна идея как это сделать:
$platforms;

GetDataFromApi::dispatch($platforms)
in job:

foreach ($platforms as $platform) {
     GetDataForPlatform::dispatch($platform);
}

Каким образом лучше решить такую задачу?

Answer 1

[pLavrenov]

лучше всего использовать events

вешаем слушателя на событие Platform created добавляем в слушателя условие при котором он будет срабатывать (на случай если например какой-то тип платформ не надо тянуть со стороны) и как только добавляем в базу Platform оно само пушит в очередь слушателя с нужным функционалом.

Модель событие-подписчик вообще очень удобно использовать везде почти.
laravel.com#events

Comments

[Dmitriy]

Тут не совсем в этом вопрос.

[pLavrenov]

Dmitriy Uvin, beanstalkd notfound это не понятно как может происходить, из двух вариантов второй лучше, но лучше юзать эвенты.

[Dmitriy]

Слишком много данных в джобу передавал, долго выполнялась

[pLavrenov]

Dmitriy Uvin, я отвлекся хотел дописать, лучше выполнить 1000 мелких job чем обработать в одном 1000 моделей

[Dmitriy]

lavren, да, это и было

[pLavrenov]

Dmitriy Uvin, время выполнения можно отслеживать в Horizon