Resultados de la búsqueda a petición "rabbitmq"
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 ...
Spark Streaming estructurado con fuente RabbitMQ
Estoy tratando de escribir un receptor personalizado paraStructured Streaming que consumirá mensajes deRabbitMQ. Spark lanzado recientemente [https://databricks.com/blog/2018/02/28/introducing-apache-spark-2-3.html] DataSource V2 API, que ...
Sobrecarga del consumidor RabbitMQ
He estado leyendo sobre los principios de la confirmación de mensajes AMQP. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artículo realmente útil y bien escrito, pero una cosa en particular sobre ...
Arquitectura de microservicios: transporte de mensajes a través de servicios cuando el orden no importa
Tl; dr: "¿Cómo puedo enviar un mensaje a través de un montón de microservicios asíncronos y desordenados y saber cuándo ese mensaje ha llegado a través de cada uno de ellos?" Estoy luchando por encontrar el sistema / protocolo de mensajería ...
Tener problemas para manejar excepciones en Spring Integration
Soy nuevo en la integración de Spring y estoy confundido acerca de cómo enviar mensajes de error a una cola de error designada. Quiero que el mensaje de error sea un encabezado en el mensaje original y termine en una cola separada. Leí que esto ...
apio 'Worker-n' pid: xxxx salió con 'exitcode 1' cuando importo hmmlearn
En mi archivo task.py, cuando importo hmmlearn, from hmmlearn import hmmy comienzo mis trabajadores de apio, me sale el siguiente error [2017-06-14 09:18:27,638: INFO/MainProcess] Received ...
¿Debo cerrar el canal / conexión después de cada publicación?
Estoy usando amqplib en Node.js, y no tengo claras las mejores prácticas en mi código. Básicamente, mi código actual llama alamqp.connect() cuando el servidor Node se inicia y luego usa un canal diferente para cada productor y cada consumidor, ...
Flujo de aire: tareas en cola pero no en ejecución
Soy nuevo en el flujo de aire e intento configurar el flujo de aire para ejecutar tuberías ETL. Pude instalar flujo de airepostgresapiorabbitmqPuedo probar ejecutar el dag turtorial. Cuando intento programar los trabajos, el planificador puede ...
¿Cómo usar Rabbit dentro de un archivo gitlab-ci.yml?
Quiero probar congitlab-ci.yml un servidor rpc nameko. No puedo lograr que funcione el Rabitt dentro.gitlab-ci.yml:: :: image: python:latest before_script: - apt-get update -yq - apt-get install -y python-dev python-pip tree - curl ...
spring rabbit amqp @RabbitListener configura el número mínimo y máximo de consumidores
Estoy usando la anotación de spring amqp rabbit @RabbitListener de: artifact spring-rabbit-1.7.1.RELEASE ¿Me pregunto si hay una manera de configurar para cada cola el número de consumidores? He estado buscando en la documentación y todavía no he ...