不确定最近发生了什么,但是我们遇到了PubSub + GCF的几个问题。
我们使用Python客户端库很好地发布了100 K大型消息。我们使用返回的消息_id来确认这一点。
然而,订阅的背景GCF (Python)并不是一致触发的。500条左右的消息(无模式):
函数完全执行,但stdout不在SD日志中。它只显示
Function execution started
Function execution took 1634 ms, finished with status: 'ok'
函数部分执行,并在代码中的任何地方崩溃,例如在第一次打印语句之后。
Funct
在启用Exactly once delivery和确认截止日期设置为600s的情况下,消息接收方仍然会在60年代或更短的时间内收到消息。这是我当前的测试代码:
final Subscriber subscriber = pubSubTemplate.getPubSubSubscriberTemplate().
subscribe("projects/xxxx/subscriptions/xxx-topic-sub", m -> {
final String s = m.getPubsu
我想知道确认PubSub消息(来自推送用户)的正确方式是什么,这是一个Firebase云函数。这是通过返回一个承诺来完成的吗? import * as functions from 'firebase-functions'
import * as admin from 'firebase-admin'
export const listener = functions.pubsub.topic('new_members').onPublish(async (message:any) => {
let data = {
name: