确保在Google Cloud Run Node App中发送了PubSub批处理请求

yack溢漏

我有一个NodeJS服务器在Google Cloud Run的容器中运行。它将消息发布到PubSub。

// during handling a request, 
const topic = pubsub.topic(topicName, {
    batching: {
        maxMessages: 1000,
        maxMilliseconds: 1000,
    },
});

// publish some messages
someArray.forEach((item) => {
    topic.publishJSON(item);
});

假设someArray.length小于maxMessages。如果Node在maxMilliseconds过去之前发送响应会怎样?消息发送了吗?Google Cloud Run会在http响应后杀死该容器,还是以某种方式知道PubSub库已设置超时?

埃米尔·吉

Cloud Run不会立即终止容器,但是会在处理请求后限制其对CPU的访问。正如文档所建议的,请完成请求处理中的所有异步任务。示例中一样尝试async / await

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章