腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1026)
视频
沙龙
2
回答
批
处理
PubSub
请求
、
、
用于批
处理
pubsub
请求的NODEJS示例代码如下所示:const
PubSub
= require(`@
google
-
cloud
/
pubsub
`); const
pubsub
= new
PubSub
(); * T
浏览 0
提问于2018-03-02
得票数 8
回答已采纳
2
回答
使用
Spring消费来自
pubsub
的
批量
消息
、
、
如何
消费来自
pubsub
的
多条
消息
?这似乎是一个简单的问题,应该有简单的解决方案,但目前我可以找到
使用
spring-
cloud
-gcp-
pubsub
从
pubsub
中
使用
批量
记录的简单方法。我
使用
spring-
cloud
-gcp-
pubsub
来消费来自
pubsub
的
消息
,并在spring boot应用程序中
处理
它
浏览 0
提问于2019-08-30
得票数 0
1
回答
如何
使用
Google
Cloud
PubSub
控制台
一次
发布
多条
消息
(
批量
处理
)
、
、
我可以
使用
控制台
一次
成功地在
Google
Cloud
Pubsub
上
发布
一条
消息
,结果显示在BigQuery的一个表中。{"ID": 123, "Item1": "aaa", "Item2": "bbb"} BigQuery表: ID | Item1 | Item2 123 | aaa | bbb
如何
通过
控制台
<em
浏览 13
提问于2020-01-26
得票数 0
1
回答
发布
/订阅提供的截止日期已超出错误
、
我正在尝试
一次
发布
多条
消息
(大约50条),但
发布
/订阅给出的是Deadline Exceeded at /user_code/node_modules/@
google
-
cloud
/
pubsub
/node_modulesconst
pubsub
=
PubSub
(); const topic =
pubsub
.topic(
浏览 8
提问于2017-12-26
得票数 5
2
回答
使用
python创建
Google
Cloud
API批
处理
主题
、
我们正在尝试
使用
Google
Cloud
PubSub
批量
处理
不同的主题创建调用(数十到数百)到
Google
Cloud
API。目前还不清楚我们
如何
做到这一点。目前,我们有以下内容,但似乎找不到有关
如何
在批
处理
调用中注入create topic请求的文档。有谁有关于
如何
做到这一点的见解吗?api = build('
pubsub
', '
浏览 2
提问于2019-09-17
得票数 0
1
回答
UnhandledPromiseRejectionWarning: TypeError:通道凭据必须是GCP批
发布
中的ChannelCredentials对象
、
、
、
我正在尝试
使用
node module @
google
-
cloud
/
pubsub
批量
发布
消息
。我的
批量
发布
代码如下所示。const {
PubSub
} = require("@
google
-
cloud
/
pubsub
"); const creat
浏览 102
提问于2021-10-11
得票数 0
1
回答
我想通过
pubsub
批量
处理
文件到
google
云存储中
我需要
使用
python脚本通过
pubsub
将文件批
处理
/流式传输到
google
云存储中。我已经
使用
了下面的python文件,能够看到从topic
发布
到订阅的
消息
,现在我想将这些单独的
消息
上传到一个文件中,需要加载到云存储中。你能建议我们在哪里可以修改以下脚本中的代码,将
消息
数据作为文件加载到云存储中(
批量
处理
单个
消息
) 在path下面我们有python脚本: python
浏览 1
提问于2018-04-20
得票数 0
1
回答
消息
未在云
发布
/订阅接收器中接收
、
、
、
import com.
google
.
cloud
.
pubsub
.v1.MessageReceiver;importimport com.
google
.
cloud
.
pubsub
.v1.AckReplyConsumer; import com.
google
.
cloud
.
pubsub
.v1.Mes
浏览 0
提问于2019-07-17
得票数 1
2
回答
Google
Cloud
Pub/Sub Python
一次
检索单个
消息
、
Problem:我的用例是,我希望从
Google
/Sub接收
消息
--每次
使用
Python接收一条
消息
。所有当前的示例都提到
使用
异步/回调选项从Pub/Sub订阅中提取
消息
。是否可以只接收1条
消息
并关闭连接,即是否有一个特性,我可以将参数(类似于max_messages)设置为1,以便一旦接收到1条
消息
,线程就会终止?
浏览 2
提问于2018-05-17
得票数 1
回答已采纳
1
回答
如何
将谷歌云平台
发布
/订阅
消息
推送到C#桌面应用
、
、
我正在尝试创建C#桌面应用程序,可以接收谷歌云平台
发布
/订阅
消息
。我不能让它在推送方法(https://
cloud
.
google
.com/
pubsub
/docs/subscriber#push_pull)下工作。我从文档中了解到的是-当
消息
发布
时,
发布
/订阅将HTTP请求推送到到端点的订阅者。然后,端点返回HTTP成功状态代码。subscriberService.CreateSubs
浏览 23
提问于2020-04-07
得票数 1
1
回答
google
.
cloud
.
pubsub
_v1和
google
.
cloud
.
pubsub
有什么区别?
、
、
我发现这两种方法都在
Google
的不同文档中
使用
:载于: from
google
.
cloud
import
pubsub
_v1
浏览 1
提问于2018-01-10
得票数 14
回答已采纳
1
回答
GCP :为什么
发布
200k
消息
会迅速导致250万条有关该主题的
消息
、
我们
使用
@
google
/
pubsub
库快速
发布
大约200k条
消息
。 当我们
使用
下面的代码等价物
发布
消息
时,最大的冲击是250万条
消息
。从日志
消息
中我们可以看到,它认为它
发布
了200 k
消息
。 第二个小问题发生在我们
使用
下面的代码时,但是将Promise.all调用与另一个for循环分块,并且
一次</em
浏览 5
提问于2020-08-06
得票数 2
回答已采纳
1
回答
使用
PubSub
API访问国外项目的com.
google
.
cloud
.
pubsub
、
我有一个AppEngine应用程序,可以向
PubSub
发布
消息
。现在,我想从一个不同的GCP项目中阅读这些
消息
。
使用
com.
google
.apis/
google
-api-services-
pubsub
v1-rev8-1.21.0和服务帐户密钥是可能的。 我以的例子为指导。代码的某些部分有点难看(例如需要一个RetryHttpInitializerWrapper),所以我想知道是否可以
使用
com.
google</em
浏览 5
提问于2016-11-17
得票数 0
回答已采纳
2
回答
实现云功能以
发布
到GCS finalize触发的
pubsub
、
、
、
、
(由于文档混乱和更改速度相对较快,所以放弃了node.js )topic_name = "projectsimport
pubsub
_v1 ImportErro
浏览 0
提问于2018-12-06
得票数 7
回答已采纳
1
回答
Java应用程序找不到访问GCP
发布
/订阅的凭据
、
、
我正在尝试
使用
GCP Java SDK通过以下代码向
发布
/订阅主题发送
消息
(在此代码片段中用占位符替换实际的项目ID和主题名称):ProjectTopicName()Z at com.
google
.
cloud
.
pubsub
.v1.stub.Grpc
浏览 8
提问于2019-07-28
得票数 0
2
回答
如何
使用
python将后台函数的确认返回给
pubsub
、
、
、
在这方面,我创建了一个触发器,该触发器
发布
到pub/sub。Pub/Sub本身向后台函数发送
消息
。然而,问题是把Ack送回酒吧/潜艇。在我读到的发回任何2xx状态的某个地方,应该完成这个任务(从队列中删除
消息
),但它没有。结果,
pubsub
“认为”
消息
没有被传递,并
一次
又<e
浏览 0
提问于2019-04-30
得票数 1
回答已采纳
2
回答
在主题之间移动
Google
/Sub
消息
、
如何
在GCP Pub/Sub中将
消息
从一个主题大容量地移动到另一个主题?具体来说,用例用于将死信主题中的
消息
移回原始主题以进行再
处理
。
浏览 7
提问于2020-07-29
得票数 1
1
回答
如何
将流xml加载到BigQuery中的指南
、
如果有人能在这里提供帮助,我将不胜感激,我们刚刚开始研究GCP,需要一个健壮且简单的模式来将
发布
在云
发布
/订阅上的xml格式的事务数据加载到一个日期分区的BigQuery表中,以便在AirFlow编排的复杂下游批
处理
中
使用
为了在摄取端允许模式漂移,一种选择是将xml转换为json,并将json存储为字符串,并在顶部
使用
json函数提取字段以进行下游
处理
,这种方法的优缺点是什么?在我们的例子中,一个优点是在xml中有很多(300+)字段,但最初只
使用
了一个子集,
浏览 22
提问于2020-06-29
得票数 0
1
回答
有没有办法(实时)检索
PubSub
订阅中的
消息
计数?
、
我想实现
PubSub
订阅的
批量
消费,检索流程开始时订阅中的所有
消息
。为此,我
使用
以及consumer.ack()和consumer.nack()函数来准确
处理
我想要的
消息
数量,并使订阅重新传递我已收到但尚未
处理
的
消息
。我的问题是,我没有设法找到一种方法来检索我的订阅中的实时
消息
计数。我已经开始从
Google
Cloud
Monitoring请求
pubsub
.googleapis.c
浏览 5
提问于2021-10-01
得票数 1
3
回答
设置Python /Sub异步拉动订阅者线程计数
、
、
、
、
我
使用
Python实现了异步拉订阅服务器。这是基本代码 while True:我需要打印像
消息
B
消息
(我需要按顺序运行)或通过给定的线程
浏览 4
提问于2017-12-28
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Cloud IoT Core 现已面向公众发布
谷歌BigQuery ML正式上岗,只会用SQL也能玩转机器学习!
如何在Python中实现异步执行?
推出ML Kit
为Go语言开发者介绍NATS
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券