Resultados da pesquisa a pedido "pika"
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 ...
No Pika ou no RabbitMQ, como posso verificar se algum consumidor está consumindo atualmente?
Eu gostaria de verificar se umConsumidor / Trabalhador está presente para consumirmensagem Estou prestes a enviar.Se não houverTrabalhador, Gostaria de começ...
RabbitMQ, Pika e estratégia de reconexão
Estou usando o Pika para processar dados do RabbitMQ. Como parecia ter problemas diferentes, decidi escrever um pequeno aplicativo de teste para ver como lidar com desconexõe Eu escrevi este aplicativo de teste, que faz o seguinte: Conecte-se ...
Erro "etiqueta de entrega desconhecida" ocorre quando tento ack mensagens para RabbitMQ usando pika (python)
Quero processar mensagens em alguns threads, mas estou recebendo erro durante a execução deste código: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika ...
Consuma várias filas em python / pika
Estou tentando criar um consumidor que se inscreva em várias filas e processe as mensagens assim que chegarem. O problema é que, quando já existem alguns dados presentes na primeira fila, eles consomem a primeira fila e nunca vão consumir a ...
Pika blocking_connection.py timeout aleatório conectando-se ao RabbitMQ
Eu tenho um coelho mq em execução na máquinao cliente e o rabbitMQ estão executando na mesma redeA rabbitMQ tem muitos clientesEu posso pingar cliente de rab...
RabbitMQ pika.exceptions.ConnectionClosed
Tentei enviar e receber mensagens usando o RabbitMQ. Não tenho formação em ciência da computação, os termos que usei não podem ser muito precisos. Tento copiar o arquivo do tutorial: Ao enviar meu formulário html, meu script python (cgi) está ...
Como fazer um simples Pika SelectConnection para enviar uma mensagem, em python?
Estou tentando converter meu código para enviar mensagens rabbitmq via Pika. Estou com muitos problemas para entender como enviar uma mensagem simples usando uma conexão assíncrona (como SelectConnection). No meu código antigo, que uso a ...
RabbitMQ altera os parâmetros da fila em um sistema de produção
Estou usando o RabbitMQ como uma fila de mensagens em uma arquitetura orientada a serviços, onde muitos serviços web separados publicam mensagens vinculadas às filas do RabbitMQ. Essas filas, por sua vez, são assinadas por vários consumidores, ...
Como recuperar mensagens AMQP não reconhecidas de outros canais que não os da minha conexã
Parece que quanto mais tempo eu mantenho meu servidor rabbitmq em execução, mais problemas tenho com mensagens não reconhecidas. Eu adoraria reencaminhá-los. De fato, parece haver um comando amqp para fazer isso, mas ele se aplica apenas ao ...
Página 1 do 2