Python Google PubSub设置来自subscribe()的确认截止日期

文章/答案/技术大牛

发布

1回答

python、google-cloud-platform、google-cloud-pubsub

我使用subscribe()订阅数据(如下所示)。有没有办法从subscribe()设置ackDeadline？代码：subscription_path = subscriber.subscription_path(project_id, subscription_id ) streaming_pull_future = subscriber.<em

浏览 13提问于2021-03-06得票数 0

回答已采纳

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 = "$$$$&qu

浏览 18提问于2019-12-05得票数 1

1回答

使用Firebase函数重试pubsub消息

firebase、google-cloud-functions、google-cloud-pubsub

我有一个由PubSub消息触发的Firebase函数，它处理需要对Google Drive API进行的一系列调用。当对Google Drive API的调用由于速率限制错误而失败时，我想重试这些调用。我将调用添加到一个新的PubSub消息中，并将其添加到队列中。此消息将立即送达。因此，我在消息中设置了delay until参数，并且仅在延迟已过时才处理该消息，否则将该消息再次添加到队列中。这会导致消息被多次传递和重试。在Fireba

浏览 1提问于2018-03-06得票数 1

3回答

对于从PubSub触发的云运行，何时才是发送请求消息的合适时间？

google-cloud-pubsub、google-cloud-run、event-arc

我正在构建一个运行在Cloud Run上的服务，该服务由PubSub通过EventArc触发。“PubSub”保证交付至少一次，并将在每一个acknowledgement截止日期重新尝试。此截止日期设置在队列订阅详细信息中。当运行在云运行

浏览 5提问于2021-06-24得票数 1

2回答

Google不重发未确认的消息

node.js、typescript、google-cloud-pubsub

为选择的答案包含一些相关信息以及以下代码： .topic(this.topicName()) this.logger.error('Received error:', error)发布到相应主题的消息会如期而至地从上面的代码中记录下来，但是，即使我没有在配置的确认截

浏览 11提问于2021-12-23得票数 0

回答已采纳

2回答

谷歌PubSub* Python多个用户客户端接收重复消息*

google-cloud-platform、google-cloud-pubsub、google-cloud-python

我有一个非常简单的应用程序来启动一个PubSub订阅者StreamingPull客户端。我在库伯奈特斯部署了这个这样我就可以放大了。当我部署了一个吊舱时，一切都如期而至。订阅确认截止日期设置为600 s。处理所有消息的分钟远远低于订阅的确认截止日期，Python客户端应该处理租约管理，因此我不确定为什么会有过期消息。我也不明白为什么同一条消息同时发送到多个订阅服务器客户端。最小工作实例： impor

浏览 6提问于2019-09-18得票数 1

回答已采纳

1回答

在PubSub订阅、确认、截止日期和重新传递的上下文中，未完成的消息对订阅者意味着什么？

google-cloud-pubsub

(有10分钟的确认截止时间)。来自GAE任务拉队列世界，我们假设工作人员将通过从PubSub订阅中提取一条消息来“租赁”一条消息，其中，从提取时开始，员工将有10分钟的时间来确认消息。然而，在添加日志之后(参见下面重新发布的消息)，重要的似乎不是从拉到ack的时间，而是从发布消息到确认的时间。这是对PubSub确认截止日期和随

浏览 1提问于2020-06-27得票数 2

回答已采纳

1回答

在CPU利用率较低的情况下进行缩减后，数据流管道暂停

google-cloud-dataflow、apache-beam

在我们的流式流水线中，我们从pubsub读取数据，执行一些验证，然后在10秒的间隙会话窗口中按关键字对其进行分组。然后，数据被进一步处理，并再次写入bigtable和pubsub。我们使用的是apache beam 2.28和数据流引擎。白天我们处理比晚上更多的数据，管道会自动增加工作进程(n2d-standard-4)的数量。正是在这一点上，所有工作进程的CPU利用率下降到接近0%，整个流水线开始大量滞后。其结果是，工作进程的数量再

浏览 18提问于2021-08-19得票数 1

回答已采纳

1回答

google.cloud.pubsub_v1和google.cloud.pubsub有什么区别？

google-cloud-pubsub、google-cloud-python、google-python-api

我发现这两种方法都在Google的不同文档中使用：载于： from google.cloud import pubsub_v1

浏览 1提问于2018-01-10得票数 14

回答已采纳

1回答

当等待函数未完成时，运行循环以更新云发布/订阅acknolwedgement截止日期

python、async-await、google-cloud-pubsub

我的所有消息都将花费超过600秒的时间来确认/处理来自云PubSub的消息，所以当我处理消息时，我需要计数到590秒，并请求将确认截止时间延长600秒(这样其他订阅者就不会得到重新提交)。： subscriber = pubsub_v1.SubscriberClient() subscription_path = "projects/path/to/subscription"

