Google pub/sub停止发送消息

Question

我正在使用最新版本的google-cloud-pubsub，并且遇到了一个声称已修复的bug。

我使用的是这个版本和其中的代码示例：https://pypi.org/project/google-cloud-pubsub/

<snip>
subscription = subscriber.subscribe(subscription_name)
def callback(message):
   print(message.data)
   message.ack()
subscription.open(callback)
<snip>

问题:因此，在我运行调用订阅者的订阅者工作程序大约4-5小时后，它停止接收消息。

对如何修复它有什么建议吗？

Answer 1

您确定在您的backlog中发布了消息吗？另外，您是否在等待订阅者完成订阅？用subscription.open(callback).result替换subscription.open(callback)将导致您等待将来，这样程序就不会返回。提供更多代码可能会使调试变得更容易。