Articles of rabbitmq

Celery & RabbitMQ ejecutándose como contenedores de ventana acoplable: se recibió una tarea no registrada de tipo ‘…’

Soy relativamente nuevo en docker, apio y rabbitMQ. En nuestro proyecto, actualmente tenemos la siguiente configuración: 1 host físico con varios contenedores de ventana acoplable en ejecución: 1x rabbitmq: contenedor de 3 gestiones # pull image from docker hub and install docker pull rabbitmq:3-management # run docker image docker run -d -e RABBITMQ_NODENAME=my-rabbit –name some-rabbit […]

No se puede conectar a RabbitMQ en Heroku con pika debido a ProbableAccessDeniedError

Acabo de configurar un complemento RabbitMQ en Heroku. Después de desarrollar mi aplicación para poner en cola y consumir mensajes que se ejecutan en una instancia local, la implementé en Heroku y aún no he podido conectar con éxito. El nombre de usuario / contraseña y nombre de host / puerto / vhost son todos […]

Python y RabbitMQ: ¿la mejor forma de escuchar consumir eventos de múltiples canales?

Tengo dos instancias de RabbitMQ separadas. Estoy tratando de encontrar la mejor manera de escuchar los eventos de ambos. Por ejemplo, puedo consumir eventos en uno con lo siguiente: credentials = pika.PlainCredentials(user, pass) connection = pika.BlockingConnection(pika.ConnectionParameters(host=”host1″, credentials=credentials)) channel = connection.channel() result = channel.queue_declare(Exclusive=True) self.channel.queue_bind(exchange=”my-exchange”, result.method.queue, routing_key=’*.*.*.*.*’) channel.basic_consume(callback_func, result.method.queue, no_ack=True) self.channel.start_consuming() Tengo un segundo anfitrión, “host2”, […]

Biblioteca de Good Python para AMQP

¿Puede recomendar qué biblioteca de Python usar para acceder a AMQP (RabbitMQ)? De mi investigación el pika parece ser el preferido.

¿Debo usar apio o zanahoria para un proyecto de Django?

Estoy un poco confundido en cuanto a cuál debo usar. Creo que cualquiera funcionará, pero ¿es uno mejor o más apropiado que el otro? http://github.com/ask/carrot/tree/master http://github.com/ask/celery/tree/master

¿Por qué usar el apio en lugar de RabbitMQ?

Según tengo entendido, Celery es una cola de tareas distribuida, lo que significa que lo único que debería hacer es enviar tareas / trabajos a otros servidores y recuperar el resultado. RabbitMQ es una cola de mensajes, y nada más. Sin embargo, un trabajador podría simplemente escuchar el MQ y ejecutar la tarea cuando se […]

Pasando de RabbitMQ a Amazon SQS

Nuestra puesta en marcha actualmente utiliza RabbitMQ (con Python/Django ) para las colas de mensajería, ahora planeamos mudarnos a Amazon SQS por su alta disponibilidad y su función de cola retrasada. Pero estoy leyendo en INTERNET en todas partes que SQS tiene un rendimiento lento y también es muy rentable, por lo tanto, ¿es una […]

Lista de apio progtwigda devuelve Ninguno

Soy bastante nuevo en Celery y he estado intentando configurar un script simple para progtwigr y anular tareas. Sin embargo, siento que estoy teniendo un problema extraño. Tengo la siguiente configuración from celery import Celery app = Celery(‘celery_test’, broker=’amqp://’, backend=’amqp’) @app.task def add(x, y): return x + y Arranco mi servidor de apio muy bien […]

Cómo conectar el apio a rabbitMQ usando SSL

Estoy tratando de conectar apio con un agente de rabbitMQ usando certificados SSL. Este es el código: from celery import Celery import ssl broker_uri = ‘amqp://user:pwd@server:5672/vhost’ certs_conf = { “ca_certs”: “/certs/serverca/cacert.pem”, “certfile”: “/certs/client/rabbit-cert.pem”, “keyfile”: “/certs/client/rabbit-key.pem”, “cert_reqs”: ssl.CERT_REQUIRED } app = Celery(‘tasks’, broker=broker_uri) app.conf.update(BROKER_USE_SSL=certs_conf) app.send_task(‘task.name’, [{‘a’: 1}]) Cuando bash ejecutar este código obtengo la siguiente excepción: […]

Apio: ¿cómo limitar el número de tareas en la cola y dejar de alimentar cuando está lleno?

Soy muy nuevo en Celery y aquí está la pregunta que tengo: Supongamos que tengo un script que se supone que constantemente busca datos nuevos de la base de datos y los envía a los trabajadores usando Celery. tareas.py # Celery Task from celery import Celery app = Celery(‘tasks’, broker=’amqp://guest@localhost//’) @app.task def process_data(x): # Do […]