腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
发布
带有
延迟
的
pubsub
消息
google-cloud-pubsub
我正在寻找一种
发布
pubsub
消息
的
方法,
延迟
一分钟。我已经浏览了他们
的
API,但根本找不到任何方法。有人能在这方面对我有所帮助吗? 一个好
的
描述性答案将是非常感谢
的
。
浏览 46
提问于2021-11-10
得票数 1
1
回答
Google /Sub在低
消息
吞吐量上触发高
延迟
javascript
、
node.js
、
google-cloud-platform
、
google-cloud-functions
、
google-cloud-pubsub
我正在运行项目,该项目将
消息
发布
到
PubSub
主题并触发后台云功能。 const {
PubSub
} = require('@google-cloud
浏览 4
提问于2020-03-23
得票数 0
1
回答
在负载均衡器后面的多个实例中,有哪些选项可以将HTTP连接路由到一个特定
的
实例?
kubernetes
、
google-cloud-platform
、
websocket
、
load-balancing
、
haproxy
例如,假设上述系统
的
每个WebSocket客户端总是属于一个组(例如,最大组大小为100),并且它将尝试使用上述系统作为
消息
网关与99个其他客户端进行通信。因此,系统
的
职责是将从一个组中
的
客户端发送
的
消息
转发到同一组中
的
其他99个客户端。客户端永远不需要与属于不同组
的
其他客户端进行通信。当然,解决此问题
的
一种方法是使用
Pubsub
系统,这样无论客户端连接到哪个实例,服务器都可以简单地将
消息
发
浏览 17
提问于2021-05-16
得票数 1
回答已采纳
1
回答
Google中
的
时间戳倾斜
google-cloud-dataflow
从主题
消息
中解析时间戳。但是,我收到了一个关于允许时间戳倾斜
的
错误,引用了下面的文档。getAllowedTimestampSkew公共时间戳getAllowedTimestampSkew()返回允许
的
时间戳偏移持续时间,这是时间戳可以在DoFn.Context.outputWithTimestamp(OutputT,org.joda.time.Instant)中向后移动
的
最大持续时间。我想知道
的
是为什么默认允许
的
偏斜是零?数据流程不就是处理
延迟
和无序数据
的</
浏览 1
提问于2016-01-26
得票数 3
2
回答
如何触发特定持续时间
的
背景云功能?
google-cloud-platform
、
google-cloud-functions
、
google-cloud-pubsub
我使用云
发布
/订阅和云函数。但是我想在特定
的
持续时间后触发我
的
云功能,比如30秒之后。这是我
的
建筑,对吗?
浏览 1
提问于2019-03-11
得票数 0
回答已采纳
1
回答
Google函数&
PubSub
-空转后
延迟
google-cloud-functions
、
google-cloud-pubsub
我触发了一个HTTP函数,然后该函数向我
的
PubSub
主题
发布
一条
消息
。当每隔几秒钟
发布
一次时,这会很快完成,通常是在<1s
延迟
的
情况下完成
的
。但是,如果我有一段时间没有
发布
任何内容(比如5分钟),
发布
就会
延迟
很长时间(大约20分钟)。 以某种方式将Pub/Sub publisher配置为立即这样做。但是,在API文档中找不到
浏览 4
提问于2017-12-06
得票数 2
回答已采纳
1
回答
用于实时处理
的
Google数据流
延迟
google-cloud-dataflow
如果我们只是在一个高流量
的
Google集群上进行简单
的
转换,并且每个“数据点”都很小,那么我们可以期望Dataflow
的
延迟
有多低。 如果相关的话,我们计划使用间隔时间为3秒
的
会话窗口策略。在得到输出结果之前,从数据点进入数据流
的
时间可以小于2秒,这是否符合实际情况?不到1秒?
浏览 10
提问于2016-09-19
得票数 1
回答已采纳
1
回答
GMB
延迟
或不触发
的
PubSub
触发器通知
google-cloud-pubsub
、
google-my-business-api
将
带有
目标的推送订阅附加到我
的
服务器上。mybusiness-api-
pubsub
@system.gserviceaccount.com将电子邮件administrator.Update设置为具有有效主题名
的
administrator.Update通知设置,然后通过手动
发布
消息
并获得web钩子successfully.来进行测试。但是,当我编辑评论回复时--我收集了部分事件,并
延迟
了30分钟。部分通知没有收到。如果我试图写问题或回答-我没有收到任何事件。问题: 为什么事
浏览 3
提问于2021-03-10
得票数 1
1
回答
GMB与
PubSub
合作获取实时审查通知。
google-cloud-pubsub
、
google-my-business-api
我已经在我们
的
平台中集成了GMB,并与
PubSub
一起获得实时审查通知。 在成功完成上述三个步骤之后,当我转到Business并编辑评论时,Google仍然没有将评论数据推送给我
的
服务器。我是否可以为所有用户创建一个单独
的
主题并
浏览 0
提问于2018-02-01
得票数 6
回答已采纳
1
回答
使用
PubSub
Golang客户端
的
高
发布
延迟
go
、
google-cloud-pubsub
、
google-cloud-sdk
我们有一个定制
的
Golang脚本来向
PubSub
发布
消息
。然后根据一定
的
条件
发布
到主题
的
1。我们目前
的
发布
速度接近5K RPS,但我们
的
延迟
高达30秒。Publish Latency.1032225-30 925 > 30
浏览 4
提问于2020-04-02
得票数 0
2
回答
如何在另一个云函数中调用云函数并使用python传递一些输入参数或参数?
python-3.x
、
google-cloud-platform
、
google-cloud-functions
我一共有三个云函数,第一个云函数,它有一些条件,如果条件为真,那么它应该触发第二和第三云函数,并在触发它们之前将所需
的
参数或参数传递给第二和第三云函数。我已经尝试了三种不同
的
执行方式,但是在执行上面的场景时我需要帮助。云函数--python中
的
1段代码: dest_table_name = 'my_dest_table' myquery = "select count
浏览 9
提问于2019-10-13
得票数 1
回答已采纳
1
回答
如果不使用
PubSub
消息
,会发生什么情况?
google-cloud-platform
、
google-cloud-pubsub
根据,如果
消息
在7天内不被消耗,就停止存储。 有办法知道丢失了多少条
消息
吗?
浏览 0
提问于2018-09-13
得票数 1
回答已采纳
1
回答
Apache /
PubSub
处理文件前
的
时间
延迟
google-cloud-platform
、
google-cloud-dataflow
、
apache-beam
、
google-cloud-pubsub
我需要
延迟
处理或
发布
文件名(文件)。我在找最好
的
选择。1)
延迟
发布
消息
,以便立即处理它,但要在好
的
/预期
的
时刻进行处理 2)
延迟
处理检索到
的
浏览 0
提问于2018-12-21
得票数 0
1
回答
Apache管道IllegalArgumentException -时间戳倾斜?
google-cloud-dataflow
、
apache-beam
、
fluentd
我有一个现有的波束管道,是处理数据摄取(来自)
的
2条路线。“热”路径进行一些基本
的
转换,并将它们存储在Datastore中,而“冷”路径在存储前执行固定
的
逐小时窗口操作,以便进行更深入
的
分析。到目前为止,管道一直运行良好,直到我开始在
发布
到
Pubsub
之前对数据进行本地缓冲(因此数据到达
Pubsub
可能会“晚几个小时”)。org.apache.beam.sdk.transforms.WithTimestamps$AddTimestampsDoFn.processElem
浏览 2
提问于2018-06-20
得票数 2
1
回答
从Google Cloud Run托管应用程序触发
的
发布
/订阅
消息
需要很长时间
java
、
spring-boot
、
google-cloud-pubsub
、
google-cloud-run
我有一个托管在Google Cloud Run中
的
简单Spring启动应用程序,它向同一项目中
的
一个主题
发布
Google Pub/Sub
消息
。 这大约需要5分钟
的
长时间。下面是我用来
发布
Google
发布
/订阅
消息
的
代码。但在App Engine环境中,同样可以工作得很好,没有
延迟
。ApiFuture<String> messageIdFuture = com.google.cloud.
浏览 0
提问于2020-11-25
得票数 0
1
回答
Google
PubSub
中低流量下
的
延迟
python
、
publish-subscribe
、
google-cloud-pubsub
我已经注意到,在高负载下,
pubsub
提供了很高
的
吞吐量和相当低
的
延迟
。但是,如果我想发送一条
消息
,
延迟
时间通常可以是几秒钟。我在传入
消息
中使用了publish_time来查看
消息
在队列中花费了多长时间,而且它通常非常低。无法判断在非常低
的
流量条件下,
发布
的
消息
是否会立即由客户端库发送,或者库是否没有立即将其传递给应用程序。
浏览 3
提问于2022-10-20
得票数 0
1
回答
Google
PubSub
订购关键问题,
消息
排序未启用
google-cloud-platform
、
google-cloud-functions
、
google-cloud-pubsub
我正面临一个问题,当
发布
一个谷歌云公共
消息
订阅与订购启用。publisher.publish( 'projects/project_id/topics/test_order_
pubsub
',json.d
浏览 2
提问于2021-10-18
得票数 1
回答已采纳
1
回答
GCP
PubSub
-如何对异步
消息
进行排队?
google-cloud-pubsub
我想了解gcp公共子环境中发行者
的
设置信息。我想要排队
的
消息
,将通过一个谷歌功能消费。要实现这一点,
发布
将在到达多条
消息
或从某个时间到达时触发。我将主题设置如下: ByteThreshold: 1e6, // Publish a batchDelayThreshold: 10 * time.Second, // Publish a no
浏览 0
提问于2019-03-28
得票数 0
回答已采纳
1
回答
使用Smack将
带有
Payload
的
项
发布
到
Pubsub
节点
xmpp
、
publish-subscribe
、
openfire
、
smack
、
whack
我正在尝试使用Smack将一个
带有
有效负载
的
项
发布
到
pubsub
节点,但到目前为止我还没有成功。我已经创建了节点,并将其配置设置为传送有效负载(setDeliverPayloads=true)。我使用send方法来发送
带有
有效负载
的
项。:simple", "")));这是由smack
浏览 0
提问于2012-04-02
得票数 1
回答已采纳
1
回答
PubSub
:如何在没有指数退避
的
情况下设置重试策略?
google-cloud-platform
、
google-cloud-pubsub
、
google-cloud-run
我有一个推送订阅,它向云运行服务发送
消息
。如果Cloud服务没有成功地确认
消息
(负确认),我希望在每次重试之间
的
时间间隔总是相同
的
情况下,重新发送
消息
的
次数最多(例如,每次重试在1分钟后进行10次重试)。我知道我可以用一个死信队列来设置
消息
重发
的
最大次数(我也可以在没有死信队列
的
情况下设置这个数字吗?)因此,只需在最大值之后丢弃/删除
消息
。不将
消息
传递到另一个队列
的
尝试次
浏览 0
提问于2021-10-14
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
马斯克发布带有“NFT”的视频推文
消息称松下5月23日发布Lumix S9全画幅无反相机,带有专属LUT按键
马斯克发布带有NFT字样的视频推文
马斯克发布带有「NFT」字样的视频推文
Redis发布带有“流式”数据类型的5.0版本
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券