使用托管在Google基础架构上的可靠,多对多的异步消息传递来连接您的服务。 Cloud Pub / Sub会根据您的需要自动扩展,并为构建您自己的强大全球服务奠定基础。
如何使用MQTT订阅遥测事件并使用C代码? (这是一个微控制器代码)我可以将数据发送到指定的主题但是当我尝试订阅这个主题时,我收到了错误...
使用google-pubsub关于主题名称的最佳做法是什么?如果我有这些事件:客户电子邮件更新客户地址更新客户创建客户删除文章创建...
Google Cloud Pub / Sub to Datastax Cassandra(在Google Cloud中)
我在Google Cloud上部署了一个9节点的Datastax Cluster。现在我已经被要求从QUEUE读取数据并加载到Google Cloud上的Datastax(Continues Streaming)。我知道Pub / ...
为Pubsub到Bigquery流构建此GCP Dataflow示例时出错
我正在尝试构建以下将Pub / Sub流式传输到BigQuery的示例:https://github.com/GoogleCloudPlatform/DataflowTemplates/blob/master/src/main/java/com/google/cloud/teleport/templates/ .. 。
解析JSON时出现Google Cloud Dataflow Javascript UDF错误
我使用Pub / Sub到BigQuery模板来传输发送到Pub / Sub主题的JSON数据。通过Dataflow,我希望将数据展平以匹配BigQuery架构并对其进行流式处理。这是 ...
使用PubSub的GKE上的Google Healthcare API - INVALID_ARGUMENT
我们一直在测试专门针对HL7的Google Healthcare API,因为我已经完成了教程,我遇到了障碍。我应该提一下,我有相当多的经验......
Gmail推送通知错误(每个开发人员只允许一个用户推送通知客户端)
我尝试在我的两个gmail帐户上执行gmail api的监视,它运行正常。但是当其他用户尝试这样做时,它会显示以下错误:HTTP错误400:“只有一个用户推送通知...
是否可以触发HTTP云功能以响应pubsub消息?在编辑订阅时,谷歌可以将消息推送到HTTPS端点,但出于滥用原因......
Google Cloud Pub / Sub重新发送消息到后台函数,如果它们返回回调错误
官方文档确实提到Google Cloud Pub / Sub会向订阅者重新发送消息,直到订阅者在使用官方Cloud Pub / Sub Node.js客户端时确认收到消息....
Google PubSub和自动扩展计算引擎实例(Python)
在我的场景中,我正在使用PubSub安排任务。这比在Google Compute Engine中的Docker容器内运行的Python脚本消耗的消息多达2.000个PubSub消息。那......
gob:类型不匹配:没有匹配编译解码器的字段 - Golang
我在两个不同的流上使用PubSub,我们从一个流接收消息,运行一些逻辑,如果它符合某些条件,我们将它发布到第二个流。第二个流也是......
如何将消息从Google Cloud pubsub(gcp)发布到远程运行的Kafka主题
需要帮助来帮助将所有来自GCP(Google Cloud Pubsub)的消息发布到远程运行的Kafka主题我已经使用了“https://powerspace.tech/how-to-stream-data-from-”中的连接器代码...
我正在使用setInterval在JS中开发一个工作程序,如果有新消息,则每10秒检查一次。我想通过以下代码知道方法是否正确。你觉得我会有一些......
Maven问题验证依赖:beam-sdks-java-io-google-cloud-platform
我需要在myven项目中集成这个依赖项: ...
Terraform Topic资源已存在于各个项目中?怎么办呢?
如何处理多个项目中存在的资源。在这种情况下,我有2个TF项目,并在谷歌pubsub中有一个共享主题。在Google提供商文档之后,我在...中创建了此配置
回复kafka模板连接标头(CorrelationId)不会发送到Google pub sub
我正在尝试使用Replyingkafkatemplate,其中自动添加了correlationid,但是当使用kafka connector-Sink连接器将消息发布到Google pubsub时,标题丢失了。 ...
输入相关值后,我收到403错误(参见屏幕截图)然后我注意到API Explorer无法输入我的API密钥。所以,我复制粘贴提供的JS代码......
我有一个问题,谷歌PubSub Node.js监听器冻结使用拉。我使用以下流程:1。创建PubSub客户端,2。从指定主题获取订阅3.监听器...
从单个JSON创建并插入多行到PubQuery / Sub和Dataflow的BigQuery
我创建了一个Beam Dataflow管道,用于解析PubSub主题中的单个JSON:{“data”:“test data”,“options”:{“test options”:“test”,“test_units”:{...
对于跨区域和跨项目的主题,谁负责出口定价?如果订户付费,当多个订户在同一地区时会发生什么?每个人支付的费用是多少?...