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

您确定积压的邮件中有正在发布的邮件吗？您是否在之后等待订阅者完成？将subscription.open(callback)替换为subscription.open(callback).result将导致您在将来等待，以便程序不会返回。提供更多的代码可能会使其更容易调试。