node.js - 监控和刷新 PubSub 批处理发布者队列

Question

在 Google PubSub 的Node.js 客户端中，是否可以监控批量发布者队列的大小并按需刷新？

我正在开发一个 Node/Express 服务，它使用 PubSub 批量发布者将应用程序事件推送到 PubSub 主题中。我想为批量发布者的队列大小设置一些指标和警报。此外，当此服务的实例接收到 SIGTERM 信号时，我想运行一个关闭程序以确保消息不会丢失。理想情况下，我希望在发生这种情况时刷新发布者队列中的所有消息，但至少我希望能够知道保留哪些消息（如果有的话）。该服务将在 Google App Engine 内部运行，它有一些关于生命周期事件的文档，但没有特定于 PubSub，至少我已经能够找到。

我已通读 PubSub 节点客户端文档和示例，但没有看到任何提及这些功能的内容。我确实注意到 Publisher 对象有一个publish_方法来强制发布队列，但它被明确称为私有方法，不能在外部使用，所以我犹豫要不要使用它。

有没有人有监控和刷新 PubSub 批量发布者队列的经验？任何帮助或资源将不胜感激。

标签： node.jsgoogle-cloud-pubsub

Answer 1

无法对批处理队列进行更多控制。但是有一个公共功能请求[1]用于更透明地跟踪（即记录、监控）消息生命周期，我将您的用例添加到请求中。