PubSub确认截止日期

文章/答案/技术大牛

发布

3回答

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

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

我正在构建一个运行在Cloud Run上的服务，该服务由PubSub通过EventArc触发。“PubSub”保证交付至少一次，并将在每一个acknowledgement截止日期重新尝试。此截止日期设置在队列订阅详细信息中。在请求开始时，一旦收到请求。然后，服务将继续以自己的速度处理请求。因此，我们无法正确设置确认截止日期，从而

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

2回答

如果30秒内没有得到响应，/Sub将重新尝试消息传递。故意的？

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

我使用Java 8 servlet作为Cloud /Sub端点。在我的推送端点上，我有一个长期运行的阻塞操作，有时运行超过一分钟。操作完成后，我将返回一个200响应，并添加消息。请注意，我创建订阅的最大允许期限为600秒。这是故意的吗？它是可配置的吗？提前谢谢。

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

2回答

Google不重发未确认的消息

node.js、typescript、google-cloud-pubsub

error => {}) 此外，当我显式地对消息调用.nack()时，它们会像预期的那样感到不满。我是不是误会了什么？

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

回答已采纳

1回答

google-cloud-platform、google-cloud-pubsub、google-cloud-run

我有一个云函数，它将消息发布到PubSub，并触发云运行来执行归档文件过程。当有大文件时，我的cloud Run python代码需要一些时间来处理数据，它看起来像是PubSub在20秒(默认确认截止时间)后重试消息，这将从我的Cloud run触发另一个实例。我已经将确认截止时间增加到600秒，并重新部署了所有内容，但它在20秒后仍在重试消息。我遗漏了什么吗？except Exception as e: return (e, 500) 以下是<

浏览 17提问于2021-07-02得票数 2

回答已采纳

1回答

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

google-cloud-pubsub

我们正在以一种“尖峰”的方式使用谷歌PubSub，在短时间内(~ 10分钟)发布数百万条小消息(< 10k)，用10个工作线程旋转2k GKE吊舱，每个线程使用同步拉和确认PubSub服务调用来完成相关的订阅(有10分钟的确认截止时间)。来自GAE任务拉队列世界，我们假设工作人员将通过从PubSub订阅中提取一条消息来“租赁”一条消息，其中，从提取时开始，员工将有10分钟的时间来确认消息。然而，在添加日志之后(参见下面重新发布的消息)，重要的似乎不是从拉到ack的

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

回答已采纳

1回答

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

google-cloud-dataflow、apache-beam

在我们的流式流水线中，我们从pubsub读取数据，执行一些验证，然后在10秒的间隙会话窗口中按关键字对其进行分组。然后，数据被进一步处理，并再次写入bigtable和pubsub。

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

回答已采纳

1回答

Eventarc中的重复事件触发Google运行服务

google-cloud-platform、google-bigquery

我的服务记录事件JSON，使我能够确认服务确实在反复接收相同的事件。 --project="${PROJECT}" \ --format='value(transport.pubsub.subscription)') g

浏览 10提问于2022-08-04得票数 1

回答已采纳

1回答

使用Firebase函数重试pubsub消息

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

我有一个由PubSub消息触发的Firebase函数，它处理需要对Google Drive API进行的一系列调用。我将调用添加到一个新的PubSub消息中，并将其添加到队列中。此消息将立即送达。因此，我在消息中设置了delay until参数，并且仅在延迟已过时才处理该消息，否则将该消息再次添加到队列中。然后，我可以在PubSub队列上设置重试延迟。

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

1回答

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

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

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

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

回答已采纳

2回答

是否可以修改PubSub订阅的全局确认截止日期而不重新创建它？

google-cloud-pubsub

我们使用GUI创建了一个默认确认截止时间为10秒的pull PubSub订阅。事实证明，我们太乐观了，我们的服务花了超过10秒的时间来处理一批拉出的消息。服务不会抛出异常，实际上它会处理所有的消息，但是由于截止日期已经过去，在某些情况下，我们会多次处理重发的消息。是否有方法更新订阅的默认截止日期？我们知道每条信息都可以做到这一点。如果没有办法做到这一点，而不删除订阅，并创建一个具有延长确认截止日期的新订阅，那么是否有

浏览 6提问于2017-02-05得票数 10

回答已采纳

3回答

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

python、gcloud、google-cloud-pubsub

我有一个很小的队列(不超过几百条消息)，并且使用的代码与gcloud文档中的代码非常相似：PROJECT = 'my_project'subscription_pathrequest={"subscription": subscr

浏览 0提问于2020-11-02得票数 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 = "$$$$" subscriber= pubsub_v1.SubscriberClient()

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

1回答

云PubSub重复消息触发的云函数

google-cloud-platform、google-cloud-functions、google-cloud-pubsub

我正在尝试使用云函数作为由PubSub触发的异步后台工作程序，并进行更长时间的工作(以分钟为单位)。完整的代码在这里有人强调，PubSub可以多次传递相同的消息，但令我惊讶的是，100条消息中有10到40条是重复的。CF的响应时间分别为5、6、7分钟。例如，当您在消息的确认截止日期到期之前没有确认该消息时，云发布/订阅会重新发送该

浏览 0提问于2019-05-18得票数 2

1回答

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

java、google-cloud-pubsub

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

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

2回答

如何使用python将后台函数的确认返回给pubsub

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

一切似乎都很好，例如，只要上传了一个文件，触发器就会实时发送消息给Pubsub，然后再发送到函数。我还可以看到传递给函数的消息。 args = base64.b64decode(data['data']).decode('utf-8') pubsub_message= a

浏览 0提问于2019-04-30得票数 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

回答已采纳

3回答

延迟消息处理并在处理前删除

google-cloud-pubsub

我需要这种能力来发送移动应用程序中的操作推送通知，但等待用户撤消操作，直到比方说10秒。

浏览 1提问于2016-09-28得票数 17

回答已采纳

1回答

Google消息在截止日期确认前多次传递

google-cloud-platform、google-cloud-pubsub

我们已将其确认截止日期设置为600秒。问题:我们已经观察到pubsub已经将相同的消息两次(从其他主题上推了两次以上)给它的订阅者，从日志中我可以看到这个消息推送的间隔只有1秒，理想的情况下，由于我们已经将ackDeadline配置为600秒，所以pubsub应该在600秒后重新尝试消息传递。需要以下答案：参考资料：-

浏览 2提问于2018-11-29得票数 8

1回答

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

python、async-await、google-cloud-pubsub

我的所有消息都将花费超过600秒的时间来确认/处理来自云PubSub的消息，所以当我处理消息时，我需要计数到590秒，并请求将确认截止时间延长600秒(这样其他订阅者就不会得到重新提交)。while awaited processing_function not finished: streaming_pull_fu

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

回答已采纳

2回答

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

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

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

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

回答已采纳

点击加载更多