python - 使用 Python 客户端 API 在 Google Cloud Pub/Sub 中运行同步拉取

Question

我在 Python 客户端 API 中找不到 returnImmediately 标志。有什么具体原因吗？有没有另一种方法可以从 Python 中的订阅中同步提取排队的消息？

Answer 1

Google 不提供此类内容。但是您可以通过实现自己的队列轻松解决此问题

from Queue import Queue

from google.cloud import pubsub

subscriber = pubsub.SubscriberClient()
topic = "projects/newproject-xxxxx/topics/tarunlalwani"
subscription_name = 'projects/newproject-xxxxx/subscriptions/sub1'

class SynchronousSubscription(object):

    def callback(self, message):
        print(message.data)
        message.ack()
        self.pending_messages.put(message)

    def __init__(self, subscription):
        self.subscription_future = subscriber.subscribe(subscription_name, self.callback)
        self.pending_messages = Queue()

    def consume_sync(self):
        return self.pending_messages.get()

sub = SynchronousSubscription(subscription_name)
data = sub.consume_sync()

当我测试时，它确实对我很有用