腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(244)
视频
沙龙
1
回答
不
尊重
MaxOutStandingMessages
的
谷歌
PubSub
同步
拉
取
google-cloud-pubsub
我使用
的
是Go库。该服务部署在kubernetes集群上,当我发送大量消息时,它以某种方式在一个pod上结束,而另一个pod只是空闲。messages from %s
pubsub
subscriber", subId) cfg, err := sub.ConfigMaxOutstandingBytes in ReceiveSettings err = sub.Receive(ctx, func(ctx context.Context, msg *
pu
浏览 10
提问于2020-07-03
得票数 0
1
回答
如何使用Go指定要在
pubsub
上拉多少条消息?
go
、
publish-subscribe
、
google-cloud-pubsub
我跟随这篇关于如何从订阅中提取消息
的
文章:。 显然,我可以最多拉1,000条消息,但是如果我只想要
拉
2条消息,我要做什么呢?提前谢谢你!
浏览 15
提问于2022-09-30
得票数 1
1
回答
同步
拉
取
pubsub
node.js
google-cloud-platform
、
google-cloud-functions
、
google-cloud-pubsub
我有一个云函数,它正在从
pubsub
订阅中进行
同步
拉
取
。使用设置为true
的
returnImmediately标志配置请求,这样我们就不需要等待
pubsub
消息出现在队列中。当有一些消息挂起时,请求返回非常快( 100ms ),但当队列中没有消息时,调用挂起大约1.5秒,然后返回空
的
消息数组。 因为我在一个云函数中,我不确定异步
拉
取
是可能
的
。当没有挂起
的
消息时,我如何摆脱这种1.5秒
的</e
浏览 0
提问于2018-11-20
得票数 0
2
回答
GCP
PubSub
:在Python中
同步
拉
取
订户?
python-2.7
、
google-cloud-pubsub
全,还有没有别的主意?下面是我
的
函数,它直接取自其中一个例子: def sample_receive_messages
浏览 17
提问于2018-01-11
得票数 3
1
回答
有没有一种方法可以在Apache Beam作业中使用
同步
拉
取来消费
谷歌
PubSub
消息
google-cloud-platform
、
google-cloud-dataflow
、
apache-beam
、
publish-subscribe
、
apache-beam-io
我已经在下面的文档中浏览了google提供
的
客户端库。给定
的
客户端库只是从
PubSub
轮询消息,但在我们创建无界源连接器之前,它不会连续轮询。https://cloud.google.com/
pubsub
/docs/pull#synchronous_pull 由于我正在尝试构建
的
源连接器是无界源,因此我需要注意检查点标记,实现
PubSub
阅读器,
PubSub
拆分源,并实现确认和NACK逻辑,我相信创建我自己
的</
浏览 19
提问于2021-01-10
得票数 0
回答已采纳
1
回答
谷歌
PubSub
拉
取
与流媒体
拉
取
的
差异
google-cloud-platform
、
grpc
、
google-cloud-pubsub
我从
谷歌
上读到了documentation关于
拉
取
和流媒体
拉
取
的
比较,但是我不能完全理解。有人能给我解释一下其中
的
区别吗?如果有人已经实现了它,并能给我指出参考资料,那也会很有帮助。非常感谢。
浏览 23
提问于2019-05-18
得票数 3
1
回答
谷歌
PubSub
监听器冻结
node.js
、
google-cloud-pubsub
我有一个
谷歌
PubSub
Node.js监听器冻结使用拉动
的
问题。 我使用以下流程: 1.
PubSub
client is created, 2.一开始,它
拉
取
大约500条消息并确认它们,但在那之后它就挂起了,队列中有超过1000条消息。我尝试定期重新启动监听器(removeListener/on),但它只获取很少
的
消息。重新启动应用程序后,它拉动~500,同样
的
情况也会发生。
浏览 15
提问于2019-04-18
得票数 0
1
回答
Pub/Sub请求计数在gcp
的
kubernetes吊舱上急剧减少
kubernetes
、
google-cloud-platform
、
publish-subscribe
、
kubernetes-pod
我有500万条消息(总计7GB)在我
的
积压gcp发布/订阅,并希望尽可能多地提取它们。我使用以下设置
的
同步
拉
,并等待3分钟来堆叠消息并发送到另一个db。defaultSettings := &
pubsub
.ReceiveSettings{ MaxOutstandingBytes: 128e
浏览 2
提问于2022-03-14
得票数 2
2
回答
谷歌
PubSub
每次
拉
取
的
最大消息数
c#
、
google-cloud-pubsub
我正在编写一个application应用程序,其中我使用了.NET
PubSub
模拟器,在那里我可以发布和订阅一个主题。但是,当我发布“大量”消息1000+时,我想拉出尽可能多
的
消息。我使用提供SubscriberServiceApiClient
的
Google.Cloud.
PubSub
.V1库与他们
的
应用程序接口进行交互。我使用具有参数maxMessages
的
PullAsync方法进行异步
拉
取
。根据他们
的
文档,这决定了每个请求可以提取
浏览 10
提问于2018-03-02
得票数 1
1
回答
在安卓系统中使用
谷歌
云
PubSub
,找到正确
的
库
android
、
google-cloud-platform
、
google-cloud-pubsub
我使用
的
是Android Studio 3.0.1,项目使用
的
是SDK版本26。我尝试使用'grpc-
PubSub
-v1‘库从
谷歌
云
pubsub
模块
拉
取消息,并在应用程序build.gradle中添加以下行: compile ('com.google.api.grpc:grpc-
pubsub
-v1:0.0.2') 当gradle
同步
出现下一个错误时: 错误:对task':app:transformDexArc
浏览 45
提问于2018-05-04
得票数 0
3
回答
成功确认后,发布/订阅消息仍未送达
python
、
gcloud
、
google-cloud-pubsub
我非常困惑为什么我
的
gcloud pub/sub队列在
同步
打包消息后没有缩小。我有一个很小
的
队列(
不
超过几百条消息),并且使用
的
代码与gcloud文档中
的
代码非常相似:PROJECT = 'my_project' subscrib
浏览 0
提问于2020-11-02
得票数 0
1
回答
如何知道Google
PubSub
订阅者是否已断线
c#
、
google-cloud-pubsub
我正在使用
谷歌
PubSub
消息服务
拉
取
已发布
的
消息,使用此处
的
代码示例(https://cloud.google.com/
pubsub
/docs/quickstart-client-librariesCancellationToken cancel) => //Do something return Task.FromResult(SubscriberClient.Reply
浏览 16
提问于2020-08-12
得票数 0
3
回答
在工作pc和家用pc之间
同步
git存储库
git
我
的
源代码是由git管理
的
。我白天在办公室工作,晚上在家工作。如何在工作和家庭中
同步
存储库? 到目前为止,我在
谷歌
上搜索到
的
解决方案只能
拉
取
或推送提交更改。如果我还想
同步
未跟踪和暂存
的
文件/文件夹,该怎么办?
浏览 0
提问于2011-06-30
得票数 2
1
回答
GCP发布/订阅客户端、GrpcSubscriberStub、超时
java
、
google-cloud-pubsub
我尝试使用GrpcSubscriberStub进行“
同步
拉
”,如示例https://cloud.google.com/
pubsub
/docs/pull中所示 SubscriberStubSettingsacknowledgeRequest);} 但是我不知道如何使用"setReturnImmediately(false)“选项来设置
拉
取
的<
浏览 21
提问于2020-01-23
得票数 2
3
回答
使用google云平台
的
延迟作业解决方案
google-cloud-platform
、
google-cloud-messaging
、
google-cloud-pubsub
我
的
应用程序从google cloud
pubsub
获取排队
的
消息并处理任务。worker应用程序也与
谷歌
应用程序引擎(Node.js)一起托管。由于第三方应用程序施加
的
速率限制,Worker应用程序遇到了麻烦。是否有现成
的
解决方案可以在google云平台中运行延迟作业? 谢谢!
浏览 22
提问于2016-08-22
得票数 3
1
回答
在
PubSub
订阅、确认、截止日期和重新传递
的
上下文中,未完成
的
消息对订阅者意味着什么?
google-cloud-pubsub
我们正在以一种“尖峰”
的
方式使用
谷歌
PubSub
,在短时间内(~ 10分钟)发布数百万条小消息(< 10k),用10个工作线程旋转2k GKE吊舱,每个线程使用
同步
拉
和确认
PubSub
服务调用来完成相关
的
订阅来自GAE任务
拉
队列世界,我们假设工作人员将通过从
PubSub
订阅中提取一条消息来“租赁”一条消息,其中,从提取时开始,员工将有10分钟
的
时间来确认消息。我们可能会让发行者根据订阅待办事项
的</em
浏览 1
提问于2020-06-27
得票数 2
回答已采纳
1
回答
如何在bigquery中只从表中选择第一行-以降低成本
select
、
google-bigquery
、
row
嗨,我只需要选择每个表
的
一行-哪一行并不重要-我只需要控制列中
的
一个值(它在每一行都是相同
的
),但是limit或first_value遍历整个表。对我来说是很好
的
随机
的
一行...我需要降低此查询
的
成本。 Thx
浏览 0
提问于2020-03-27
得票数 0
1
回答
使用异步
拉
取
持续接收来自
谷歌
PubSub
的
消息
java
、
multithreading
、
asynchronous
、
google-cloud-pubsub
在这个
的
帮助下,我成功地创建了一个小型Java应用程序,它可以在一分钟内提取已发布
的
消息。我
的
实现看起来像这样。,它会打印在对象上传帐户上收到
的
所有消息,然后停止。现在,我想要做
的
是持续运行侦听器,因此,我尝试在main方法内
的
无限循环内运行方法eventListener(),如下所示 public static void main(String[] argsat com.google.api.gax.rpc.ClientContext.create(ClientContext.
浏览 75
提问于2019-03-28
得票数 1
回答已采纳
1
回答
Android :
同步
和映射
android
、
android-emulator
我必须开发一个android应用程序,应该与网络服务器上
的
数据
同步
。请帮帮我..
浏览 1
提问于2010-11-24
得票数 0
回答已采纳
2
回答
显示Mercurial推送/
拉
取
进度
version-control
、
mercurial
、
progress-bar
、
push
、
pull
是否可以使用Mercurial来显示长时间运行
的
推送或
拉
取
操作
的
进度?
谷歌
基本上告诉我“
不
”,但有没有人知道得更清楚?我期待
的
是像hg pull -v这样
的
东西。
浏览 0
提问于2008-11-21
得票数 42
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
状态同步,究竟是推还是拉?
被解雇员工起诉谷歌:并非泄露公司机密,谷歌“杀鸡儆猴”
直播系统聊天技术(七):直播间海量聊天消息的架构设计难点实践
谷歌公布 GitHub 最新开源库 androidx:开发 AOSP Jetpack
Redis in.NET Core(1)
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券