云函数不会捕获pubsub消息，即使被触发也不会
执行任何操作。
相关·内容
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
我有一个Firebase函数，它是由一个消息生成的PubSub。该函数要么使用消息，要么等待稍后使用它。
是否有一种方法可以从这个函数返回，而不承认消息，以便以后会是？
例如，我可以从云函数返回一个吗？如果我读得对，似乎表明这是可能的：
返回non-null functions.CloudFunction containing non-null functions.pubsub.Message A Cloud Function which you can export.
浏览 0提问于2017-08-03得票数 4
2回答
似乎GCP云函数在调用时总是确认Pubsub推送消息，即使函数崩溃或失败。
这阻止了新的发布/订阅“死信”主题功能的使用，该功能要求在将消息转发到不同的主题之前，消息传递失败。目前，消息从不会失败。
有没有办法利用“死信主题”或使用云函数的pubsub重新交付？除了在函数本身设置“重试”标志之外，这并不能解决这个问题。
浏览 1提问于2020-05-15得票数 4
背景:我们将云发布主题配置为在多个应用程序引擎服务中进行交互，在那里我们已经配置了基于推送的订阅者。我们已将其确认截止日期设置为600秒。
问题:我们已经观察到pubsub已经将相同的消息两次(从其他主题上推了两次以上)给它的订阅者，从日志中我可以看到这个消息推送的间隔只有1秒，理想的情况下，由于我们已经将ackDeadline配置为600秒，所以pubsub应该在600秒后重新尝试消息传递。
需要以下答案：
为什么同一条消息仅在1秒内被传递超过一次
在重新尝试消息传递之前，pubsub不遵守ackDeadline配置吗？
参考资料：-
浏览 2提问于2018-11-29得票数 8
我有一个云函数，它是从发布/订阅消息中触发的。此函数从不显式地确认源代码中的消息。
那么，如果确认从未发生在源代码中，此函数何时确认发布/子消息？
Update:当一个函数崩溃时，我理解消息确认不应该发生，但是对该消息的新函数调用永远不会出现在日志中。
可复制示例
创建一个名为test_topic的公共主题
使用触发器test_function创建一个名为test_topic的云函数。给它所有的默认设置，包括不重试失败。在代码本身中，使用hello_pubsub入口点将语言设置为python3.7，并使用以下代码：
导入base64 def hello_pubsub(事件，上下
浏览 1提问于2021-01-20得票数 2
我正在尝试创建一个可以由pubsub主题触发的google云函数。我使用google部署管理器模板来创建它。但我找不到任何方法来设置云功能的订户消息过滤器。我尝试在创建云函数资源之前和之后创建订阅。但从根本上说，它是行不通的。如果我在创建云函数之前创建它，那么在创建资源之后，它会覆盖subscriber函数并删除过滤器。 是否可以使用google部署管理器模板为任何pubsub云函数设置订阅者消息过滤器？
浏览 45提问于2021-02-25得票数 3
回答已采纳
架构：
我们有一个架构，它使用了两个公共主题/订阅对：
主题T1是由一个周期性的任务触发的(例如，每5分钟一次)。订阅S1是云功能的触发器。
Topic T2充当由我们的服务发布的后台作业的队列。订阅S2由云函数在每次执行时读取，以服务排队的后台作业。
这允许我们控制后台作业被服务的频率，而不依赖于它们被添加到队列中的时间。
云函数(由S1触发)通过从S2读取消息。它决定哪些后台作业已经准备好，并在成功地为作业提供服务后，ACK提供了相关的消息。未准备好或失败的作业以后将不会服务于ACK‘。
问题：
我们在使用google的官方时遇到了问题：
有时ACK‘’ed消息会再次出
浏览 0提问于2018-02-05得票数 5
回答已采纳
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回答
我想做一个设置:我的Dockerized -> Pub/Sub Dockerized仿真器<- Cloud函数Dockerized仿真器
分步骤：
我的应用程序向Pub/Sub Docker模拟器发布消息
Pub/Sub Docker模拟器在主题下注册消息
云功能/订阅主题和过程
我希望在本地运行每个服务，并在开发模式中首先测试整个设置。我成功地建立了前两部分。我能够向Dockerized仿真器发布一条消息，并通过订阅它获得数据。
在此之后，我想添加云函数(步骤3)并让函数/s订阅该主题。我还对函数进行了文档化，并将所有内容放到了docker-组合文件中，这样我
浏览 6提问于2021-05-11得票数 0
2回答
我在Google平台上设置了一些数据处理工作流。这些位置处理物理地址并返回有关它们的一些指标。工作流使用云函数和PubSub流的组合。
在工作流中有一个Google函数时，一些消息不会从触发流中被捕获，或者被多次捕获。我知道这在某种程度上是预料之中的。然而，这种情况经常发生。这足以导致10倍的多报对某些地点和其他几个没有结果。
我认为callback函数没有正确地确认消息，但我不确定应该有什么不同才能获得更可靠的消息拾取和确认。如有任何建议，敬请见谅。
用于检索度量的GCP云函数由PubSub流触发，并执行retrieve_location函数，将数据发送到不同的PubSub流。retriev
浏览 6提问于2020-08-17得票数 1
回答已采纳
1回答
我正在尝试使用云函数作为由PubSub触发的异步后台工作程序，并进行更长时间的工作(以分钟为单位)。完整的代码在这里
我的原型将数据插入到BigQuery中，并等待几分钟(以模拟更长的任务)。我正在向PubSub主题发布100条消息(间隔1秒)。
有人强调，PubSub可以多次传递相同的消息，但令我惊讶的是，100条消息中有10到40条是重复的。CF的响应时间分别为5、6、7分钟。对于4分钟的响应，我没有注意到重复。
我已经为相同的时间间隔做了多次测试。接收第一条消息和第二条消息的时间差为~30秒到~600秒。
在文档中提到“云发布/订阅可以发送重复的消息。例如，当您在消息的确认截止日期到期之
浏览 0提问于2019-05-18得票数 2
2回答
我正在开发一个Swift应用程序，它根据URL作为主键从MongoDB中提取数据。如果URL尚未在集合中，那么我希望触发Google函数来检查URL并将其添加到数据库中。
在查看云函数触发选项时，我没有看到让它监视写入MongoDB的简单方法(计划是有一个新URL表，通过云函数运行)。
我看到了PubSub和Firebase触发器，PubSub似乎是最好的选择，但是我找不到很多关于从iOS向PubSub发布消息的信息(尽管在订阅方面有很多信息)。
我确实看到了很多关于iOS的FireBase文档。我想知道是否最好写到Firebase并在上面触发，所以当应用程序的每个用户输入一个未被识别的URL
浏览 3提问于2020-08-14得票数 0
回答已采纳
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
回答已采纳
2回答
我已经为函数编写了代码，但是现在我也想在发布在pubsub上的消息时触发相同的功能。
那么，如何从Http和ICloundEventFunction(fron )调用相同的云功能呢？
浏览 6提问于2022-10-07得票数 0
这可能会导致云发布/订阅服务出现问题。但到目前为止，GCP支持并不是很有帮助，所以我在这里发布了这个问题。 根据here的说法，Pubsub消息应该有一个messageId属性，无论它是来自pull还是push。 所以我试着看看消息是什么样子的：(这里的事件是推送到云函数的pubsub消息) exports.my_cloud_function = (event) => {
logger.debug(`Event: ${util.inspect(event)}`);
} 我所期待的： { '@type': 'type.googleapis.com/goog
浏览 25提问于2019-10-05得票数 0
回答已采纳
1回答
GCP多账户自动成本控制服务
、、、、
我已经使用GCP指南中的示例代码来创建Python函数，以便在预算警报表明项目超出支出限制时发送消息并禁用项目计费。预算警报使用pubsub来激活Cloud函数。
使用示例代码方法，云函数在被监视的项目中。该项目由一个特定的Google帐户拥有，当发布预算警报时，该帐户拥有使用pubsub的预算。
我想提供云功能到其他谷歌帐户作为一项服务。我想要做的是，当我自己的帐户之外的Google帐户中触发一个预算警报时，就会向我的Google帐户下的一个项目的云函数发送一个pubsub消息。
在我看来，这就是pubsub的目的，但每当我尝试配置这种方法时，我发现我唯一能做到的组合就是将预算和云功能放在同
浏览 4提问于2021-10-20得票数 1
我有一个将数据写入Google Cloud pubsub的应用程序，根据pubsub的文档，由于重试机制而导致的重复是偶尔会发生的事情。还有失序消息的问题，这在pubsub中也没有保证。
此外，根据文档，可以使用Google Cloud Dataflow对这些消息进行重复数据删除。
我想让这些消息在消息队列(即云pubsub)中可用，以供服务使用，并且云数据流似乎确实有一个pubsubio编写器，然而，您不会回到写入pubsub可能会创建重复的完全相同的问题吗？这不也是顺序的问题吗？如何使用pubsub (或任何其他系统)按顺序传输消息？
是否可以使用云数据流从pubsub主题读取并写入另一个
浏览 46提问于2019-03-12得票数 2
我们希望通过具有pubsub触发器()的防火墙云功能接收有关主题的pubsub通知。然而，并没有指明如何设置公共订阅，而只是在它到达firebase时如何接收它。
公共订阅类型的“推送”似乎是我们想要的，所以我们不需要拉。如果我们创建一个类型为"push“的pubsub订阅，那么我们应该指定一个https端点，但据我们了解，firebase pubsub触发器是一个背景函数。是否有关联的https端点，我们应该为pubsub订阅指定，以便通知将正确到达firebase，并在我们的firebase云函数中触发pubsub触发器？
或者，我们是否需要在应用程序引擎上创建另一个推送端点，然后
浏览 4提问于2018-09-20得票数 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
我有一个从pubsub订阅读取的流式数据流，没有应用窗口。管道的第一步是读取pubsub订阅。在将消息发送到下一步之前，数据流如何决定它应该在第一步中累积多少消息，并在pubsub上继续读取更多传入消息？
浏览 0提问于2020-09-28得票数 0
是否可以触发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
我正在使用云pubsub触发云函数。但是，我希望云pubsub能够并发运行我指定的任意多个进程。有没有办法做到这一点？
浏览 18提问于2021-06-07得票数 0
回答已采纳
我已经使用本教程部署了简单的PubSub云函数触发器：
为了测试，我将大消息(超过8MB)推送到PubSub主题。
结果，云函数在日志中返回了以下错误消息：Function execution could not start, status: 'request too large'
问题是，Cloud Function开始不断地启动，产生持续的资源使用和日志消息。只有在我手动清除相关的PubSub主题后，它才会停止。
是否有防止此类行为的机制/配置？理想情况下，云函数触发器执行后，PubSub消息不会被再次拾取。
浏览 0提问于2020-08-04得票数 0
1回答
我将默认的数据流模板GCS用于Pub/Sub。云存储中的输入文件大小为300 of，每一行有2-3百万行。
启动数据流批处理作业时，会引发以下错误
来自工作人员的错误消息: org.apache.beam.sdk.io.gcp.pubsub.PubsubIO$Write$PubsubBoundedWriter.processElement(PubsubIO.java:1160)：javax.naming.SizeLimitExceededException: Pub/Sub消息大小(1089680070)超过最大批处理大小(7500000)
从文档中可以看到: Pub/Sub在一批中最
浏览 6提问于2020-08-26得票数 1
我不知道我是否要疯了，或者这是否是一个没有记录的限制(我已经浏览了GCP文档)：
是否可能在“主题A”上有一个带有pubsub触发器的云函数，而在该云函数中，向“topic B”发布一条消息。
我尝试过其他所有具有相同代码运行的触发器(云函数作为HTTP触发器、云存储触发器、Firebase触发器)，它们都成功地将发布到主题中。但是，当我(几乎字面上)将我的代码复制到一个pubsub触发器中时，当它尝试将自己的消息发布到下一个主题时，它只会挂起。该函数在尝试发布时只是超时。
因此，概括地说，在GCP中是否可能出现以下情况？
PubSub主题A->云功能-> Pubsub
谢谢您的任
浏览 2提问于2021-07-09得票数 0
回答已采纳
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
我部署了一个云运行服务，带有一个事件弧触发器，它在幕后创建一个pubsub主题，该触发器将订阅该主题。
最近，令我恐惧的是，我注意到触发器不再被调用。再往下看，我注意到pubsub主题有0个订阅。我去了云运行服务控制台，触发器仍然存在，为什么没有订阅这个主题？
我之前已经多次重新部署了服务，订阅从未像这样消失过。删除并重新创建触发器恢复了订阅，但现在我丢失了所有消息。:-(
谁能解释一下这是怎么发生的，如果它再次发生，我如何在不重新创建触发器的情况下重新启用订阅，从而丢失我所有的pubsub消息？
非常感谢。
浏览 0提问于2021-06-17得票数 1
我需要使用python脚本通过pubsub将文件批处理/流式传输到google云存储中。
我已经使用了下面的python文件，能够看到从topic发布到订阅的消息，现在我想将这些单独的消息上传到一个文件中，需要加载到云存储中。
你能建议我们在哪里可以修改以下脚本中的代码，将消息数据作为文件加载到云存储中(批量处理单个消息)
在path下面我们有python脚本: python-docs-samples/pubsub/cloud-client
subscriber.py
publisher.py
其他问题:是否可以通过pubsub流式传输文件并将其加载到云存储中。
谢谢
浏览 1提问于2018-04-20得票数 0
2回答
云功能异常的电子邮件警报
、、、
我对GCP环境很陌生。
场景：我创建了一个云函数，它基于发布到主题的消息触发。
条件：发布的每条消息都必须有。消息体和两个属性init.
云函数应该检查消息和属性是否存在(非空)。如果上述任何一个都是空云功能，则必须失败，请发出电子邮件警报。
**Sample Code**
import base64
import sys
def hello_pubsub(event, context):
pubsub_message = base64.b64decode(event['data']).decode('utf-8')
print(pubsub_messa
浏览 4提问于2021-05-31得票数 1
我有一个云函数，叫做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
1回答
我希望使用下面的语法创建一些计划好的云函数，以便在函数的源代码中定义计划：
exports.scheduledFunction = functions.pubsub.schedule('every 5 minutes').onRun((context) => {
console.log('This will be run every 5 minutes!');
return null;
});
我知道，根据，这个云函数会自动创建一个发布/子主题，以根据定义的时间表触发该函数。文档警告不要手动编辑GCP控制台中的发布/子主题，因为它可能破坏调度。
他
浏览 12提问于2022-09-16得票数 0
回答已采纳
1回答
如何从云函数触发异步作业
、、、
我有一个云函数(Python)，它是由http从web客户端触发的，它必须计算某些内容并响应快速。我想将http请求参数保存到数据库中(用于分析)。
如果我只是启动对我的postgresql的写，函数将不得不等待它，它将是较慢的。
使用PubSub，该函数还需要发布和等待响应(Docs示例)：
# Publishes a message
try:
publish_future = publisher.publish(topic_path, data=message_bytes)
publish_future.result() # Verify t
浏览 6提问于2022-04-28得票数 0
回答已采纳
我创建了一个云函数，它可以收听一个公共主题。在部署时，这将创建对正确主题的订阅，并按我所期望的方式功能。
export const handler = functions.pubsub.topic("topicName").onPublish(( message, context ) => {
// code that runs
});
使用的部署命令是：
firebase deploy --only functions
我的问题:如何为主题设置订阅筛选器，以便(例如)只在属性是特定值时运行云函数？
我知道如何在控制台中手动创建订阅，并在创建订阅时创建过滤器，但我
浏览 2提问于2021-02-01得票数 4
回答已采纳
我从云函数的正式文档中复制了这个代码片段：
exports.helloPubSub = functions.pubsub.topic('testTopic').onPublish(event => {
return console.log("test topic event data", event.data)
})
该主题存在，该函数已成功部署；如果我向其发送消息，该消息将到达设备，但此函数不会被调用。
有人帮忙吗？
浏览 3提问于2017-06-14得票数 1
回答已采纳
我在GCC有两个相似的环境。由PubSub主题触发的云功能。在这两个云函数中，将PubSub主题列为触发器。
在一个环境中，主题列出了一个订阅计数为1，它被列出为一个推到端点的的url。
在其他环境中，订阅计数为0。所以，我不知道这种对端点url订阅的推动是否与云函数触发器有关，还是仅仅是我在途中偶然设置的，而实际上并没有做任何事情呢？(我会删除订阅以查找，但它实际上是在一个活动环境中，我不想无意中破坏它！)
浏览 0提问于2018-07-05得票数 1
回答已采纳
我的应用程序的用户可以接收消息，我希望他们在文档消息创建后1小时收到通知推送。 下面是我的云函数： export const scheduler = functions.firestore
.document("profile/{uuid}/message/{messageId}")
.onCreate((change, context) => {
//code that will send a notification push in one hour
return true;
})
浏览 7提问于2020-08-03得票数 0
回答已采纳
我们正在使用GCP中的公共和云功能来协调我们的数据工作流。
我们的工作流程类似于：
pubsub1和pubsub3可以在不同的时间触发(例如:凌晨1点和凌晨4点)。他们每天被触发，从外部来源(我们的ETL，Talend)。
我们的云函数基本上在BigQuery中执行SQL。
这很好，但是我们必须手动创建一个编排数据库来记录函数何时开始和结束(回答“函数X已执行好吗？”的问题)。业务逻辑与业务逻辑有很强的耦合，因为云功能必须知道之前必须执行哪些功能，以及之后要触发哪些pubsub。
因此，我们正在寻找一个分离业务逻辑和业务逻辑的解决方案。
我发现composer (气流)可以是一个解决方案，但
浏览 0提问于2020-04-16得票数 2
回答已采纳
1回答
我有一个数据流作业，它从3个PubSub主题中读取JSON，将它们展平在一个主题中，应用一些转换并保存到BigQuery。
我使用的是具有以下配置的GlobalWindow。
.apply(Window.<PubsubMessage>into(new GlobalWindows()).triggering(AfterWatermark.pastEndOfWindow()
.withEarlyFirings(AfterFirst.of(AfterPane.elementCountAtLeast(20000),
浏览 0提问于2020-02-07得票数 0
我有一个Google主题，它有时包含数千条消息，有时甚至没有消息。这些消息表示每个任务可能需要超过一个小时的任务。最好我能够使用Cloud来实现这一点，因为它能够很好地适应需求，如果发布了一千条消息，我希望云运行实例的100多个可以旋转起来。这些运行实例是通过推送订阅启动的。问题是PubSub有600秒的确认超时时间。这意味着，为了让云运行这些消息，它们必须在600秒内完成。如果没有，PubSub将其超时，并再次发送，导致任务重新启动，直到第一个任务最终确认它为止(这将导致同一任务多次运行)。云运行通过返回2** HTTP状态代码来确认消息。文件说明
当运行在云运行上的应用程序完成处理请求时
浏览 0提问于2019-08-05得票数 11
1回答
摘要：
你好，我使用一个云函数作为由PubSub触发的异步后台工作人员。我有两个云函数，第一个将向cloud发出请求，然后，对于每个结果，将这个结果发送到PubSub。当一条消息(因此数据库中的结果之一)发送到PubSub时，将触发第二条消息。
错误：
有时候(完全随机的)第一个云函数在SQL请求之后不发送任何消息，而我在日志中有0错误，只是没有消息。
问题：
我做错什么了吗？
我要承认这个信息吗？(我想没有理由‘我在PubSub文档中看到由PubSub触发的CF会自动确认消息)
我要再发一次信吗？但是，如果我有0错误，我怎么知道我必须这样做呢？
代码：
//[requirements]
co
浏览 3提问于2021-07-08得票数 0
回答已采纳
2回答
我很难用javascript/Nodejs8 8 Google函数将有效负载发布到Google PubSub。
因此，我有一个由HTTP请求触发的云函数，然后将请求体发布到一个pubsub (配置为拉模式)。
这是我的代码：
const {PubSub} = require('@google-cloud/pubsub');
const pubsub = new PubSub();
const topic = pubsub.topic('my-fancy-topic');
function formatPubSubMessage(reqObj){
//
浏览 12提问于2019-10-09得票数 0
回答已采纳
我有一个由PubSub触发的谷歌云函数，我正在尝试将一个有错误的执行转发到一个死信主题。 我强制执行一个错误： throw Error('test') 并且该函数在状态错误的情况下结束。以错误结束函数，是否应将消息转发到Dead Letter主题？
浏览 25提问于2021-02-11得票数 0
回答已采纳
1回答
我正在尝试构建GCP云功能，它是通过云调度器触发的，用于收集来自博彩公司API的赔率数据，用于各种不同的运动和比赛，按不同的时间表进行。
我正在寻求一些关于我的方法的一些建议，关于这是否是正确的策略，或者是否有更好的方法来实现我想要的。
我一直在使用python作为代码和GCP函数(Gen 2)、、Pub/Sub。火药恢复。
目标:使用从博彩公司收集赔率数据，并在Firestore中存储所需的数据点。
计划：安装云功能(Gen 2)和Cloud一起收集每一项运动比赛的赔率数据，这些比赛按不同的时间表进行。
问题：每项运动将有3-5个博彩市场为每次活动收集.有时，庄家API提要要求您发出一个AP
浏览 16提问于2022-11-09得票数 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
回答已采纳
1回答
如何解决云函数超时错误？
、、、
import json
import base64
from google.cloud import bigquery
import ast
import pandas as pd
import sys
import pandas_gbq
def process_data(data):
#msg = str(data)
df = pd.DataFrame({"Data":data},index=[0])
df['time'] = pd.datetime.now()
lst = list(df)
df[lst] = df
浏览 1提问于2019-12-02得票数 1
回答已采纳
1回答
我在使用谷歌云PubSub应用程序接口时遇到了一些问题。最近，我开始使用云PubSub为我正在工作的聊天服务器排队消息。使用socket.io节点库将来自PubSub订阅的消息转发给用户。我可以毫不费力地完成这个设置--我运行我的node.js服务器，打开几个浏览器窗口，我就可以毫无问题地聊天了。
然而，我注意到，通常在服务器运行了几个小时后，它开始输出以下错误：
(node:2525) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): Error: Request had inva
浏览 0提问于2017-07-21得票数 5
我很想知道以下问题的最佳解决方案是什么:我让遥测数据以10秒的间隔发布到pubsub。数据按周期变化(即，一个特定的参数从400到1700，然后重置回400...) 当参数为800、1200、1500时，希望触发云函数或云运行API。 所以我想知道，如果pubsub消息说参数是这些值，我们是否可以触发云函数/云运行？ 当然，一种方法是编写一个Cloud函数，在发布新消息时始终激活，并使用"if“条件来确定是否继续。然而，我认为这是一种非常昂贵的方法，因为当这些周期特别长并且不需要频繁执行时，云函数将每10秒触发一次。所以我想知道有没有更划算的方法。
浏览 13提问于2020-09-25得票数 0
回答已采纳
2回答
我正在尝试使用google的云功能，我所有的东西都工作得很好，但是我的消息并没有被公开。
我做了这些事：
1)创建一个主题
2)创建了一个函数
3)设置的函数触发器
4)选择公共主题
5)将节点版本设置为8。
这是我的默认云功能：
/**
* Triggered from a message on a Cloud Pub/Sub topic.
*
* @param {!Object} event Event payload.
* @param {!Object} context Metadata for the event.
*/
exports.helloPubSub = (eve
浏览 0提问于2019-04-10得票数 5
回答已采纳
我需要从谷歌云pubsub.The数据是由一个物联网devices.Whenever产生的物联网设备发送数据到云我需要这些数据被从pubsub转移到firebase实时数据库。我只需要在database.How中的最后更新的值，我可以做到。
浏览 15提问于2018-07-27得票数 3
回答已采纳
我有一个由PubSub触发的Google Cloud函数。当函数成功结束时，将确认文档状态消息。
但是随机地，函数在执行10分钟后重试(相同的执行ID)。它是PubSub确认最大超时。
我还试图获取消息id，并在函数代码中以编程方式确认它，但PubSub应用程序接口响应没有消息需要使用该ID进行确认。在StackDriver监控中，我看到一些消息没有得到确认。
下面是我的代码: main.py
import base64
import logging
import traceback
from google.api_core import exceptions
from
浏览 0提问于2020-03-02得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
