Google PubSub 如何在流式拉取消息时处理搜索到的消息

Question

我正在尝试处理 Python 中 seek(timestamp) 返回的消息。

我使用流式拉取订阅了非搜索消息：

subscriber = pubsub_v1.SubscriberClient()
subscription_path = subscriber.subscription_path(project_id, subscription_id)
future = subscriber.subscribe(subscription_path, callback=callback())

with subscriber:
    try:
        future.result()
    except TimeoutError:
        future.cancel()

def callback(msg):
    msg.ack()

我找到了 SeekRequest 对象：

https://googleapis.dev/python/pubsub/2.4.0/types.html

我原以为 seek() 会导致通过流式拉取再次接收重放的消息。但是，取而代之的是 SeekResponse 对象。

是否可以通过流式拉取回调将搜索到的消息分流到达？

Answer 1

搜索响应不包含任何消息。事实上，这是一个空洞的回应。 RPC 有一个响应，因此您可以知道搜索是否有任何错误，例如在不存在的订阅上执行。 Seek 导致重播的消息作为消息沿着与常规传递相同的路径重新传递给订阅者，例如，再次通过流式拉取接收它们。