Google Cloud PubSub 错误：已超过截止日期

Question

我有一个简单的服务，可以将消息发布到 PubSub 主题，并且偶尔会收到“已超过截止日期”错误消息：

GaxError(RPC 失败，由 <_rendezvous rpc with deadline exceeded>)

Python 代码：

from google.cloud import pubsub
pubsub_client = pubsub.Client()
topic = pubsub_client.topic("pubsub-topic")
data = data.encode('utf-8')
message_id = topic.publish(data)

它每秒会发布几条消息，来自 Flask 网络应用程序，可能几百个中就有一个因该错误而失败。

Answer 1

原来我创建了太多的 PubSub 客户端！

我将此部分移到函数/路由之外，以便主题和客户端是全局变量，并且不会在每次调用时初始化：

pubsub_client = pubsub.Client()
topic = pubsub_client.topic("pubsub-topic")

（在实例化 Flask 之后）：

app = Flask(__name__)