0

Решаю задачу импорта базы данных в реструктурированную новую. Есть настроенный супервайзер, который запускает джобы. Запуск произвожу из консоли через кастомную команду, которая отправляет джобу, с самым высоким приоритетом, которая уже отправляет в очередь остальные.

$blogArticles = Blog::with('getAuthor')->get();

    foreach ($blogArticles as $blogArticle)
    {
        $articleWriter = new DataWriter($blogArticle);
        dispatch(new ImportData($articleWriter))->onQueue($this->queuePriority)->delay(60*50);
    }

В DataWriter идет уже обработка импорта. Так сделано для того, чтобы не было времени ожидания при отправки джоб в очередь. Но тут возникает проблема: самих $blogArticles более 80 тыс, а процесс раскидывания джоб затухает где-то на 3600. Т.е. явно время жизни джобы ограничено.

Собственно вопрос в том, как решить проблему, и как сделать правильно.

1 ответ 1

0

Решено с помощью чанков. Чанками отправляю коллекции в класс, раскидывающий джобы обработчика. Т.е. ставлю в в очередь с высоким приоритетом задачи, по раскидыванию в очередь джоб с обработкой записи каждой статьи.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.