pika

1열

1답변

Python ActiveMQ : pika 클라이언트를 사용하여 ActiveMQ에서 작업 할 수 있습니까?

ActiveMQ는 amqp:// 프로토콜을 지원하며, 이제는 Python 내에서 ActiveMQ 인스턴스에 연결하려고합니다. pika 패키지를 사용하는 것이 가능할까요? 피카의 문서를 읽으면서 RabbitMQ과 함께 사용하는 것이 디자인 된 것처럼 보였습니다. 그렇지 않으면 내가 사용하는 프로토콜이 파이썬에서 ActiveMQ에 가장 적합합니까?

0열

1답변

rabbitmq 메시지 폐기 아무도 듣고 있지 않습니다.

나는이 질문이 어리 석거나 배가 완전히 배 모양 인 경우 rabbitmq 메시지, 사과에 대한 완전한 초보자입니다. rabbitmq을 사용하는 설정은 특정 프로브에서 메시지를 보내는 것입니다. 각 프로브에는 고유 한 이름이 있습니다. 그런 다음 필요에 따라 데이터를 처리하는 중앙 집중식 서버가 있습니다. 프로브 이름에 해당하는 직접 교환 및 라우팅 키를 사

0열

1답변

소비자 취소 후 RabbitMQ pika 비동기 소비자 하트 비트 문제

RabbitMQ와 pika (python)을 사용하여 노드 (비동기 소비자)에게 작업을 제공하는 작업 대기열 시스템을 실행하고 있습니다. 작업을 정의하는 각 메시지는 해당 작업이 완료된 후에 만 승인됩니다. 때때로 이러한 노드에 대한 업데이트를 수행해야하며 노드가 완료 될 때까지 노드가 대기 한 다음 정상적으로 종료되는 종료 모드를 만들었습니다. 그런

0열

2답변

ack없이 토끼 메시지를 얻으려고했지만 성공하지 못했습니다.

토끼 대기열에있는 모든 메시지를 가져 오는 작업이 있습니다. 나는 단지 얻고, 소비 할 필요가 없다. 그래서 여기 처음 오는군요 큐에있는 모든 메시지를 얻고, 제대로 작동이 코드를 실행하면 내가 def some_function_name() : connection = rabbitObj.get_connection() channel = rabb

0열

1답변

토끼 대기열에 대한 연결 수를 제한 하시겠습니까?

나는 과 rabbitmq-3.6.6 중개인을 우분투 -16.04에 사용합니다. Request/Reply 서비스를 디자인했습니다. 모든 클라이언트가 요청을 푸시하는 단일 요청 대기열이 있습니다. 각 클라이언트는 고유 한 응답 대기열을 만듭니다. 서버는이 클라이언트를 대상으로하는 응답을이 고유 대기열에 푸시합니다. 내 API는 init 및 run의 두 메시지로

1열

1답변

rabbitmq의 Correlation_id

기본 교환에서 correlation_id와 함께 callback_queue를 사용하는 코드 조각을보고있었습니다. 그러나 사용자 정의 된 교환으로 변경하려고 시도했을 때 대기열에 대한 응답이 다시 수신되지 않습니다. 그것을 시험해보기 위해 나는이 간단한 예제를 https://www.rabbitmq.com/tutorials/tutorial-six-python.

0열

1답변

AMQP가 양방향 RPC 프로토콜 인 이유는 무엇입니까?

필자는 Pika 문서를 읽었지만 "AMQP 양방향 RPC 프로토콜은 클라이언트가 서버에 요청을 보내고 서버가 클라이언트에 요청을 보낼 수있는 이유"라는 이유를 이해하지 못합니다. 아무도 나에게 예를 들어 주실 수 있습니까? 교환을 만들 때를 의미합니까? 클라이언트 보냅니다 exchange.declare 서버 응답 : exchange.declare-확인 이

1열

1답변

pika confirm_delivery는 브로커가 메시지를 받았을 때 또는 소비자가 승인했을 때를 확인합니까?

내 프로듀서 코드에서 소비자가 언제 메시지를 수신했는지 알고 싶습니다. basic.ack channel.confirm_delivery()과 BlockingConnection을 사용하면 설명서에서 1) 브로커가 메시지를 받았거나 2) 소비자가이를 수락했다는 것을 확인해야하는지 확실하지 않습니다. (NO 소비자와)이 코드를 실행 : import pika im

0열

2답변

) (basic_ack 않습니다이

나는 다음과 같이 RabbitMQ에 대한 연결을 만든 말 콜백 함수에 배치 할 수 있습니다 connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost', 5672, '/', credentials)) channel = connection.channel() channel.qu

1열

1답변

Python Pika가 iddle에서 채널 연결을 끊습니다.

iddle 채널에 대한 시간 제한을 설정하는 방법을 이해하는 데 문제가 있습니다. 나는이 대답을 찾을 : Stop channel.basic_consume if the connection is idle/Not consuming from long time 을하지만 변수 timer_id 내 ON_MESSAGE 메서드 내 범위에서 가져옵니다. 주어진 시간에 메시지