Комбу отключается при публикации - PullRequest
0 голосов
/ 16 мая 2018

У меня проблемы с публикацией сообщений с помощью Kombu 4.1. Мой вариант использования состоит в том, что у меня есть сервер, который собирает сообщения из очереди rabbitmq (очередь 1), выполняет некоторую задачу обработки и затем повторно публикует их в другую очередь (очередь 2). У меня нет проблем с использованием очереди 1, но когда я пытаюсь опубликовать в очереди 2, возникает прерывистая ошибка, которая заставляет меня отключиться от rabbitmq. Я активировал обе попытки и комбинированный ConsumerProducerMixin, но проблема остается. Я также опубликовал этот выпуск на странице Kombu GitHub безрезультатно: - https://github.com/celery/kombu/issues/857

Есть ли у кого-нибудь понимание этой проблемы, будет ли она исправлена ​​в Kombu 4.2, есть ли обходные пути, не включающие переключение на другую библиотеку?

Спасибо

1 Ответ

0 голосов
/ 10 июля 2018

Не совсем ответ о том, почему это происходит, но два обходных пути, которые, кажется, решают проблему для нас.

  • Установите heartbeat=0 при открытии нового Соединения (но, возможно, вам нужны сердцебиения).
  • Понизить версию комбу до v4.0.2. Как указано здесь , task_publish_retry_policy кажется оторванным от kombu==4.1.0

Надеюсь, это поможет!

...