您如何在 Firebase Cloud Functions 中确认 PubSub 消息?
How can you acknowledge a PubSub message in Firebase Cloud Functions?
我想知道确认 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: 'Los Angeles',
state: 'CA',
country: 'USA'
};
// Will a PubSub message be acknowledged just by retuning a promise?
return await db.collection('cities').doc('LA').set(data);
}
感谢您的帮助。
如果您的函数通过返回已解决的承诺成功完成,消息将被确认。如果该函数抛出异常或 returns 被拒绝的承诺,则 pubsub 将重试该消息。
注意:Cloud Functions 在成功调用函数后在内部确认 Pub/Sub 消息。启用重试后,Cloud Functions 可以使用相同的 Pub/Sub 消息重新调用在执行期间失败的函数。
https://cloud.google.com/functions/docs/calling/pubsub#functions_calling_pubsub-java
我想知道确认 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: 'Los Angeles',
state: 'CA',
country: 'USA'
};
// Will a PubSub message be acknowledged just by retuning a promise?
return await db.collection('cities').doc('LA').set(data);
}
感谢您的帮助。
如果您的函数通过返回已解决的承诺成功完成,消息将被确认。如果该函数抛出异常或 returns 被拒绝的承诺,则 pubsub 将重试该消息。
注意:Cloud Functions 在成功调用函数后在内部确认 Pub/Sub 消息。启用重试后,Cloud Functions 可以使用相同的 Pub/Sub 消息重新调用在执行期间失败的函数。
https://cloud.google.com/functions/docs/calling/pubsub#functions_calling_pubsub-java