腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
处理
SubscriberClient
确认
失败
的
消息
?
google-cloud-pubsub
我找到了这个文档:https://cloud.google.com/nodejs/docs/reference/pubsub/0.19.x/v1.
SubscriberClient
#acknowledge如果
消息
确认
失败
,是否会被放回
消息
队列并等待稍后重新发送?或者这条
消息
丢失了?
浏览 25
提问于2019-03-13
得票数 0
1
回答
如何
在Python语言中使用AckID
确认
谷歌PubSub
消息
python
、
google-cloud-platform
、
publish-subscribe
、
google-cloud-pubsub
= 5.0 # "How long the subscriber should listen forexcept: # noqa在上面的例子中,
消息
一收到就被
确认
但我只想在本地芹菜工人
处理
完
消息
浏览 6
提问于2020-02-10
得票数 0
回答已采纳
1
回答
使用
SubscriberClient
客户端库创建C#时指定C#凭据
c#
、
.net-core
、
google-cloud-pubsub
我为我们
的
服务设置了一个GCP PubSub
处理
器,它创建了如下所示
的
SubscriberClient
var subscriptionClient = await
SubscriberClient
.CreateAsync我设置了GOOGLE_APPLICATION_CREDENTIALS环境变量并指向一个有效
的
SA键。一切都如期而至。但是,
如何
避免在本地机器上使用/依赖GOOGLE_APPLICATION_CREDENTIALS环境变量呢?鉴于文档中
浏览 6
提问于2021-01-28
得票数 1
回答已采纳
1
回答
通过python同步拉取
确认
pubsub
消息
不起作用
python
、
google-cloud-platform
、
google-cloud-pubsub
使用python google-cloud-pubsub库,通过subscriber.acknowledge()
确认
消息
不会
确认
我
的
消息
。我的
确认
截止时间设置为30秒。下面是我
的
代码: from google.cloud import pubsub_v1 subscription_name = "$$$$" subscriber= pubsub_v1.
SubscriberClie
浏览 18
提问于2019-12-05
得票数 1
1
回答
当等待函数未完成时,运行循环以更新云发布/订阅acknolwedgement截止日期
python
、
async-await
、
google-cloud-pubsub
我
的
所有
消息
都将花费超过600秒
的
时间来
确认
/
处理
来自云PubSub
的
消息
,所以当我
处理
消息
时,我需要计数到590秒,并请求将
确认
截止时间延长600秒(这样其他订阅者就不会得到重新提交)。我
的
计划是编写一个等待进程运行
的
包装器 while awaited processing_function not finished: update the deadline 我
浏览 6
提问于2021-07-09
得票数 0
回答已采纳
1
回答
如何
在ASP.NET核心应用程序中持续监听Pub/Sub
消息
?
c#
、
asp.net-core
、
google-cloud-platform
、
google-cloud-pubsub
我想实现一个HTTP,它不响应ASP.NET请求,但是在启动时就开始监听Google /Sub
消息
,并且它在整个生命周期中一直在无限期地监听。方法1:只需使用SimpleSubscriber,并在Startup.Configure中开始监听
消息
:
浏览 1
提问于2017-10-17
得票数 5
回答已采纳
1
回答
动态铲运机中节点间
消息
的
确认
rabbitmq
我知道兔子MQ支持Publisher
确认
机制--代理对发布者的
确认
。文档声明代理在
处理
消息
时通过在“
确认
模式”设置
的
通道上发送basic.ack来
确认
消息
。此通信是代理和发布服务器客户端之间
的
通信。让我们假设我在另一个数据中心中有一个主节点A和一个辅助B,并且根据文档“ack模式”确定铲子
如何
确认
消息
,动态铲子是从A到B设置
的
。如果设置为on -
确认</e
浏览 1
提问于2019-12-03
得票数 0
回答已采纳
1
回答
RabbitMQ铲子插件是否保留
消息
顺序?
rabbitmq
、
rabbitmq-shovel
我使用RabbitMQ铲子插件(动态铲子,见下文)在两个RabbitMQ代理之间通过一个不可靠
的
广域网链接提供单向
消息
。我在RabbitMQ服务器日志中看到了正常
的
连接丢失。AMQP设置
的
相关部分对于两个代理都是相同
的
:一个交换(扇出,持久)和一个队列(持久)。消费应用程序要求在发送端以相同
的
顺序接收
消息
。 观察到
的
行为似乎表明情况并非如此,可能是由于重传等原因。RabbitMQ铲子插头是否保存
消息
顺序而不丢失
消息
?
浏览 7
提问于2015-08-11
得票数 1
回答已采纳
1
回答
如何
知道Google PubSub订阅者是否已断线
c#
、
google-cloud-pubsub
我正在使用谷歌PubSub
消息
服务拉取已发布
的
消息
,使用此处
的
代码示例(https://cloud.google.com/pubsub/docs/quickstart-client-librariesSubscriptionName subscriptionName = SubscriptionName.FromProjectSubscription(projectId, subscriptionId);
SubscriberClient
subscribe
浏览 16
提问于2020-08-12
得票数 0
0
回答
谷歌PubSub
消息
复制
python
、
google-cloud-pubsub
我正在使用python客户端(作为google-cloud 0.30.0
的
一部分)来
处理
消息
。有时(大约10% )我
的
消息
会被复制。我将在几个小时内一次又一次地收到相同
的
消息
,多达50个实例。我
的
订阅设置是600秒的
确认
时间,但
消息
可能会在前一条
消息
一分钟后重新发送。 在运行时,我偶尔会收到503个错误(我用我
的
policy_class记录了这些错误),有人遇到过这种情况吗?我<e
浏览 2
提问于2017-12-06
得票数 1
2
回答
.Net客户端
的
Google
消息
延迟问题
google-cloud-pubsub
一切顺利,除了获取
消息
所需
的
时间约为12至15秒,在我们
的
情况下是不可接受
的
。一个注意事项是,每当成功地提取
消息
时,并且在pull
的
下一次迭代中,如果在pubsub上有
消息
,它将立即获取该
消息
。这意味着如果在连续
的
pull延迟中发现
消息
,则延迟非常低。但是问题是,假设在一次迭代中我得到了Deadline exceeded异常,因为pubsub没有
消息
。然后我在pubsub中为下一次迭代推送一条<em
浏览 2
提问于2017-02-27
得票数 0
回答已采纳
1
回答
Python请求只获取很少
的
消息
。
python
、
google-cloud-platform
、
google-cloud-pubsub
我已经将订阅可以提取
的
max_messages设置为10,000,但由于某种原因,每次我
的
python文件从PubSub中提取
消息
时,
消息
的
数量都低于100,这太少了。请帮助我理解我
如何
能够拉更多
的
消息
,因为我需要
处理
大约10,000条
消息
每拉。subscriber = pubsub_v1.
SubscriberClient
() pullData = subs
浏览 6
提问于2022-08-12
得票数 0
回答已采纳
2
回答
谷歌PubSub Python多个用户客户端接收重复
消息
google-cloud-platform
、
google-cloud-pubsub
、
google-cloud-python
当我缩放到2个容器时,我开始收到重复
的
消息
。我知道有些小
的
重复
消息
是可以期待
的
,但是几乎一半
的
消息
,有时更多,是多次接收
的
。 我
的
过程需要大约600毫秒来
处理
一条
消息
。订阅
确认
截止日期设置为600 s。在我
的
过程中没有
失败
,所有的
消息
在
处理
时都会被标记。日志显示,两个容器在完全相同
的
时间接收到
浏览 6
提问于2019-09-18
得票数 1
回答已采纳
1
回答
人工
确认
消息
: Spring Cloud Stream Kafka
apache-kafka
、
spring-cloud-stream
我想实现
的
场景是从Kafka消费一条
消息
,
处理
它,如果某个条件
失败
,我不希望
确认
该
消息
。为此,我在spring cloud stream参考文档中找到了 autoCommitOffset是否在
处理
消息
时自动提交偏移量。如果设置为false,则
确认
标头将在邮件标头中可用于延迟
确认
。我
的
问题是,在将autoCommitOffset设置为false后,
如何
确认
消
浏览 2
提问于2016-06-15
得票数 2
1
回答
弹簧集成-设计-防止无限加工循环
spring-integration
我有一个spring集成流,其中
处理
器(调度
的
)顺序地从队列(jms)读取
消息
并尝试
处理
。如果
处理
器发现在另一个事件完成之前无法
处理
该
消息
,它会将该
消息
发送回原始队列,并在稍后尝试
处理
。如果它只是不断地将无法
处理
的
消息
发送回队列,它就会创建一个无限循环。 所以我需要保留它们,直到我读完队列中已经存在
的
所有
消息
。并在将所有现有
消息
浏览 13
提问于2017-07-14
得票数 1
1
回答
如何
在使用Rabbitmq时让
消息
自动重试,并设置ttl = 0?
crash
、
rabbitmq
、
ttl
我们有一个这样
的
场景:我知道我们可以使用DLX来
处理</
浏览 0
提问于2016-04-25
得票数 1
1
回答
微服务体系结构中
的
Saga业务可移植性问题
c#
、
microservices
、
saga
我需要
处理
微服务体系结构中
的
分布式事务。从理论上讲,最好
的
方法之一是使用Saga编排模式。问题是我找不到任何关于
如何
提供可伸缩性
的
详细信息。 让我们使用下面的例子。因为我可以有多个OrderService.API,那么如果CreateOrderSaga是一种状态机,那么它是否意味着它应该自己
处理
它中
的
所有步骤,或者其他协调器可以承担它
的
工作?那么,如果这一个API在运行saga进程时崩溃,其他saga协调员能否继续以崩溃API遗留
的
相
浏览 4
提问于2019-12-02
得票数 6
回答已采纳
1
回答
如何
使用Qpid Proton Python显式
确认
或取消
确认
消息
python
、
amqp
、
qpid
、
qpid-proton
我有一个Qpid Proton Python MessageHandler接收一些
消息
,这些
消息
会触发一些
处理
。如果
处理
失败
,我
如何
拒绝
消息
?然而,将其更改为False似乎并不能避免
确认
消息
,因为后续
的
接收方不会赶上
失败
的
消息
。
浏览 30
提问于2021-01-28
得票数 0
回答已采纳
1
回答
在故障转移之后,Artemis接收重复
的
消息
。
duplicates
、
high-availability
、
failover
、
activemq-artemis
、
failovercluster
为了测试在发生故障时
的
通信性能,我对每条
消息
进行编号并连续发送,每秒发送大约30条
消息
。并发现,即使设置了ha策略,在故障转移/故障回退之后,使用者也会重复接收少量接收到
的
消息
。这是正常
的
吗?我知道Artemis通过给
消息
提供一个唯一
的
值来提供自动重复
消息
检测,这样可以避免重复发送
消息
,但是重复接收
的
消息
具有不同
的
“客户端ack messageID”。这
浏览 2
提问于2021-01-18
得票数 0
回答已采纳
2
回答
JMS上一条
消息
确认
java
、
jms
我正在尝试解决以下情况:假设现在数据库重新联机,并且所有新
消息
都被成功
处理
。所以我调用了.acknowledge来
处理
浏览 1
提问于2014-03-28
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka是如何处理Netflix每天2万亿条消息的?
RabbitMQ 补偿机制、消息幂等性解决方案
基于可靠消息方案的分布式事务(四):接入Lottor服务
分享两个Debug案例
分布式事务解决方案之RabbitMQ
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券