클라우드 pubsub 저속 폴링 속도

Question

하나의 구독으로 pubsub 주제가 있는데 두 명의 다른 구독자가 여기에서 빠져 나오고 있습니다. stackdriver를 사용하여 구독에 ~ 1000 개의 메시지가 있음을 알 수 있습니다. 각 가입자는 다음과 같은 설문 조사 루프를 실행합니다

client = pubsub.Client() 
topic = client.topic(topic_name) 
subscription = pubsub.Subscription(subscription_name) 

while True: 
    messages = subscription.pull(return_immediately=True, max_messages=100, client=client) 
    print len(messages) 
    # put messages in local queue for later processing. Those processes will ack the subsription 

내 문제는 느린 폴링 속도입니다 - 내가, 내가 때마다 단지 몇 가지 메시지를 받고 있어요 폴링하기 위해 대기중인 메시지의 많음이있다하더라도. 또한 많은 답변이 메시지없이 다시 나타납니다. stackdriver에 따르면, 내 메시지는 1.5 메시지/초입니다.

나는 return_immediately=False을 사용하려고 시도했는데, 그 속도가 약간 빨라 졌는데, 풀링 속도는 ~ 2.5 메시지/초로 증가했지만 여전히 예상했던 속도는 아니었다.

아이디어를 끌어 올리는 방법을 알려주세요. 어떤 pubsub 설문 조사 모범 사례?

Answer 1

끌어 오기 속도를 높이려면 한 번에 두 개 이상의 미해결 된 끌어 오기 요청이 있어야합니다. 얼마나 많은 사람들이 얼마나 빨리 그리고 얼마나 많은 장소에서 게시하는지에 달려 있습니다. 적어도 몇 가지 뛰어난 것을 항상 필요로 할 것입니다. 그들 중 한 명이 돌아 오자 마자 다른 풀 요청을하십시오. 그렇게하면 Cloud Pub/Sub가 가입자에게 메시지를 전송할 준비가 될 때마다 메시지 수신 대기 요청이 발생합니다.