Привет. Использую pika. Нужно с одного паблишера отправлять сообщение в

3 консюмера

Вот инит:
rmq_channel.exchange_declare(exchange=RABBITMQ_EXCHANGE, exchange_type=ExchangeType.fanout)
rmq_channel.queue_declare(queue=queue, durable=True)
rmq_channel.queue_bind(queue=queue, exchange=RABBITMQ_EXCHANGE, routing_key=routing_key)

Отправка сообщения:
rmq_channel.basic_publish(
exchange=RABBITMQ_EXCHANGE,
routing_key=routing_key,
body=json.dumps(body),
properties=properties,
)

Консюмер:
rmq_channel.basic_consume(
queue=RABBITMQ_SPIDER_DATA_QUEUE,
on_message_callback=self._spider_data_queue_callback,
)

Сообщение приходит только в 1 консюмер. В чём может быть причина?

2 ответов

13 просмотров

Один консьюмер помечает сообщение как прочитанное

проблема в режиме работы ексчейнджа

Похожие вопросы

Обсуждают сегодня

Честно говоря замучался с пробросом токена из Github Secrets. Из документации все равно ничего непонятно, перебираю всевозможные варианты оттуда, пока ничего не работает. Ест...
1
pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
Sergey
9
Еще одну панику поймал: $ werf helm repo add --username gitlab --password ${CI_JOB_TOKEN} helm-werf ${HELM_REPO_V2_URL} "helm-werf" has been added to your repositories $wer...
citius
1
Вроде всё верно, imagePullSecrets находится в секции spec. Возможно в Secret указано что-то не в том формате (а именно ключ ".dockerconfigjson"). Поищу информацию. А этот Secr...
3
Вот такая неприятность на stable и ea версиях: werf helm --namespace s4c upgrade --install --atomic --timeout 5m --set s4c.version=839185f3 --set s4c.deployEnv=staging -f d...
citius
6
Подскажите, следующая проблема с werf и Github Actions, ошибка следующая - "failed to authorize: failed to fetch anonymous token: unexpected status from GET request to https:/...
1
Блин а мне как поумнеть ?
Toxin
191
Всем привет! Прохожу этот самоучитель. Дошел до # Настроим подключение к MinIO. mc alias set minio http://minio:9000 minioadmin minioadmin # Получим содержимое сохранённого...
Aleksandr
7
Всем привет. Подскажите. Следующая ошибка при выполнении команды werf ci-env github --as-file - "unable to get synchronization client id: unable to get repo ghcr.io/*** tags: ...
2
А подскажите такую штуку. Процесс сборки и деплоя проходит успешно (Github Actions), но видно что как будто сборка идёт совсем без учёт кеша, всё снова пулится и повторно слои...
1
Карта сайта