pika

11열

1답변

Pika + RabbitMQ : basic_qos를 prefetch = 1로 설정하면 대기열에있는 모든 메시지를 계속 사용합니다.

저는 RabbitMQ 대기열에 각각 10 명의 작업자를 돌리는 Python 작업자 클라이언트가 있습니다. 이 같은 비트 : #!/usr/bin/python worker_count=10 def mqworker(queue, configurer): connection = pika.BlockingConnection(pika.ConnectionPara

1열

1답변

RikaMQ의 Pika 시간 초과 문제

Pika에 시간 초과 오류가 발생하는 문제가 있습니다. 동일한 코드 (아래)는 다른 환경에서도 정상적으로 작동하지만이 코드에서는 실패합니다. connection = pika.BlockingConnection(pika.ConnectionParameters(host=host)) rabbitmqctl 상태 [{pid,30059}, {running_appli

1열

1답변

Pika 0.9.5로 RabbitMQ에 큰 메시지 보내기 : 메시지가 자동으로 토끼에 의해 누락되었습니다.

결과를 가져 와서 RabbitMQ 메시지 대기열에 게시하는 샐러리 작업이 많이 있습니다. 게시 된 결과는 매우 커질 수 있습니다 (최대 몇 메가). RabbitMQ 메시지에 많은 양의 데이터를 넣는 것이 좋은 생각인지에 대한 의견이 엇갈 렸지만 다른 상황에서는이 작업을 보았습니다. 메모리를 관리하는 한 제대로 작동하는 것 같습니다. 그러나 현재의 작업 세트

0열

1답변

연결을 시도 할 때 일찍 시간 초과하는 방법

나는 rabbitmq-server에 연결을 시도하는 응용 프로그램을 가지고 있지만 서버에 연결할 수없는 경우 응용 프로그램이 지정된 시간 (초) 내에 시간 초과되도록하려고합니다. 내 문제는 내가 어떻게하는지 알 수 없다는 것입니다. 분명히하기 위해 제작자가 이전에 제한 시간에 연결하려고 시도 할 때입니다. 지금은 최대 20-30 초가 걸리기 때문입니다.

1열

2답변

pika를 사용하여 rabbitmq를 통해 파일을 보내는 방법은 무엇입니까?

rabbitmq에 대한 자습서를 살펴보고 유용하다고 생각합니다. 그러나 pika를 사용하여 rabbitmq를 통해 파일을 보내는 방법을 알려주는 문서를 찾을 수 없습니다. 코드 예제가 선호되며 pika 이외의 다른 라이브러리도 사용할 수 있습니다.

2열

1답변

Pika에서 "queue_declare"의 결과 개체에 대한 문서

다음 자습서 : http://www.rabbitmq.com/tutorials/tutorial-three-python.html에서 다음 코드가 있습니다. result = channel.queue_declare(exclusive=True) queue_name = result.method.queue 피카에 대해 문서화 된 "결과"개체는 어디에 있습니

1열

1답변

너무 많은 하트 비트를 놓친 후 응용 프로그램이 깨졌습니다.

나는 수많은 작업자에게 부하를 분산시키는 응용 프로그램을 가지고 있습니다. 지금까지 모든 직원이 동일한 VM에서 실행 중이며 아직 확장 할 필요가 없습니다. 제 문제는 3-4 일마다처럼 아래의 오류 메시지와 함께 작업자가 충돌합니다. 1200 초 내에 클라이언트와 rabbitmq 서버 사이에 연결이 없습니다 (추측). Traceback (most recen

1열

1답변

pik async에서 kombu를 어떻게 사용합니까?

나는 kombu를 사용하여 동시에 두 개의 메시지를 처리 할 서버를 작성하려고합니다. 내 수송 수단은 토끼 야. 답변은 kiku를 pika-async와 함께 사용하는 것입니다. 그러나이를 수행하는 방법에 대한 문서가없는 것 같습니다. 도움 말?

3열

2답변

여러 소비자에게 RPC 호출

메시지 흐름이 사용자가 처리 할 수있는 것보다 많은 경우 메시지를 수신하는 소비자가 있습니다.이 소비자의 다른 인스턴스를 시작하고 싶습니다. 하지만 소비자의 정보를 폴링 할 수 있기를 원한다. 팬 아웃 교환기를 사용하여 RPC를 사용하여 생산자로부터이 정보를 요청할 수 있었기 때문에 모든 제작자가 RPC- 요구. 내 질문이 먼저 가능하며 두 번째로 합리적입

15열

2답변

로거 "pika.adapters.blocking_connection"에 대한 핸들러가 없습니다.

비슷한 질문은 모두 맞춤형 로거 사용을 기반으로 한 것 같습니다. 기본값/없음을 사용하면 기쁩니다. 내 pika python 앱이 실행되고 메시지를 수신하지만 몇 초 후에 No handlers could be found for logger "pika.adapters.blocking_connection"과 충돌이 발생합니까? import pika cred