Недавно я пытался использовать библиотеку pika для создания очереди в качестве документации rabitmq...

Я использую библиотеку Пика.Я беру 2 отдельных подключения 2-х кроликов MQ серверов.Затем просто...

Программа Python, выполняющая одну очередь с несколькими потребителями Я ищу, когда очередь...

У меня есть несколько потоков, производящих сообщения, которые публикуют сообщения нечасто...

Я хочу получить все отложенные задачи в очереди для сохранения в базе данных.и удалите эти задачи...

У меня есть два процесса Python, один потребительский процесс и один производственный процесс

Я пытаюсь подключиться к удаленному серверу rabbitmq. У меня правильные учетные данные, и на...

Я использую Celery для создания фоновых подписчиков в своем приложении Flask. Каналы, которые я...

Я использую AMQP RPC (более или менее так, как это описано в документации RabbitMQ) для...

У меня есть очередь задач в RabbitMQ с несколькими производителями (12) и одним потребителем для...

Посмотрите на следующий снимок экрана В моей очереди есть привязка с обменом с именем foo,...

В моем проекте я использую службу API и ожидаю сообщения через RabbitMQ. Я использую поведенческую...

Я использую scrapy-rabbitmq для извлечения URL из RabbitMQ в мою scrapy.Я использую следующее в...

import pika params = pika.URLParameters([URL]) connection = pika.BlockingConnection(params) channel...

Я использую scrapy для получения сообщения (url) от RabbitMQ, но когда я использую yield для вызова...

Я хотел бы получить сообщения из очереди RabbitMQ, обернуть их в объект и отправить для какой-либо...

У меня есть одно сомнение.прежде всего, дайте мне знать, я думаю, что правильно или нет.здесь идет...

Я пытаюсь опубликовать сообщение для Celery через RabbitMQ, используя библиотеку python Pika...

В нашей настройке у нас есть центральный экземпляр RabbitMQ, работающий на трех хостах, каждый со...

Я работаю над большим приложением, которое требует eventlet, а теперь также требует rabbitMQ....

Я использую pika в Python3 для отправки файлов CSV с одного узла на другой, и здесь все в порядке

У меня вопрос по поводу rabbitmq.Я пытаюсь настроить систему обмена сообщениями, основанную на...

Я ожидал, что await queue.get() будет блокироваться в aio_pika, но даже если я не установил...

У меня есть сценарий, скрипт на python, который будет публиковать, скажем, сообщение 150 КБ с...

У меня есть приложение django, и я хочу получать сообщения от кролика mq.Я хочу, чтобы слушатель...