¿Cómo puedo recuperar mensajes AMQP no reconocidos de otros canales que no sean los de mi conexión?

Parece que cuanto más tiempo mantengo mi servidor rabbitmq en funcionamiento, más problemas tengo con los mensajes no reconocidos. Me encantaría solicitarlos. De hecho, parece haber un comando amqp para hacer esto, pero solo se aplica al canal ...

Pass la url en el método de análisis en scrapy que se consumió de RabbitMQ

Estoy usando el scrapy para consumir el mensaje (url) del RabbitMQ, pero cuando uso el rendimiento para llamar al método de análisis pasando mi url como parámetros. El programa no viene dentro del método de devolución de llamada. A continuación ...

¿Cómo crear una cola retrasada en RabbitMQ?

Error "etiqueta de entrega desconocida" se produce cuando intento enviar mensajes a RabbitMQ usando pika (python)

Quiero procesar mensajes en algunos hilos pero recibo un error durante la ejecución de este código: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika ...

¿Cómo hacer una simple Pika SelectConnection para enviar un mensaje, en python?

Estoy tratando de convertir mi código para enviar mensajes rabbitmq a través de Pika. Tengo muchos problemas para comprender cómo enviar un mensaje simple utilizando una conexión asincrónica (como SelectConnection). En mi antiguo código, que ...

SparkStreaming, RabbitMQ y MQTT en python usando pika

Solo para complicar las cosas, me gustaría consumir mensajes de la cola rabbitMQ. Ahora sé que hay un complemento para MQTT en conejo ( https://www.rabbitmq.com/mqtt.html [https://www.rabbitmq.com/mqtt.html]) Sin embargo, parece que no puedo ...

RabbitMQ pika.exceptions.ConnectionClosed

Intenté enviar un mensaje y recibir un mensaje usando RabbitMQ. No tengo experiencia en informática, los términos que utilicé no podrían ser muy precisos. Intento copiar el archivo tutorial: cuando envío mi formulario html, mi script de Python ...

Tiempo de espera aleatorio de Pika blocks_connection.py que se conecta a RabbitMQ

RabbitMQ, Pika y estrategia de reconexión

Estoy usando Pika para procesar datos de RabbitMQ. Como parecía tener diferentes tipos de problemas, decidí escribir una pequeña aplicación de prueba para ver cómo puedo manejar las desconexiones. Escribí esta aplicación de prueba que hace lo ...

Consume múltiples colas en python / pika

Estoy tratando de crear un consumidor que se suscriba a múltiples colas y luego procese los mensajes a medida que lleguen. El problema es que cuando hay algunos datos ya presentes en la primera cola, consume la primera cola y nunca va a consumir ...