google-cloud-pubsub 相关问题

使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。

无法使用 PubSub 让云函数每 15 分钟运行一次

我一直在尝试运行常规云函数,以每 15 分钟运行一次向适当的用户发送通知。 到目前为止,我一直无法让该函数重复运行(似乎......

回答 1 投票 0

如何在 Apache Beam 管道中记录传入消息

我正在编写一个简单的 apache beam 流管道,从 pubsub 主题获取输入并将其存储到 bigquery 中。几个小时以来,我以为我什至无法阅读消息,因为我只是在尝试......

回答 2 投票 0

类型错误:函数缺少 1 个必需的位置参数:'self'

我在 GCP 中有一个函数可以在本地计算机上运行,但是当我将其推送到 GCP Cloud Functions 时,我不断收到错误。 该函数从 PubSub 收集消息,然后使用 ...

回答 1 投票 0

pubsub 调用的 Cloudfunction v2 会记录“允许未经身份验证的调用或设置正确的授权标头。”

我创建了一个由 pubsub 主题/订阅消息发布事件调用的 cloudfunction v2。但是,每当触发时,我都会收到此错误: { http请求:{ 延迟:“0s” 公关...

回答 4 投票 0

GCP pubsub Push订阅支持自定义属性吗?

我有 GCP pubsub Push 订阅。此订阅正在推送到 GCP Cloud 运行实例,该实例接收作为 HTTP 请求的 pubsub 消息。我目前正在尝试添加自定义属性...

回答 1 投票 0

在 Cloud PubSub 中发布非字符串消息

几乎所有通过网络提供的发布/订阅示例都使用字符串消息。 如何将 Java 对象、JSON 或 AVRO 等文本消息以外的消息发布到主题,然后通过

回答 4 投票 0

Gmail API - 推送通知 - 新电子邮件到达时收到 2 条通知

我想编写一个Python脚本,每次当我的收件箱收到新消息时它都会通知我。为此,我使用了 Google 的 Pub/Sub 服务。我已经创建了主题和订阅...

回答 1 投票 0

PubSub 到 BigQuery 订阅:不起作用

Avro 架构 { “命名空间”:“com.x.y.z.model”, “名称”:“XYZ数据点”, “类型”:“记录”, “字段”:[ { “……

回答 1 投票 0

使用 Apache Beam 和 Python 将带有 ordering_key 的消息写入 Google PubSub

我正在尝试使用 Apache Beam (https://cloud.google.com/pubsub/docs/publisher) 将带有 ordering_key 的 Google PubSub 消息写入主题。虽然带有 ordering_key 的 Google Pubsub 是测试版功能...

回答 1 投票 0

GCP PubSub 将历史消息重播到特定订阅

我有一个 GCP PubSub 主题和多个使用应用程序,每个应用程序都有自己的订阅。 Topic 的最大保留时间为 31 天,消息存储在数据库中。用途...

回答 1 投票 0

Terraform gcloud

我在 Google Cloud 中进行了以下设置: 应用程序“生成器”,将消息发布到 Google Cloud PubSub 主题。 使用唯一消息的应用程序“worker”。 任何无效的 PubSub

回答 3 投票 0

GCP Pub/sub 同步请求订阅的预期延迟

我的应用程序将从 GCP Pub/sub 接收某些事件,并且应用程序应该使用 cron 作业(主要是每小时一次)处理这些事件。所以,我打算使用同步拉动

回答 1 投票 0

使用 Google Cloud Build 和 Pub/Sub 触发器来克隆和运行存储库

我是否可以使用 Google Cloud Build 触发器来触发 Google Pub/Sub 事件来拉取存储库并为其构建代码?或者这只能通过 Cloud Build 实现...

回答 1 投票 0

数据流中的“无根单位”错误,从 Golang 中的 PubSub 到 Bigquery

我正在尝试从 PubSub 读取消息,然后写入 DataFlow 中的 BigQuery 表。但是,我通过使用直接运行器遇到了“无根单位”错误。 这是我的代码; 包主 导入...

回答 2 投票 0

如何使用Python(或API)接收Firebase消息

我有一组运行 python 的设备,并且需要能够分别向/从它们发送消息。我知道可以向单个 InstanceID 令牌发送消息,但我...

回答 1 投票 0

pubsub 是否为每次调用推送端点生成日志?

是否可以在任何地方看到 pub/sub 向特定推送端点发出的请求列表?我不需要太多信息——比如“此时调用此端点”...

回答 1 投票 0

如何从 Mongo Atlas 触发器向 GCP PubSub 发出经过身份验证的请求

我有以下代码: 导出 = 函数(changeEvent) { var {PubSub} = require("@google-cloud/pubsub"); var avro = require("avro-js"); const keyFilename = context.val...

回答 1 投票 0

使用 Spark Dataproc 在 Pub/Sub 中写入

我想使用Dataproc Spark在BigQuery上运行2个每分钟执行一次的SQL文件,然后将结果写入pub/sub。 我不确定是否可以同时使用这两种技术。 是否...

回答 1 投票 0

如何配置 Google Workspace 提醒中心以向 PubSub 主题发布提醒?

我正在构建一个通知系统,当员工采取触发 DLP 规则的操作时,该系统将通知处于松弛状态的员工。 我想要达到的理想流程是: 员工采取行动 > 规则三...

回答 2 投票 0

持续发布

我正在使用谷歌云 PubSub Java 客户端库,并且有一个关于发布保证的基本问题。在下面的代码中,如果发布成功返回,即代码到达 // do

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.