Если с сообщением что-то пошло не так
$channel->basic_ack($message->delivery_info['delivery_tag']);
, то может этого не достаточно? Может надо как-то ещё обозначить завершение импорта для rabbit? $this->handler->handle($command);
public function handle(Command $command)
{
$trades = Trade::create(
$command->uuid,
$command->userId, $command->companyId, $command->categoryId, ....
);
$this->repository->add($trades);
$this->flusher->flush();
}
можно и на localhost машины с контейнерами, но тогда надо порты разнести в конфигах nginx и compose
Результаты не очень.
Писал в файл время вставки. За ориентир взял время в 0.1 сек.
При первом импорте за такое время записалось всего 9 товаров, остальные записи заняли меньше времени. Но при последующих импортах количество товаров, которые записываются за 0.1 сек. увеличиваются.
48 -> 132 -> 676 -> 1804 -> 2164 -> 2583 -> 2657. Даже есть записи, которые выполняются за 0.2, 0.3 сек.
С чем это может быть связано?