Articles of rabbitmq

Creación y enrutamiento dynamic de colas de apio.

Estoy intentando llamar a una tarea y crear una cola para esa tarea, si no existe, a continuación, inserte inmediatamente en esa cola la tarea llamada. Tengo el siguiente código: @task def greet(name): return “Hello %s!” % name def run(): result = greet.delay(args=[‘marc’], queue=’greet.1′, routing_key=’greet.1′) print result.ready() entonces tengo un enrutador personalizado: class MyRouter(object): def […]

¿Cómo crear una cola retrasada en RabbitMQ?

¿Cuál es la forma más fácil de crear una cola de demora (o estacionamiento) con Python, Pika y RabbitMQ? He visto una pregunta similar, pero ninguna para Python. Considero que esta es una idea útil al diseñar aplicaciones, ya que nos permite acelerar los mensajes que deben volver a ponerse en cola nuevamente. Siempre existe […]

RabbitMQ pika.exceptions.ConnectionClosed

Intenté enviar un mensaje y recibir un mensaje usando RabbitMQ. No tengo formación en informática, los términos que utilicé no pueden ser muy precisos. Intento copiar el archivo del tutorial: al enviar mi formulario html, mi script en python (cgi), el mensaje se envía a la cola connection = pika.BlockingConnection(pika.ConnectionParameters(host=’localhost’)) channel = connection.channel() channel.queue_declare(queue=’task_queue’, durable=True) […]

Medición del tiempo de ejecución de la tarea de apio.

He convertido un trabajo por lotes independiente para usar apio para enviar el trabajo a realizar. Estoy usando RabbitMQ. Todo se ejecuta en una sola máquina y ningún otro proceso está utilizando la instancia de RabbitMQ. Mi script solo crea un montón de tareas que son procesadas por los trabajadores. ¿Existe una forma sencilla de […]

¿Es posible mover / combinar mensajes entre colas RabbitMQ?

Estoy buscando saber si es posible mover / combinar mensajes de una cola a otra. Por ejemplo: main-queue contiene los mensajes [‘cat-1′,’cat-2′,’cat-3′,’cat-4′,’dog-1′,’dog-2′,’cat-5’] dog-queue contiene mensajes [‘dog-1, dog-2, dog-3, dog-4] Entonces, la pregunta es, (asumiendo que ambas colas están en el mismo clúster, vhost), ¿es posible mover los mensajes de dog-queue de dog-queue main-queue utilizando rabbitmqctl […]

¿Cómo puedo ver las tareas en cola en RabbitMQ?

Estoy usando RabbitMQ como mi agente de mensajes y mis trabajadores son tareas de apio. Estoy tratando de diagnosticar un problema en el que estoy haciendo tareas en cola para RabbitMQ pero Celery no responde. ¿Hay alguna manera de verificar qué tareas se ponen en cola en RabbitMQ? Me gustaría ver la fecha y la […]

No se puede iniciar Airflow worker / flower y es necesario aclarar la architecture de Airflow para confirmar que la instalación es correcta

La ejecución de un trabajador en una máquina diferente produce los errores especificados a continuación. He seguido las instrucciones de configuración y he sincronizado la carpeta dags. También me gustaría confirmar que RabbitMQ y PostgreSQL solo deben instalarse en la máquina central Airflow y no es necesario que estén instalados en los trabajadores (los trabajadores […]

¿Cómo enviar la carga JSON a RabbitMQ utilizando el complemento web?

Tengo una instancia de RabbitMQ 3.4.2 con un complemento de administración web instalado. Cuando paso al mensaje {‘operationId’: 194} a la cola usando el paquete de la cola kombu de Python, el mensaje se lee en el otro extremo como un diccionario. Sin embargo, cuando envío el mensaje utilizando la consola web: Me sale el […]

Uso de Tornado con Pika para el monitoreo asíncrono de la cola

Tengo un servidor AMQP ( RabbitMQ ) del que me gustaría publicar y leer en un servidor web Tornado . Para hacer esto, pensé que usaría una biblioteca de python amqp asíncrona; en particular Pika (una variación de eso que supuestamente es compatible con Tornado). He escrito un código que parece leer con éxito desde […]

¿Cómo puedo listar o descubrir colas en un intercambio de RabbitMQ usando python?

Necesito tener un cliente de Python que pueda descubrir colas en un intercambio de servidor RabbitMQ reiniciado, y luego iniciar un cliente para reanudar el consumo de mensajes de cada cola. ¿Cómo puedo descubrir las colas de algunas api / library python compatibles con RabbitMQ?