Resultados da pesquisa a pedido "rabbitmq"
Passe o URL para o método de análise em scrapy que foi consumido pelo RabbitMQ
Estou usando o scrapy para consumir a mensagem (url) do RabbitMQ, mas quando uso o yield para chamar o método de análise passando meu url como parâmetros. O programa não vem dentro do método de retorno de chamada. Abaixo está o código a seguir de ...
Spark Structured Streaming com fonte RabbitMQ
Estou tentando escrever um receptor personalizado paraStructured Streaming que consumirá mensagens deRabbitMQ. Spark lançado recentemente [https://databricks.com/blog/2018/02/28/introducing-apache-spark-2-3.html]API DataSource V2, o que parece ...
Sobrecarga de consumidor RabbitMQ
Eu tenho lido sobre os princípios das mensagens AMQP confirma. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artigo realmente útil e bem escrito, mas uma coisa em particular sobre os agradecimentos dos ...
Arquitetura de microsserviço - envie mensagens através de serviços quando o pedido não importa
Tl; dr: "Como posso enviar uma mensagem por vários microsserviços assíncronos e não ordenados e saber quando essa mensagem passou por cada um deles?" Estou com dificuldades para encontrar o sistema / protocolo de mensagens correto para uma ...
Tendo problemas para lidar com exceções no Spring Integration
Eu sou novo na integração de primavera e estou confuso sobre como enviar mensagens de erro para uma fila de erros designada. Quero que a mensagem de erro seja um cabeçalho na mensagem original e termine em uma fila separada. Eu li que isso pode ...
aipo 'Worker-n' pid: xxxx saiu com 'exitcode 1' quando importo o hmmlearn
No meu arquivo tasks.py, quando importo o hmmlearn, from hmmlearn import hmme inicio meus trabalhadores de aipo, recebo o seguinte erro [2017-06-14 09:18:27,638: INFO/MainProcess] Received ...
Devo fechar o canal / conexão após cada publicação?
Estou usando o amqplib no Node.js e não sou claro sobre as práticas recomendadas no meu código. Basicamente, meu código atual chama oamqp.connect() quando o servidor Nó é inicializado e, em seguida, usa um canal diferente para cada produtor ...
Fluxo de ar: tarefas na fila, mas não em execução
Eu sou novo no fluxo de ar e estou tentando configurá-lo para executar pipelines ETL. Eu consegui instalar fluxo de arpostgressalsãorabbitmqEu sou capaz de testar executar o turtorial dag. Quando tento agendar os trabalhos, o agendador é capaz ...
Como usar o Rabbit dentro de um arquivo gitlab-ci.yml?
Eu quero testar comgitlab-ci.yml um servidor rpc nameko. Eu não posso conseguir fazer o Rabitt trabalhar 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 configure o número mínimo e máximo de consumidores
Eu estou usando a anotação @RabbitListener da mola amqp rabbit de: artefato spring-rabbit-1.7.1.RELEASE Gostaria de saber se existe uma maneira de configurar para cada fila o número de consumidores? Pesquisei na documentação e não encontrei nada ...