pika

0열

2답변

셀러리 작업에서 비동기 rabbitmq 클라이언트 pika 또는 pyrabbit을 어떻게 구현할 수 있습니까?

약 1 천만 개의 작업을 처리하기 위해 celery 및 rabbitmq을 사용하고 있습니다. 작업의 출력은 원격 rabbitmq에 저장된 json입니다. Pika을 사용하여 원격 rabbitmq의 다른 대기열에 메시지를 게시했습니다. 현재 pika가 비동기 적이기 때문에이 오류 pika.exceptions.ConnectionClosed: Connection

1열

1답변

다중 처리 시스템에서 Pika 소비자를 다루는 방법

필자는 Pika와 함께 일부 대기열을 사용하는 다중 프로세스 및 다중 스레드 시스템을 보유하고 있습니다. 시스템이 멀티 스레드 소비자와 함께 단일 프로세스에서 작동하면 잘 작동하지만 다중 프로세스 (생성 된 프로세스)에서 작동 할 때 일부 소비자는 큐에서 중복 데이터를 가져옵니다. 소비자가 대기열에서 데이터를 가져 오는 경우 다른 소비자가 해당 대기열에서

1열

1답변

피카 및 gevent - 호환성

은 geika와 호환되는 Pika입니까? gevent 패치 표준 소켓 라이브러리와 함께 제공된 원숭이 패치 -이 기능은 gevent가 설치된 유효한 pika를 전환하기에 충분합니까? 감사합니다. 매트.

0열

1답변

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

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

0열

1답변

Pika에서 TTL을 구현합니까?

내 대기열에서 특정 시간 내에 처리되지 않은 메시지를 삭제하고 싶습니다. 저는 이미 소비자에게 게시 시간을 기록하여이를 수행합니다. 그러나 아무도 서브 스크립 션을하지 않는 경우 대기열이 부실 메시지를 단순히 삭제하는 것이 좋습니다. Pika의 메시지에 만료 시간 (TTL)을 설정할 수 있습니까? RabbitMQ 문서는 그것에 대해 이야기하지만 Pika 문

0열

1답변

rabbitmq에서 내부적으로 메시지를 저장하는 방법과 원래 형식으로 다시 검색하는 방법은 무엇입니까? 내가 파이썬을 다음과 같이 rabbitmq 메시지를 게시하려고

다음 import findspark findspark.init("/home/spark/spark-2.2.0") from pyspark.sql import SparkSession import pika connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel

0열

1답변

pika를 위해 꼬인 연결로 소비자를 다시 연결하는 방법은 무엇입니까?

은 내가 RabbitMQ 소비자로 새앙 토끼 트위스트 연결을 사용하고, 여기에 내 코드입니다 : @defer.inlineCallbacks def run(connection): queue_name = 'aaa' channel = yield connection.channel() queue = yield channel.queue_de

7열

1답변

특정 메시지가 수신 될 때까지 jupyter 노트북 셀 실행을 차단하십시오.

jupyter 노트북과 호환되는 Python 용 비동기 분산 컴퓨팅 엔진을 구현하려고합니다. 시스템은 사용자가 특정 계산 결과 (예 : 예상 결과가있는 메시지가 전달 될 때까지 주어진 노트북 셀의 실행을 차단)를 기다릴 수 없게 만드는 '푸시 알림'접근 방식을 기반으로합니다. 정확히 말하면, 내가하려고 해요 : 노트북 이벤트 루프를 jupyter 새로운 작

1열

1답변

RabbitMQ basic_publish가 비동기입니까?

다음 제작자 코드가 있습니다. 메시지은 일부 계산 후에 얻은 dict 데이터입니다. 큐에 메시지을 게시하고 싶습니다. 그런 다음 다른 계산을 위해 메시지을 빈 dict로 재설정합니다. 그러나 소비자는 항상 대기열에서 빈 dict를 받고있다. 기분이 메시지 게시되기 전에 재설정됩니다 (비동기?). 동기시키는 방법? message = {a big dict ..

-2열

1답변

원격 RabbitMQ 서버에 연결하는 동안 AccessDeniedError

RabbitMQ & python pika로 두 개의 호스트를 연결하려고합니다. 여기 는 노동자입니다 : #!/usr/bin/env python import pika, time NEW_TASK_HOST_IP = '192.168.0.2' credentials = pika.PlainCredentials('login-to-remote', 'pass') co