python-pika

1열

1답변

영구 전달 모드를 사용하면 작업자가 실패한 메시지를 즉시 선택하도록합니다.

Python-Pika을 사용하여 메시지를 가져 오는 위치는 RabbitMQ Server입니다. 문제는 내가 persistent delivery mode을 활성화하고 작업자가 메시지를 처리하지 못하는 경우입니다. 메시지를 릴리스하는 대신 RabbitMQ 연결이 재설정 될 때까지 메시지를 보류합니다. 동일한 작업을 포함하여 사용 가능한 작업자로부터 적절한 시간

1열

1답변

새앙 토끼

다음 코드를 사용하여 RabbitMQ 큐에 대한 소비자의 총 수를 가져옵니다 것은 내가 소비자의 수의 수를 얻기 위해 사용하는 것입니다. 그러나 소비자가 대기열에서 소모하는 경우이 수는 0으로 인쇄됩니다. 이제 대기열에서 소비하는 총 소비자 수가 필요합니다. 이 나타납니다 RabbitMQ 관리 (소비자 : 0 활성 25 총) 대기열에 메시지가있는 동안 대기

0열

1답변

도커 odoo 9 설치 pika 오류

나는 달성하고 싶은 간단한 도커 빌드가 있습니다. odoo로부터 새앙 토끼 라이브러리 9를 설치 : 기본 이미지 odoo를 당겨 9 RUN은 새앙 토끼 를 설치 PIP하지만 난이 오류를 받고 있어요으로 진행할 수 없습니다. enter image description here btw, 윈도우 환경에서 도커를 사용하고 있습니다.

0열

1답변

구독 중에 콜백을 추가하여 파일을 쓰는 방법

이것은 아마도 pika를 사용하는만큼 파이썬 콜백에 관한 질문 일 것입니다. RabbitMQ의 대기열에 가입하고 전달 된 메시지의 페이로드를 처리 한 다음 해당 페이로드를 일련의 (디스크) 파일에 쓰는 코드를 개발하려고합니다. 따라서 간단한 "Hello World"예제 인 http://www.rabbitmq.com/tutorials/tutorial-one-

0열

2답변

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

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

0열

2답변

파이썬은

다음 이 기능이 예상 결과를 출력 producer.py def callback(ch, method, properties, body): result = body.decode() resp = JSONEncoder().encode(result) json_resp = json.loads(resp) print(json_resp) ch.basic_ack(de

0열

1답변

rabbitmq 서버를 통한 게시 및 구독

한 노드에서 메시지를 보내고 다른 노드에서 메시지를 받기 위해 대기하는 시나리오가 필요합니다. 메시지를받은 후 각 노드가 수신자가되어 메시지를받은 후 다시 게시자가됩니다.

0열

1답변

pika (python 클라이언트)를 사용하여 RabbitMQ에서 MQTT 메시지 게시/구독

기존 RabittMQ 서버 설정이 있고 MQTT 플러그인이 mqtt 메시지를 게시/구독 할 수 있도록 설정했습니다. 기존 대기열 메시지를 처리 할 pika 클라이언트가 있습니다. 지금 당장은 동일한 pika on_message() 핸들러를 사용하여 mqtt 메시지를 처리하려고합니다. eclipse paho 클라이언트를 통해 mqtt 메시지를 게시하고 구

0열

1답변

Pika는 우분투에서 RabbitMq에 연결할 수 있지만 Centos에서는 작동하지 않습니까?

동일한 코드가 우분투에서 작동 할 수 있으며 Centos에서 작동하지 않습니다! 방화벽이 이미 닫혔습니다! 우분투 16.04, 파이썬 버전 3.5.2. Centos 7, python 버전 3.5.2. 우분투 및 센소스는 새로 설치된 가상 박스입니다! RabbitMq config tls! CentOS에서 연결하는 경우 rabbitmq disable ssl은

2열

1답변

Twisted and Pika - 메시지 확인 호출에 콜백을 추가하는 방법은 무엇입니까?

피카의 twisted protocol adapter을 사용하고 있습니다. 내가 메시지를 성공적으로 처리 한 한 때 나는이 호출을 사용하여 RabbitMQ에 승인을 보내 channel.basic_ack(delivery_tag=delivery_tag) basic_ack 호출은 비동기 적으로 발사하는 것 같지만 그래서 나는 콜백 또는 errback을 추가 할