如何在 Firebase Cloud Functions 中确认 PubSub 消息?

米尔顿

我想知道确认 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);
}

谢谢你的帮助。

道格史蒂文森

如果您的函数通过返回已解决的承诺成功完成,则消息将被确认。如果该函数抛出异常或返回被拒绝的承诺,则 pubsub 将重试该消息。

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

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

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

从Cloud Functions触发PubSub消息

Firebase Cloud pubsub订阅停止监听消息

GCP Cloud Function无法正确接收/确认PubSub消息

Firebase Cloud Functions如何确认Cloud pub / sub

如何在Cloud Functions for Firebase中读写Firebase存储?

如何在Firebase Cloud Functions中处理错误的JSON?

如何在嵌套的承诺 Cloud Functions 中确定 Firebase 的范围

如何使用Cloud Functions中的Cloud DataStore或Cloud SQL for Firebase?

Google Cloud PubSub:不发送/接收来自Cloud Functions的所有消息

在Google Cloud PubSub中获取单个消息的大小

如何在Spring Cloud Stream中手动确认RabbitMQ消息?

是否可以在同步拉取 pubsub 中取消确认消息

消息在PubSub中的排序

如何使用 Google Cloud Functions / Tasks / PubSub 进行批处理?

如何在Firebase Cloud Functions的index.js中读取Firebase数据库条目?

即使已确认,Googlr PubSub 请求消息?

如何在Firebase Cloud Functions中捆绑和要求非JS依赖项?

如何在Cloud Functions for Firebase中获取服务器时间戳?

如何在Cloud Functions for Firebase中访问多个实时数据库实例

用于Firebase的Cloud Functions:如何在刚刚推送的列表中引用键

如何在Firebase Cloud Functions中设置特定标头的缓存?

如何在Cloud Build中为PubSub订阅指定Cloud Run端点?

如何编写一个Cloud Function来接收,解析和发布PubSub消息?

如何通过他们的 REST API NACK Google Cloud PubSub 消息?

REST API,用于监视Google Cloud pubsub中的未传递消息

REST API,用于监视Google Cloud pubsub中的未传递消息

Google Cloud PubSub在异步请求中侦听消息时抛出504 Deadline Exceeded错误

如何在确认消息中获得禁令的原因

如何为Google Cloud PubSub中的订阅提供到期时间