pika

0열

1답변

도움이 필요하십니까? Rabbit MQ RPC를 사용하여 python 스크립트를 실행하는 중. Socket 104, Socket closed when connection was open 오류가 발생합니다. 내가 부족으로 인해 명성 의견을 드릴 수 없습니다로 Traceback (most recent call last): File "./server.p

1열

1답변

rabbitMQ 메시지를 저장하는 방법

나는 메시지를 서버로 송수신하기 위해 파이썬과 함께 RabbitMQ 서버를 사용하고 있습니다. 이것은 메시지를 코드로 보내는 데 사용하는 코드입니다. import numpy as np import pandas as pd import pika connection = pika.BlockingConnection(pika.ConnectionParameter

1열

1답변

SelectConnection을 통한 지연 메시지 소비

SelectConnection을 사용하여 소비자를 작성하고 싶습니다. 네트워크 인프라에는 일정 시간이 지난 후에 연결을 끊는 여러 장치가 있으므로 하트 비트 기능을 사용하고 싶습니다. 내가 아는 한, IOLoop은 주 스레드에서 실행되므로이 스레드가 메시지를 처리하는 동안 하트 비트 프레임을 처리 할 수 없습니다. 제 아이디어는 메인 스레드가 IOL

0열

2답변

도커 컨테이너에서 로컬 머신에서 실행중인 rabbitmq에 액세스하기

rabbitmq 큐에 가입 한 파이썬 스크립트를 실행하는 도커 이미지를 테스트하고 싶습니다. 내 로컬 컴퓨터에서 rabbitmq를 실행 중이며 같은 컴퓨터에서 실행중인 도커 컨테이너를 테스트하고 로컬 rabbimq 서버에 가입 시키려고합니다. docker 실행 명령에 설정된 환경 변수 'QUEUE_IP'을 (를) 스크립트가 읽고 싶습니다. 파이썬 스크립트

1열

1답변

pika python에서 'x-message-ttl'설정

pika를 사용하여 Rabbitmq 대기열에 대해 TTL을 1 초로 설정하고 싶습니다. 난 내가 1 초 후 데드 - 레터에이 특정 큐에있는 모든 메시지를 시도하고 다음과 같은 오류를 Traceback (most recent call last): File "rabt.py", line 8, in <module> arguments={'x-mes

1열

1답변

Rabbitmq 한 큐에 여러 큐브가 있습니다

동일한 큐에서 폴링하는 여러 사용자가 있고 X 초마다 큐를 확인하면 기본적으로 X 초 후에 두 명의 소비자가 동시에 basic.get을 시작할 수 있습니다. 질문 : 1. 동시에 두 명 이상의 소비자가 동일한 메시지를받을 수 있습니까? 난 단지 basic_ack가 큐에서 메세지를 지정하지 않고 삭제, 그래서 우리는 다음과 같은 시나리오가 있다고 가정합니다

0열

1답변

RabbitMQ on Docker : 포트가 연결되었을 때 Pika가 연결되면 포트없이 연결이 거부되었습니다.

pika를 사용하여 대기열에 연결하고 내 로컬 상자에서 실행하고 docker 컨테이너에서 rabbitmq를 실행하려고합니다. 나는 curl 명령과 웹 브라우저에서 보는 것으로 모두 http://0.0.0.0:15677에있는 rabbitmq에 액세스 할 수 있습니다. 따라서 rabbitmq는 정상적으로 실행되는 것처럼 보입니다. 그러나 파이썬을 사용하여 연결

0열

1답변

RabbitMQ를 사용하여 연결을 재설정했습니다.

Helo, 저는 rabbitmq에서 정말 새로 왔습니다. 나는 rabbitmq 라우터를 구축하고 pika를 사용하여 Python으로 HelloWorld를 보내려고했다. 터미널에서 나는 sudo rabbitmq-server start를한다. 나는 localhost : 15672를 입력 할 수있다. 하지만 localhost에 연결하려고하면 5672가 1 초 동

0열

1답변

연결이 유휴 상태 인 경우 channel.basic_consume 중지/오랜 시간 사용 안 함

pika 소비자 (pika.BlockingConnection)의 마지막 유휴 시간 (마지막 메시지 처리 시간)을 얻으려는 경우가 있습니다. 사용 사례 : 마지막으로 처리 된 시간이 임계 시간 (예 : 1 시간)보다 큰 경우. 나는 소비자가 나가거나 내가해야 할 일을 결정할 콜백 방법을 원한다. 사용자에게 알림을 보내는 것과 같습니다. 이렇게 할 방법이 있습

0열

1답변

RabbitMQ : 여러 대기열에서 한 번에 하나의 메시지 만 사용

RabbitMQ에서 여러 대기열에 계속 연결하려고합니다. 이 대기열 중 하나에서 새 메시지가 나올 때마다 외부 프로세스를 생성하고 싶습니다. 이 프로세스는 메시지 처리에 다소 시간이 걸릴 수 있으며 이전에 팝업 한 메시지가 완료 될 때까지 특정 큐의 다른 메시지 처리를 시작하지 않으려합니다. 가능한 경우, 외부 프로세스에서 서버를 완료하고 기다리기 위해 프