Firebase仿真器，其中包含一条关于pubsub主题not触发云函数的消息
Firebase仿真器是Firebase提供的一个工具，用于在本地模拟和测试Firebase服务的功能。它可以帮助开发人员在不依赖于实际云端资源的情况下进行开发和调试。
在Firebase仿真器中，pubsub主题是一种用于实现消息传递的机制。它允许应用程序中的不同组件之间进行异步通信，通过发布和订阅消息来实现。当一个消息被发布到特定的pubsub主题时，所有订阅该主题的组件都会收到该消息。
然而，有时候pubsub主题可能无法触发云函数执行的情况。这可能是由于以下原因导致的：
- 订阅者未正确配置：确保云函数已正确订阅了pubsub主题，并且订阅者的代码逻辑正确。
- 权限问题：检查云函数是否具有足够的权限来访问pubsub主题。确保云函数的服务账号具有正确的权限设置。
- 消息格式不匹配：检查发布到pubsub主题的消息格式是否与云函数期望的格式匹配。确保消息能够被云函数正确解析和处理。
如果pubsub主题未能触发云函数执行，可以通过以下步骤进行排查和调试：
- 检查云函数的订阅配置：确保云函数已正确订阅了pubsub主题，并且订阅者的代码逻辑正确。
- 检查权限设置：确保云函数的服务账号具有正确的权限设置，可以通过Firebase控制台或命令行工具进行配置。
- 检查消息格式：确保发布到pubsub主题的消息格式与云函数期望的格式匹配。可以在云函数中打印日志或使用调试工具来检查消息的内容和格式。
- 使用Firebase仿真器进行本地调试：可以使用Firebase仿真器模拟pubsub主题的消息发布，并观察云函数的执行情况。这样可以更方便地进行排查和调试。
对于Firebase仿真器，腾讯云并没有提供类似的产品。但腾讯云的云函数（SCF）和消息队列（CMQ）等服务可以实现类似的功能。云函数可以作为事件驱动的计算服务，响应消息队列中的消息触发执行，实现类似于pubsub主题触发云函数的效果。您可以参考腾讯云云函数和消息队列的相关文档来了解更多信息：
- 腾讯云云函数产品介绍：https://cloud.tencent.com/product/scf
- 腾讯云消息队列产品介绍：https://cloud.tencent.com/product/cmq
相关·内容
1回答
我想做一个设置:我的Dockerized -> Pub/Sub Dockerized仿真器<- Cloud函数Dockerized仿真器
分步骤：
我的应用程序向Pub/Sub Docker模拟器发布消息
Pub/Sub Docker模拟器在主题下注册消息
云功能/订阅主题和过程
我希望在本地运行每个服务，并在开发模式中首先测试整个设置。我成功地建立了前两部分。我能够向Dockerized仿真器发布一条消息，并通过订阅它获得数据。
在此之后，我想添加云函数(步骤3)并让函数/s订阅该主题。我还对函数进行了文档化，并将所有内容放到了docker-组合文件中，这样我
浏览 6提问于2021-05-11得票数 0
2回答
我正在开发一个Swift应用程序，它根据URL作为主键从MongoDB中提取数据。如果URL尚未在集合中，那么我希望触发Google函数来检查URL并将其添加到数据库中。
在查看云函数触发选项时，我没有看到让它监视写入MongoDB的简单方法(计划是有一个新URL表，通过云函数运行)。
我看到了PubSub和Firebase触发器，PubSub似乎是最好的选择，但是我找不到很多关于从iOS向PubSub发布消息的信息(尽管在订阅方面有很多信息)。
我确实看到了很多关于iOS的FireBase文档。我想知道是否最好写到Firebase并在上面触发，所以当应用程序的每个用户输入一个未被识别的URL
浏览 3提问于2020-08-14得票数 0
回答已采纳
我们希望通过具有pubsub触发器()的防火墙云功能接收有关主题的pubsub通知。然而，并没有指明如何设置公共订阅，而只是在它到达firebase时如何接收它。
公共订阅类型的“推送”似乎是我们想要的，所以我们不需要拉。如果我们创建一个类型为"push“的pubsub订阅，那么我们应该指定一个https端点，但据我们了解，firebase pubsub触发器是一个背景函数。是否有关联的https端点，我们应该为pubsub订阅指定，以便通知将正确到达firebase，并在我们的firebase云函数中触发pubsub触发器？
或者，我们是否需要在应用程序引擎上创建另一个推送端点，然后
浏览 4提问于2018-09-20得票数 4
回答已采纳
我正在为一个项目使用firebase，并且正在使用下面的代码创建一个调度函数。我想每一分钟都记录一条信息。
export const timedQuery = functions.pubsub.schedule('1 * * * *').onRun((context) => {
console.log("I am running")
return null;
})
我有在http函数下工作的代码的主要逻辑，并且希望在部署到生产之前看看这在本地是否有效。通过查看firebase文档，我下载了所有的firebase模拟器，并使用"firebase模拟器
浏览 8提问于2020-04-16得票数 36
回答已采纳
我已经添加/设置了在我的localhost端口8085上运行的firebase pubsub仿真器。到目前为止，我需要使用Googel云中的pubsub，在那里我将使用他们的控制台来创建主题，还可以查看发布到这些主题的消息。
现在它在本地运行，似乎没有一个UI来管理主题/消息，而且我似乎找不到解释如何在本地pubsub上创建主题、如何审查现有主题以及如何审查消息的文档？
此外，如果我正在编写一个引用pubsub库的云函数，如果它正在运行，它会自动使用我的本地模拟器版本吗?或者我需要在我的node.js函数中的某个地方指定主机/端口吗？有没有这样的例子？
我相信他们是一个http API，我可以
浏览 0提问于2020-07-15得票数 1
1回答
我有一个云函数，它执行一些逻辑，当它完成时，它会向一个名为onPlanBeginning的主题发送一条消息
export const onNewPendingPlan = functions.firestore
.document('pendingPlanCreations/{id}')
.onCreate(async (pendingPlanDocSnap) => {
try {
//[... some logic that executes correctly ...]
console.
浏览 2提问于2020-07-07得票数 0
回答已采纳
我创建了一个云函数，它可以收听一个公共主题。在部署时，这将创建对正确主题的订阅，并按我所期望的方式功能。
export const handler = functions.pubsub.topic("topicName").onPublish(( message, context ) => {
// code that runs
});
使用的部署命令是：
firebase deploy --only functions
我的问题:如何为主题设置订阅筛选器，以便(例如)只在属性是特定值时运行云函数？
我知道如何在控制台中手动创建订阅，并在创建订阅时创建过滤器，但我
浏览 2提问于2021-02-01得票数 4
回答已采纳
我正在做一个普通的express支持的API项目，该项目使用firebase函数来执行一些离线数据处理。在许多情况下，API会将事件引发到pub-sub，然后被云函数拾取。一个典型的例子是所有的聚合(日/月的总销售额)都被推送到云函数。 我正在考虑使用firebase仿真器的集成测试套件，在那里我可以测试从API层到云函数被触发及其对数据存储的更新。在仿真器上集成测试套件为我在速度和成本上提供了很好的优势，同时也提供了快速的本地验证。 我正在使用firebase模拟器调用我的常规测试脚本 firebase emulators:exec "npm run test" 在运行测试
浏览 8提问于2021-04-19得票数 0
我发现有两个来源间接引用了这样一个事实:当使用Firebase创建Google订阅时(使用firebase-functions/v1 npm包)，Firebase会自动创建PubSub主题和PubSub订阅：
(YouTube)
(StackOverflow)
因此，您不需要(例如)使用$ gcloud pubsub topics create $TOPIC_NAME和$ gcloud pubsub subscriptions create $SUBSCRIPTION_NAME来创建主题和订阅。
这种行为在任何地方都有记录吗？
我想在Firebase之外创建我的PubSub
浏览 10提问于2022-06-18得票数 1
回答已采纳
1回答
我正在尝试将我的firebase云功能项目连接到第三方发布/订阅(一个单独的项目)。根据这个，这是不可能的，所以没有传统的方法来完成这个工作。但是，我尝试在我的防火墙云函数上使用@google-cloud/pubsub客户端手动订阅某些主题。我需要对pub/sub消息做出反应，并编写/更新某些文档。
示例(最小)：
我在sub.ts上有一个公开订阅：
const pubSubClient = new PubSub({
projectId: config.project_id,
credentials: {
client_email: config.client_email,
浏览 2提问于2020-11-15得票数 0
回答已采纳
1回答
我试图在gcp上使用terraform来实现以下目标。
云函数侦听添加到发布/副主题中的消息，一旦添加消息，云函数将被触发，如果在处理该消息时出错，则将消息放入相应的死信队列。
我不知道如何创建云功能的订阅，它也包含死信策略。目前，我正在为云函数执行以下操作，
resource "google_cloudfunctions_function" "brw-user-function-item-registered" {
// details
event_trigger {
event_type = "google.pubsub.topic.
浏览 3提问于2021-08-12得票数 0
1回答
我在Google上有一些发布/子设置，还有一些云功能运行在Firebase上。
我想在Firebase上设置一个触发器，所以当创建用户帐户时，我会在Google上发布一条消息给主题。
这个是可能的吗？我漏掉了什么明显的东西吗？
在创建帐户时，我可以触发一个云函数，而且我很高兴在此时显示控制台日志。
我正在考虑在我的Firebase触发器中添加一些类似于@google-cloud/pubsub的内容，这样我就可以在我的firebase触发器的正文中真正地设置消息了，但是这感觉有点不对。
很笨重，而不是该怎么做？
简而言之，我想我要做的是在触发器上发布到主题？
浏览 2提问于2017-11-16得票数 1
回答已采纳
1回答
我正在尝试构建GCP云功能，它是通过云调度器触发的，用于收集来自博彩公司API的赔率数据，用于各种不同的运动和比赛，按不同的时间表进行。
我正在寻求一些关于我的方法的一些建议，关于这是否是正确的策略，或者是否有更好的方法来实现我想要的。
我一直在使用python作为代码和GCP函数(Gen 2)、、Pub/Sub。火药恢复。
目标:使用从博彩公司收集赔率数据，并在Firestore中存储所需的数据点。
计划：安装云功能(Gen 2)和Cloud一起收集每一项运动比赛的赔率数据，这些比赛按不同的时间表进行。
问题：每项运动将有3-5个博彩市场为每次活动收集.有时，庄家API提要要求您发出一个AP
浏览 16提问于2022-11-09得票数 1
2回答
我已经为函数编写了代码，但是现在我也想在发布在pubsub上的消息时触发相同的功能。
那么，如何从Http和ICloundEventFunction(fron )调用相同的云功能呢？
浏览 6提问于2022-10-07得票数 0
1回答
我想这一定是一个愚蠢的原因，但我不明白为什么在运行以下命令时，只识别和部署了第一个云函数：
firebase deploy --only "functions:test1,functions:test2"
第一个函数是简单的CRON，部署得很好：
exports.test1 = functions
.pubsub.schedule('2,7,12,17,22,27,32,37,42,47,52,57 * * * *')
.timeZone('Europe/Paris')
.onRun((context) => {
con
浏览 2提问于2022-05-23得票数 1
回答已采纳
我正在尝试创建一个可以由pubsub主题触发的google云函数。我使用google部署管理器模板来创建它。但我找不到任何方法来设置云功能的订户消息过滤器。我尝试在创建云函数资源之前和之后创建订阅。但从根本上说，它是行不通的。如果我在创建云函数之前创建它，那么在创建资源之后，它会覆盖subscriber函数并删除过滤器。 是否可以使用google部署管理器模板为任何pubsub云函数设置订阅者消息过滤器？
浏览 45提问于2021-02-25得票数 3
回答已采纳
2回答
似乎GCP云函数在调用时总是确认Pubsub推送消息，即使函数崩溃或失败。
这阻止了新的发布/订阅“死信”主题功能的使用，该功能要求在将消息转发到不同的主题之前，消息传递失败。目前，消息从不会失败。
有没有办法利用“死信主题”或使用云函数的pubsub重新交付？除了在函数本身设置“重试”标志之外，这并不能解决这个问题。
浏览 1提问于2020-05-15得票数 4
1回答
我有一个云函数，它正在从pubsub订阅中进行同步拉取。使用设置为true的returnImmediately标志配置请求，这样我们就不需要等待pubsub消息出现在队列中。
const request = {
subscription: formattedName,
maxMessages: maxMessages,
returnImmediately: true,
};
...
client.pull(request)
...
当有一些消息挂起时，请求返回非常快( 100ms )，但当队列中没有消息时，调用挂起大约1.5秒，然后返回空的消息数组。
因为我在一
浏览 0提问于2018-11-20得票数 0
我试着在本地运行firebase函数。
已经使用firebase init emulators配置了模拟器。
firebase emulators:start --only pubsub工作正常，我可以看到日志：
┌──────────┬────────────────┐
│ Emulator │ Host:Port │
├──────────┼────────────────┤
│ Pub/Sub │ localhost:8085 │
└──────────┴────────────────┘
Firebase.json中的pubsub仿真器配置：
"pubsub"
浏览 3提问于2021-03-23得票数 2
回答已采纳
我有一个Firebase函数，它是由一个消息生成的PubSub。该函数要么使用消息，要么等待稍后使用它。
是否有一种方法可以从这个函数返回，而不承认消息，以便以后会是？
例如，我可以从云函数返回一个吗？如果我读得对，似乎表明这是可能的：
返回non-null functions.CloudFunction containing non-null functions.pubsub.Message A Cloud Function which you can export.
浏览 0提问于2017-08-03得票数 4
是否可以触发HTTP云函数来响应pubsub消息？
在编辑订阅时，谷歌可以将消息推送到HTTPS端点，但由于滥用原因，用户必须能够证明您拥有该域名才能做到这一点，当然，您不能证明您拥有谷歌自己的*.cloudfunctions.net域名。
我正在尝试订阅的特定主题是一个公共主题，projects/pubsub-public-data/topics/taxirides-realtime。答案可能是使用后台函数，而不是HTTP触发，但由于不同的原因，这不起作用：
gcloud functions deploy echo --trigger-resource projects/pubsub-pub
浏览 1提问于2018-07-29得票数 5
架构：
我们有一个架构，它使用了两个公共主题/订阅对：
主题T1是由一个周期性的任务触发的(例如，每5分钟一次)。订阅S1是云功能的触发器。
Topic T2充当由我们的服务发布的后台作业的队列。订阅S2由云函数在每次执行时读取，以服务排队的后台作业。
这允许我们控制后台作业被服务的频率，而不依赖于它们被添加到队列中的时间。
云函数(由S1触发)通过从S2读取消息。它决定哪些后台作业已经准备好，并在成功地为作业提供服务后，ACK提供了相关的消息。未准备好或失败的作业以后将不会服务于ACK‘。
问题：
我们在使用google的官方时遇到了问题：
有时ACK‘’ed消息会再次出
浏览 0提问于2018-02-05得票数 5
回答已采纳
1回答
我正在尝试编写一个云函数，每当在集合“传感器读数”中读取的传感器被创建时，它就会被执行：
const admin = require('firebase-admin');
admin.initializeApp(functions.config().firebase);
exports.createNotification = functions.firestore
.document('sensor-readings/{sensorId}')
.onCreate((snap, context) =>
浏览 1提问于2020-03-09得票数 0
回答已采纳
1回答
我从云函数向pubsub发送消息，并使用PubsubIO从全局窗口接收消息。有时，从云函数传递的一些消息在从Java中提取时没有出现(在我的例子中，200条消息中有4条被遗漏了)。
我的云函数：
const PubSub = require('@google-cloud/pubsub');
const pubsub = PubSub();
exports.messagePublisher= function(event,callback) {
const file = event.data;
function publishMessage(){
consol
浏览 0提问于2017-10-26得票数 0
我在GCC有两个相似的环境。由PubSub主题触发的云功能。在这两个云函数中，将PubSub主题列为触发器。
在一个环境中，主题列出了一个订阅计数为1，它被列出为一个推到端点的的url。
在其他环境中，订阅计数为0。所以，我不知道这种对端点url订阅的推动是否与云函数触发器有关，还是仅仅是我在途中偶然设置的，而实际上并没有做任何事情呢？(我会删除订阅以查找，但它实际上是在一个活动环境中，我不想无意中破坏它！)
浏览 0提问于2018-07-05得票数 1
回答已采纳
我从云函数的正式文档中复制了这个代码片段：
exports.helloPubSub = functions.pubsub.topic('testTopic').onPublish(event => {
return console.log("test topic event data", event.data)
})
该主题存在，该函数已成功部署；如果我向其发送消息，该消息将到达设备，但此函数不会被调用。
有人帮忙吗？
浏览 3提问于2017-06-14得票数 1
回答已采纳
1回答
我正在尝试使用云函数作为由PubSub触发的异步后台工作程序，并进行更长时间的工作(以分钟为单位)。完整的代码在这里
我的原型将数据插入到BigQuery中，并等待几分钟(以模拟更长的任务)。我正在向PubSub主题发布100条消息(间隔1秒)。
有人强调，PubSub可以多次传递相同的消息，但令我惊讶的是，100条消息中有10到40条是重复的。CF的响应时间分别为5、6、7分钟。对于4分钟的响应，我没有注意到重复。
我已经为相同的时间间隔做了多次测试。接收第一条消息和第二条消息的时间差为~30秒到~600秒。
在文档中提到“云发布/订阅可以发送重复的消息。例如，当您在消息的确认截止日期到期之
浏览 0提问于2019-05-18得票数 2
我对Node.js的Node.js模块有个问题。我使用Docker和PubSub模拟器创建了一个本地环境。我能够发布一条消息并使用异步拉检索它(如这里所记录的：)。然而，当我试图使用同步拉()时，我一直有以下错误：
错误:无法加载默认凭据。浏览到以获得更多信息。在GoogleAuth。(/var/code/node_modules/google-auth-library/build/src/auth/googleauth.js:167:23) at next (本机)在实现的(/var/code/node_modules/google-auth-library/build/src/auth/
浏览 0提问于2018-11-29得票数 1
回答已采纳
1回答
基于官方
我尝试使用"PubSub拉订阅“触发器创建一个云函数。
import base64
def hello_pubsub(event, context):
"""Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
context (google.cloud.functions.Context): Metadata for the event.
"""
浏览 4提问于2020-07-22得票数 4
回答已采纳
我有一个将数据写入Google Cloud pubsub的应用程序，根据pubsub的文档，由于重试机制而导致的重复是偶尔会发生的事情。还有失序消息的问题，这在pubsub中也没有保证。
此外，根据文档，可以使用Google Cloud Dataflow对这些消息进行重复数据删除。
我想让这些消息在消息队列(即云pubsub)中可用，以供服务使用，并且云数据流似乎确实有一个pubsubio编写器，然而，您不会回到写入pubsub可能会创建重复的完全相同的问题吗？这不也是顺序的问题吗？如何使用pubsub (或任何其他系统)按顺序传输消息？
是否可以使用云数据流从pubsub主题读取并写入另一个
浏览 46提问于2019-03-12得票数 2
1回答
如何使用云存储的发布/订阅通知
、、、、
我需要使用云存储的发布/订阅通知，在firebase上我有存储文件，我还需要在firebase上的另一个字段中执行这些存储进程，有时进程会失败，因此我需要使用云存储的发布/订阅通知来发布OBJECT_FINALIZE 要实现https://cloud.google.com/storage/docs/pubsub-notifications，我需要创建主题，即用户操作的暂停。 我可以在哪里创建主题？，我对文档感到困惑
浏览 13提问于2021-08-18得票数 0
回答已采纳
在我的应用程序中，消息通过MQTT从设备接收(和发送)到GC。我想从Pubsub检索(并发送)消息(稍后将该数据放入Firebase RTDB中)，但我不知道我必须引用哪个主题:我的设备发送到/devices/deviceID/state，但无法在GC控制台中为该主题创建Sub。
谢谢。J
浏览 1提问于2020-07-31得票数 0
我已经创建了两个Firebase函数-一个是HTTPS，用于将消息发布到主题，另一个是发布/订阅函数，用于响应发布到该主题的消息。
testPubSub.ts
import { pubsub } from "firebase-functions";
export const testPubSub = pubsub
.topic("high-scores")
.onPublish(async (message, context) => {
console.log("hit test pubsub");
return n
浏览 4提问于2019-09-12得票数 1
3回答
PubSub死字
、、、
我正在尝试将云函数pubsub订阅转发到一个死信主题，如下所述：
我试过了
$ gcloud pubsub subscriptions update gcf-worker-topic --dead-letter-topic=gcf-worker-dead-letter-topic
并尝试在控制台中修改gcf-worker-topic订阅。两者都给了我相同的错误：
ERROR: (gcloud.pubsub.subscriptions.update) INVALID_ARGUMENT: The supplied AppEngine URL project does not match the s
浏览 0提问于2020-06-12得票数 2
1回答
首先，感谢您阅读本文，并尝试回答它:) 在GCP (Google Cloud Plateform)上，我有一个数据库存储在云SQL上， 2个云函数，第一个用来对数据库发出请求(这个请求可以有1000多个结果)，然后将结果发布到PubSub上，第二个用来做web抓取，这要归功于木偶。 第一个云函数代码： //[Requirement]
const mysql = require('mysql')
const {SecretManagerServiceClient} = require('@google-cloud/secret-manager')
const P
浏览 13提问于2020-12-02得票数 0
回答已采纳
我有一个云函数，叫做Pub/Sub。只有在正确处理消息时，它才应该对消息进行ACK。
我在日志中看到一个内存错误，然后有一条消息‘状态结束: ok’。
该消息被确认并从我的Pub / Sub主题中删除！
复制者：
import base64
import requests
def hello_pubsub(event, context):
""" Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
浏览 5提问于2022-06-29得票数 2
我已经使用本教程部署了简单的PubSub云函数触发器：
为了测试，我将大消息(超过8MB)推送到PubSub主题。
结果，云函数在日志中返回了以下错误消息：Function execution could not start, status: 'request too large'
问题是，Cloud Function开始不断地启动，产生持续的资源使用和日志消息。只有在我手动清除相关的PubSub主题后，它才会停止。
是否有防止此类行为的机制/配置？理想情况下，云函数触发器执行后，PubSub消息不会被再次拾取。
浏览 0提问于2020-08-04得票数 0
让我们假装：
我在帐户主题中添加了“：demo/INP”，名为INP.，我有几个ESP32设备，每个设备都订阅了一个应用程序，以便在上接收一些消息。
import pubsub
topic ::= "cloud:demo/INP"
main:
print "wakeup - checking messages"
pubsub.subscribe topic --blocking=false: | msg/pubsub.Message |
sender := ?
if msg.sender.is_device:
sender
浏览 7提问于2021-08-08得票数 0
回答已采纳
1回答
我想使用java spring引导在Firebase云消息传递中创建一个主题，但我不知道如何创建它。我想向所有订阅该主题的用户发送一条消息，但我不知道如何在FCM中创建一个主题。
浏览 0提问于2021-02-24得票数 1
回答已采纳
1回答
我正在尝试让firebase模拟器使用pubsub发布来触发云函数。基本设置在云函数之外工作。尝试连接云函数时，不会出现任何消息。 我有种感觉，我做了一些根本错误的事情。 发布代码： import { PubSub, Topic } from '@google-cloud/pubsub';
const topicName = 'MyTopic';
const [taskTopic] = await pubsub.createTopic(topicName);
await this.taskTopic.publish(Buffer.from(msg)); “手
浏览 9提问于2021-01-30得票数 1
回答已采纳
我们的Java应用程序运行在Google app Engine上。它正在使用谷歌的PubSub发布和消费消息。
谷歌PubSub有两个Java客户端。推荐使用gRPC客户端，但正如本页底部所述，Google App Engine不支持。
另一个库是Google Cloud Pub/Sub API客户端-
在使用gRPC客户端库时，使用pubsub仿真器很容易。只需设置一个环境属性并完成。
Google客户端可以与PubSub PubSub仿真器一起工作吗？
在本地运行我们的应用程序时，我们的目标是能够使用PubSub仿真器，而不是连接到云中的活动实例。
浏览 7提问于2017-02-02得票数 0
回答已采纳
我正在使用云pubsub触发云函数。但是，我希望云pubsub能够并发运行我指定的任意多个进程。有没有办法做到这一点？
浏览 18提问于2021-06-07得票数 0
回答已采纳
两年前，我做了一个(独特的)混合Firebase和GCP的项目。由GCP IoT核心管理的ESP32传感器发布关于PubSub主题的消息(温度和湿度值)，也由GCP处理。PubSub topic.The上的消息发布触发了Firebase云函数。此Firebase云函数的目标是记录到达主题的数据，然后将其存储到项目的Firebase实时数据库中。最终，一个web应用程序负责绘制消息中包含的跨时间数据。 这就是大局，结果如下：https://hello-cloud-iot-core.firebaseapp.com/ 两年来一切正常，但几天前Firebase Cloud Functions不再被触
浏览 41提问于2021-02-19得票数 0
回答已采纳
我想知道确认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:
浏览 20提问于2020-01-18得票数 0
回答已采纳
1回答
上下文
我正在从事一个项目，在这个项目中，我们将在特定的GCP项目PubSub项目STAGE-1中获取关于一个GCP主题的实时数据。我们还有其他GCP项目(我们将其视为较低级别的环境)，例如DEV-1、QA-1等，在这些项目中，我们希望将这些消息重新发布到数据实时数据中，这只是STAGE-1 GCP项目下的主题的补充。
问题
是否有一种方法可以将消息重新发布(桥)配置为跨GCP项目的其他PubSub主题？
如果云PubSub本机不支持这种设置，那么可能采用什么方法呢？
P.S.我是PubSub的新手。
提前谢谢。干杯:)
浏览 2提问于2021-11-19得票数 0
4回答
我正在使用Pubsub(推送)和Cloud Run，我将在其中部署一个使用Spring Boot构建的Java应用程序。 我有两个案子。假设我有Service A在云上运行时，由于负载较高，需要运行10个容器/实例。我想： 推送消息(来自云函数)到全部(广播)的容器Service A 推送消息(来自云函数)到单一任意容器Service A 背景：我的Cloud Run服务将使用服务器发送的事件将数据直接推送到客户端/浏览器。这当然意味着容器/实例将保持一种状态。在某些情况下，我需要将消息推送到所有sse/ws连接 在所有容器上(想象一个带有公共聊天室的聊天应用程序，其中每个人都可以看到发布的
浏览 69提问于2021-02-14得票数 1
1回答
我正在运行项目，该项目将消息发布到PubSub主题并触发后台云功能。
我读到，在大量的消息中，它执行得很好，但是对于每秒几百条甚至几十条消息这样的较小数量的消息，Pub/Sub可能会产生很高的延迟。
发布单个消息的代码示例：
const {PubSub} = require('@google-cloud/pubsub');
const pubSubClient = new PubSub();
async function publishMessage() {
const topicName = 'my-topic';
const dat
浏览 4提问于2020-03-23得票数 0
所以我已经通过firebase-tools用firebase init functions初始化了一组firebase函数。然后，我编写了一个如下函数： const functions = require('firebase-functions');
exports.resizeImage = functions.storage.object().onFinalize(async (object) => {
functions.logger.info("Uploaded object!");
}); 然后，我使用cd functions npm r
浏览 7提问于2020-10-10得票数 0
2回答
我使用云发布/订阅和云函数。
现在，我想将一条消息发布到一个将触发背景云功能的主题上。
但是我想在特定的持续时间后触发我的云功能，比如30秒之后。
我该怎么做？
更新：
这是我的建筑，对吗？
浏览 1提问于2019-03-11得票数 0
回答已采纳
1回答
我有一个spring boot应用程序，我在其中通过在应用程序启动时传递订阅id来创建订阅者。
import com.google.cloud.pubsub.v1.MessageReceiver;
import com.google.cloud.pubsub.v1.Subscriber;
import com.google.pubsub.v1.ProjectSubscriptionName;
...
...
public void startAndWait() {
ProjectSubscriptionName subscriptionName = ProjectSubscriptionNam
浏览 0提问于2019-07-17得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