浏览 6提问于2021-07-09得票数 0

回答已采纳

2回答

故意的？

java、google-cloud-platform、google-cloud-pubsub

在我的推送端点上，我有一个长期运行的阻塞操作，有时运行超过一分钟。操作完成后，我将返回一个200响应，并添加消息。我注意到的是，如果我的长时间运行操作超过30秒，消息也会被重试。似乎用于推送的HTTP连接不存在超过30秒之类的时间。这是故意的吗？它是可配置的吗？

浏览 0提问于2019-11-10得票数 1

1回答

Google错误:超过截止日期

google-cloud-pubsub

我有一个简单的服务，它将消息发布到PubSub主题，偶尔会收到“超过截止日期”的错误消息： from google.cloud import pubsub pubsub_client = pubsub.Cl

浏览 1提问于2017-02-17得票数 3

回答已采纳

2回答

为什么消息不能重新投递？

google-cloud-platform、google-cloud-pubsub

确认截止时间为10秒。当我使用异步拉取的方式处理消息时，我不会调用message.ack()和message.nack()，而是等待消息确认截止日期，并期望Pub/Sub重新传递此消息。acked'); } else { }logger.info('subscribefaker.i

浏览 25提问于2019-05-29得票数 1

2回答

Pub/Sub测试:即使通过ack_deadline，客户端也接收到的消息

google-cloud-platform、google-cloud-pubsub

我在测试Cloud /Sub根据google的文档，拉子的ack_deadline可以设置在10s-600s之间。如果ack_deadline通过，msg将由Pubsub重新交付。我正在处理订阅客户端中的pubsub消息，然后再对msg进行处理。该加工时间可达700 s，超过了600 s的最大极限。复制：运行

浏览 7提问于2022-09-24得票数 1

回答已采纳

1回答

推送订阅发送多条消息比消息确认截止日期早得多

google-cloud-platform、google-cloud-storage、google-cloud-pubsub

我为GCS设置了Pubsub通知。()和我将Pubsub订阅设置为将消息推送到GAE端点。将消息确认截止日期设置为90。但是，当我试图在指定的桶中创建对象时，pubsub非常快地发送了多条消息。复制步骤：在指定的主题上创建

浏览 0提问于2019-01-30得票数 0

回答已采纳

1回答

Google抛出504个截止日超过错误，同时监听异步拉中的消息

python、google-cloud-platform、google-cloud-pubsub

我有一个订阅PubSub主题并使用异步拉的服务。在空闲10分钟并没有收到任何消息后，PubSub抛出504个截止日期超过错误。错误消息： INFO:google.cloud.pubsub_v1.subscriber.INFO:google.cloud.pubsub_v1Re-established str

浏览 1提问于2020-07-09得票数 3

回答已采纳

3回答

成功确认后，发布/订阅消息仍未送达

python、gcloud、google-cloud-pubsub

我非常困惑为什么我的gcloud pub/sub队列在同步打包消息后没有缩小。我有一个很小的队列(不超过几百条消息)，并且使用的代码与gcloud文档中的代码非常相似：PROJECT = 'my_project' subscriber =

浏览 0提问于2020-11-02得票数 0

2回答

Pub/Sub -确认截止日期被忽略，当使用准确一次交付时

google-cloud-pubsub

在启用Exactly once delivery和确认截止日期设置为600s的情况下，消息接收方仍然会在60年代或更短的时间内收到消息。subscribe("projects/xxxx/subscriptions/xxx-topic-sub", m -> {08:19:06.277 INFO 261

浏览 18提问于2022-07-22得票数 0

4回答

如何为中的urlfetch设置超时？

python、django、google-app-engine、timeout

我经常犯这样的错误：方法:获取异常类型: DownloadError异常位置:/google_appengine/google/appengine/api/urlfetch.py in _get_fetch_result，第325行感觉好像只有在12秒之后才会超时(我不确定问题:我如何设置更长的超时时间？

浏览 1提问于2010-01-29得票数 19

回答已采纳

1回答

修改异步订阅服务器中的ack截止日期

java、google-cloud-pubsub

我目前切换到google-cloud-pubsub库的0.24.0-beta版本，无法找到修改消息确认截止日期的方法。在以前的版本中，有一个modifyAckDeadline()，它允许我这样做。为了了解我为什么要尝试它:我想实现的是一种重试机制，在这种机制中，无法处理的消息会在10分钟内重新传递，并且只有在X次不成功的重试之后才会被确认。

浏览 0提问于2017-09-29得票数 1

点击加载更多