当前位置: 首页 > 知识库问答 >
问题:

监视和刷新PubSub批处理发布服务器队列

魏烨熠
2023-03-14

在Google PubSub的Node.js客户机中,是否可以监视批量发布者队列的大小并按需刷新它?

我正在开发一个Node/Express服务,它使用PubSub批处理发布器将应用程序事件推送到PubSub主题中。我想在批处理发布服务器的队列大小上设置一些指标和警报。此外,当此服务的实例接收到SIGTERM信号时,我希望运行一个关闭过程,以确保消息不会丢失。理想情况下,当发生这种情况时,我希望刷新发布者队列中的任何消息,但至少我希望能够知道哪些消息(如果有的话)仍然存在。这项服务将在Google App Engine中运行,它有一些关于生命周期事件的文档,但没有针对PubSub的文档,至少我已经找到了。

共有1个答案

鱼浩荡
2023-03-14

不可能对批处理队列有更多的控制。但是有一个公共特性请求[1],用于对消息生命周期进行更透明的跟踪(即日志记录、监视),我将您的用例添加到了请求中。

 类似资料:
  • 问题内容: 我在我的Node.js应用程序中使用Mongoose,这是我的配置: 但是在控制台中,它仍然会警告我: DeprecationWarning:不建议使用当前的“服务器发现和监视”引擎,并将在以后的版本中将其删除。要使用新的“服务器发现和监视”引擎,请将选项{useUnifiedTopology:true}传递给MongoClient构造函数。 问题是什么?我以前没有使用过,但是现在它显

  • 我正在windows机器上运行Jenkins.war进程的Jenkins。“java-jar Jenkins.war”。如果我关闭服务的命令提示符,詹金斯就会倒下。我希望Jenkins在命令提示符关闭的情况下仍然处于启动状态,甚至在机器重新启动之后,这个Jenkins也将被启动。我们如何在windows机器上做到这一点?

  • 注意 许多监视器特性只在Neo4j服务器高级版和企业版才可以使用。 为了能获取Neo4j数据库的健康状况,可以采用不同级别的监控等级。这些功能一般都是通过 JMX呈现出来。 25.1. 调整远程JMX访问Neo4j的服务器 默认情况下,Neo4j高级版和企业版都不允许远程的JMX连接,因为在 conf/neo4j-wrapper.conf配置文件中的相关配置是被注释掉了的。为了启用该功能, 你必须

  • hprose 为发布服务提供了多个方法,这些方法可以随意组合,通过这种组合,你所发布的服务将不会局限于某一个函数,某一个方法,某一个对象,而是可以将不同的函数和方法随意重新组合成一个服务。 AddFunction 方法 AddFunction(name string, function interface{}, option ...Options) Service 该方法的用于发布一个函数(命名函

  • 我正在尝试使用Solace将一条大文本消息发布到Solace队列。NET API。我在另一个JAVA应用程序中订阅了该队列。当消息大小很小时,它工作得非常好。但如果消息较大,订户将无法读取消息。 是否有运行会话的方法。同步发送(消息)? 谢谢