Resultados da pesquisa a pedido "pika"
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, ...
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...
SparkStreaming, RabbitMQ e MQTT em python usando pika
Apenas para tornar as coisas mais complicadas, eu gostaria de consumir mensagens da fila rabbitMQ. Agora eu sei que existe um plug-in para o MQTT no coelho ( https://www.rabbitmq.com/mqtt.html [https://www.rabbitmq.com/mqtt.html]) No entanto, ...
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, 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 ...
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á ...
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 ...
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ç...
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 ...
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 ...
Página 1 do 2