Как избежать увеличения времени при выполнении задачи?

Похоже что всё работает как надо.
Протестировал на локальном с $this->em->clear(); - время не увеличивается. На рабочем пока не проверял, но думаю, что и там будет всё в норме.

Как избежать увеличения времени при выполнении задачи?

Добрый вечер.
Именно doctrine, затупил, каюсь)
Переписал пока на dbal, всё летает, нет разницы по времени между localhost и рабочим сервером.
Но Ваши советы попробую использовать, надеюсь, что и они помогут, а то уж сильно длинная портянка получилась с запросом.

p.s. Логирование, как мне кажется, не очень хорошо отключать.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, вот это не смотрел

Как избежать увеличения времени при выполнении задачи?

Дмитрий, перед каждым тестом делаю truncate таблицы, проверок никаких нет, все данные сначала подготавливаю, потом передаю в очередь.

а что с памятью? растет?

Для контейнера с mysql?

Как избежать увеличения времени при выполнении задачи?

Дмитрий, оставил один, время увеличивается.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, из 4000)
В файле есть 4000 товаров, в цикле закидываю их в очередь. Из очереди они записываются в базу. При первом импорте 4000 товаров за 0,1 сек записалось 48, при втором импорте из 4000 товаров за 0,1 сек. в базу записалось 132 товаров и так далее. Остальные товары записывались за меньшее время.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, теперь я Вас не понял)

Как избежать увеличения времени при выполнении задачи?

48 -> 132 -> 676 -> 1804 -> 2164 -> 2583 -> 2657

Дмитрий, здесь я имел ввиду, что в первый импорт за 0.1 сек записалось 48 товаров, во второй - 132, в третий 646 товаров и так далее

Как избежать увеличения времени при выполнении задачи?

Дмитрий, получается, что время на вставку в базу увеличивается. Но не с каждой записью, время записи прыгает, то больше, то меньше.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, попробовал залогировать время каждой записи в базу данных.
Результаты не очень.
Писал в файл время вставки. За ориентир взял время в 0.1 сек.
При первом импорте за такое время записалось всего 9 товаров, остальные записи заняли меньше времени. Но при последующих импортах количество товаров, которые записываются за 0.1 сек. увеличиваются.
48 -> 132 -> 676 -> 1804 -> 2164 -> 2583 -> 2657. Даже есть записи, которые выполняются за 0.2, 0.3 сек.
С чем это может быть связано?

Как избежать увеличения времени при выполнении задачи?

Если с сообщением что-то пошло не так

iljaGolubev, то есть возникла ошибка или ещё что-то, что помешало записи в базу?

Как избежать увеличения времени при выполнении задачи?

iljaGolubev, изменил код, как Вы написали, но результат прежний.
Я не могу понять. Если я отправляю подтверждение выполнения через

$channel->basic_ack($message->delivery_info['delivery_tag']);

, то может этого не достаточно? Может надо как-то ещё обозначить завершение импорта для rabbit?

Как избежать увеличения времени при выполнении задачи?

надо смотреть туда - в коде взял из раббита и положил - деградация

Дмитрий, restart контейнера или с rabbit или c supervisor возвращает всё в норму, импорт занимает мало времени, потом опять идёт увеличение.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, отрабатывается здесь.

$this->handler->handle($command);

Полный код handle()

public function handle(Command $command)
    {

        $trades = Trade::create(
            $command->uuid,
            $command->userId, $command->companyId, $command->categoryId, ....
        );

        $this->repository->add($trades);

        $this->flusher->flush();
    }

Как избежать увеличения времени при выполнении задачи?

А чем он подозрительный?

Как избежать увеличения времени при выполнении задачи?

Одиночка Айс, в docker-e весь сайт крутится, там не только импорт товаров. Очереди для обновления товаров по расписанию.

Как избежать увеличения времени при выполнении задачи?

Дмитрий, обычный DTO

Как избежать увеличения времени при выполнении задачи?

Одиночка Айс, в каком смысле "самостоятельно"?

Бесплатные или бюджетные VPS?

Sanes, в каком смысле "мертвичина"?

Бесплатные или бюджетные VPS?

Добрый вечер.
https://vds.selectel.ru
Посуточная оплата (от 200 руб.)