如何在GCP pub/sub中检查确认时间
在GCP（Google Cloud Platform）的pub/sub（发布/订阅）服务中，可以通过以下步骤来检查确认时间：
- 首先，确保你已经创建了一个pub/sub主题（Topic）和一个订阅（Subscription）。
- 在订阅者端，你可以使用Google Cloud Client Library或者REST API来接收消息。当你接收到一条消息时，消息会包含一个属性（attribute）叫做"publishTime"，它表示消息的发布时间。
- 通过读取消息的"publishTime"属性，你可以获取到消息的发布时间。这个时间是一个UTC时间戳，精确到纳秒级别。
- 如果你想在代码中获取消息的确认时间，可以使用pub/sub客户端库提供的方法。例如，在Java中，你可以使用
AcknowledgeRequest.getAcknowledgeDeadlineSeconds()方法来获取确认时间。
pub/sub的确认时间是指消息被订阅者确认的时间点。当订阅者接收到消息后，它需要发送一个确认请求来告知pub/sub服务该消息已经被处理。确认时间可以用来衡量消息处理的延迟时间。
GCP pub/sub是一种高可靠、可扩展的消息传递服务，适用于实时数据流、事件驱动的架构和异步任务处理等场景。它具有以下优势：
- 可靠性：pub/sub保证消息的可靠传递，即使在网络故障或订阅者不可用的情况下也能保证消息不丢失。
- 可扩展性：pub/sub可以处理大规模的消息流，支持高并发和高吞吐量的消息传递。
- 灵活性：pub/sub支持多种消息传递模式，包括发布/订阅、点对点和请求/响应模式。
- 实时性：pub/sub能够实时地传递消息，适用于需要快速响应的应用场景。
推荐的腾讯云相关产品是腾讯云消息队列CMQ，它是一种高可用、高可靠、高性能的分布式消息队列服务，适用于异步通信、解耦、削峰填谷等场景。你可以在腾讯云官网上了解更多关于腾讯云消息队列CMQ的信息：腾讯云消息队列CMQ
请注意，以上答案仅供参考，具体的技术实现和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我是Google Cloud Pub/Sub的新手。我已经创建了一个主题并创建了一个订阅。在Java中处理消息。我已经创建了一个MyReceiver类，并实现了MessageReceiver接口的receiveMessage(PubsubMessage message，AckReplyConsumer consumer)。 @Service
public class MyReceiver implements MessageReceiver {
ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.new
浏览 18提问于2021-09-15得票数 0
我试图在我的应用程序中构建一个网络钩子。更准确地说，我希望用户能够将HTTP设置到应用程序UI中，当事件发生时，我希望我的应用程序将数据发送到这个端点。请记住，端点不是我的域(可以是google.com/endpoint或example.com/endpoint.
我使用GCP和似乎是完美的选择。我的应用程序发布事件，Pub/Sub处理所有事情:尝试将我的数据发布到端点，重试如果失败，自动缩放.
问题是，根据Pub/Sub ，我需要验证我发送数据的域(!!)。但这个域不是我的，它是用户域.
所以我的问题是：
我对Pub/Sub完全误解了吗？
如果我必须验证用户域(这是我做不到的)，那么
浏览 1提问于2019-02-01得票数 0
我有一个Google函数订阅了一个主题。当云调度程序每5分钟调用GCP /Sub时，我们的GCP /Sub会向主题发布一条消息。问题是，有时在调用第一个云函数之后，云函数会被调用两次。
订阅的确认截止日期为600秒。因此，我无法理解为什么GCF在90年代被GCP Pub/Sub两次调用。调用两次90年代后是否与某件事有关？
浏览 5提问于2022-05-01得票数 1
回答已采纳
1回答
我正在从事微型服务，其中包含对GCP Pub/Sub中某个主题的订阅。由于一个Microservices的多个实例运行在多个主机上(云上的多个集群)，我想知道订阅消息的确认行为。当一个实例上的订阅接收、处理和确认消息时，其他主机上的相同订阅是否接收消息？
我希望一旦订阅服务器确认了消息，pub/sub就不会进一步发送消息，但是如果在不同主机上同一订阅的两个订阅服务器同时接收消息，会导致复制吗？
浏览 9提问于2022-03-22得票数 1
回答已采纳
需要一些关于集成测试GCP工作流的技术和设计选择的建议，GCP工作流是由Pub/Sub触发并启动数据流作业的。
为了在本地运行测试，我考虑使用Pub/Sub仿真器，但是对于工作流，我需要触发测试工作流执行，还是为测试目的设置工作流？
任何关于如何测试这样的环境或技术，可用于执行和断言测试结果的想法，将不胜感激。
浏览 3提问于2022-05-15得票数 0
我想要注意的是，我将描述的场景发生得非常罕见，在大多数情况下，一切都像预期的那样工作。
我在Pub/ side上有一个主题和一个订阅。
我的java应用程序侦听订阅，进行一些处理，然后发回确认消息。因为google发布/订阅保证至少发送一次，所以我们基于objectGeneration头和'objectId‘头在我们这一侧进行消息去重。
有时，我们看到应用程序一次又一次地接受已确认的消息，这是意想不到的行为。
日志示例：
//first
2019-12-17 20:51:57.375 INFO 1 --- [sub-subscriber3] bucketNotificationFlow
浏览 9提问于2019-12-18得票数 6
1回答
我需要用POST请求将消息发布到GCP Pub/Sub，因为我使用的平台(Zoho)不允许任何GCP库。我不知道如何以简单的方式提出请求，因为正常的身份验证系统似乎很复杂。
是否有一种使用API密钥发布消息的简单方法？
或者，是否有一种简单的方法可以在GCP中创建API端点，然后将数据转发到消息传递系统？
我使用python客户端发布到Pub/Sub，但由于身份验证问题，无法发出POST请求。
浏览 1提问于2019-08-16得票数 1
回答已采纳
1回答
我正在使用GCP /Sub实现事件驱动。
我有一个名为orders的主题，该主题将有一个名为orderPlacedSubscription的订阅--我有两个服务希望侦听此订阅的所有消息并执行不同的操作，因此我有paymentService和notificationService，paymentService将侦听由orderPlacedSubscription过滤的每条消息并处理支付，通知服务将侦听相同的消息并发送通知。
我的问题
pub-sub是否支持有两个与一个订阅相关的订阅者，并且都接收消息并分别确认它们？
如果每个订阅者可以在不影响另一个订阅者的情况下单独确认消息，那么谷歌云发
浏览 7提问于2022-07-25得票数 1
回答已采纳
如果在GCP pub/sub组件中发生任何事件，则需要调用外部服务，例如，如果在GCP pub/sub api中接收到任何消息，则它应该使用这些消息详细信息调用GCP外部服务。任何关于如何从Google Cloud平台调用外部web服务的信息都会很有帮助
浏览 7提问于2021-10-11得票数 0
我有一个经常使用的pub子队列，它附带了一个拉订阅(一个侦听器)。在一天中的某些随机时间里，队列中的消息需要更多的时间才能到达订阅。是否有任何具体的原因或方案，我应该考虑在这里，以确保交付？在订阅中启用了排序键。
浏览 7提问于2022-07-21得票数 0
1回答
我有1个发布/订阅主题和1个订阅。我在探索GCP PubSub Kafka Connector。 有2个Kafka实例在2个地域运行。是否可以在两个地区使用Kafka连接器，在Pub/Sub中从相同的公共订阅中采购消息？ 我想找出一种将msgs从pub/sub迁移到多个kafka实例的方法。(比方说循环)
浏览 18提问于2020-10-08得票数 0
回答已采纳
我有一个具有访问点https://reporting-intake-service-XXX-uc.a.run.app的GCP项目上的云运行服务。服务本身使用Pub/Sub来推送消息。
更新:我已经确认问题在于服务中的Pub/Sub调用，而不是服务本身的访问。
Dockerfile
FROM python:3
WORKDIR /app
COPY . .
RUN pip install -r requirements.txt
CMD python3 intake.py
intake.py
import logging
from flask import Flask, request
from go
浏览 6提问于2022-05-30得票数 0
回答已采纳
1回答
我是新的数据流和发布子工具在GCP。
需要将prem流程上的电流迁移到GCP。
当前流程如下：
我们有两种类型的数据提要
Full Feed -它的临时作业大小为100 of (单个XML -非常复杂的一个完整的数据- ETL作业处理该XML并将其加载到~60个表中)
有单独的ETL作业来处理完整的提要。ETL作业处理完整提要和创建加载就绪文件，所有表将被截断和重新加载。
Delta每30分钟需要处理一次增量文件(XML文件-它只会在最后30分钟内进行更改)
源系统每30分钟推送XML文件(多个文件具有时间戳)，计划中的ETL进程将选择源系统生成的所有文件，并
浏览 3提问于2020-10-02得票数 0
我是GCP世界的新手。我必须检查我的batchSetting发布消息给pub sub是否真的有效。这是批处理设置：
private BatchingSettings getBatchingSettings() {
long requestBytesThreshold = 10000L;
long messageCountBatchSize = 100L;
Duration publishDelayThreshold = Duration.ofMillis(2000);
BatchingSettings batchingSetti
浏览 2提问于2021-09-03得票数 1
回答已采纳
1回答
我正在使用Python在Apache中编写一个程序，从Pub/Sub读取JSON文件的内容，并对接收到的字符串进行一些处理。这是程序中的一部分，我从Pub/Sub中提取内容并进行处理：
with beam.Pipeline(options=PipelineOptions()) as pipeline:
lines = pipeline | beam.io.gcp.pubsub.ReadStringsFromPubSub(subscription=known_args.subscription)
lines_decoded = lines | beam.Map(lambda x:
浏览 0提问于2018-03-19得票数 0
回答已采纳
GCP 表示，云运行容器的最大运行时间可以是60分钟(超过15分钟的超时是测试版功能)。现在，触发云运行的一种方式是通过pub-sub推送订阅。然而，GCP 表示，pub-sub推送订阅可以有10分钟的最大ack截止时间。
现在，我的云运行容器需要15分钟才能完成。在容器启动10分钟后，推送订阅错过了ack截止日期，topic重新发布消息，由于该消息创建了云运行的另一个实例。这个keep在无限循环中进行。
有人能建议一下这里可以做些什么吗？
浏览 3提问于2021-02-11得票数 1
1回答
我有两个我想要运行的脚本，function_1和function_2，其中只有在function_1成功执行之后才能运行function_2。
为了在GCP上实现这一点，我将每个脚本转换为一个云函数，按照GCP中的标准设置为由Pub/Sub触发。假设我想使用Composer来调度这些函数。由于没有用于执行云函数的运算符，所以我必须使用Pub/Sub运算符向我的主题发送一条消息，这将反过来执行该函数。
我的问题是:只有在function_2成功运行之后，才有可能在Composer执行中为function_1设置触发器吗？由于我的DAG任务不是函数的执行，而是向Pub/Sub发送消息(它反过来运行
浏览 6提问于2020-04-27得票数 0
回答已采纳
我正在尝试使用控制台: BigQuery创建GCP Pub订阅。
但是，我收到以下错误消息：
API returned error: ‘Request contains an invalid argument.’
任何帮助都将不胜感激。
备注
当大查询表不存在时，我得到以下错误：
2.未删除Pub Sub模式
浏览 8提问于2022-08-25得票数 2
在启用Exactly once delivery和确认截止日期设置为600s的情况下，消息接收方仍然会在60年代或更短的时间内收到消息。这是我当前的测试代码：
final Subscriber subscriber = pubSubTemplate.getPubSubSubscriberTemplate().
subscribe("projects/xxxx/subscriptions/xxx-topic-sub", m -> {
final String s = m.getPubsu
浏览 18提问于2022-07-22得票数 0
我有一个云函数订阅了Pub/Sub主题。
根据，如果云函数返回一个不成功的响应，它将重新发送消息：
端点通过返回HTTP成功状态代码来确认消息。一个不成功的响应表示消息应该被憎恨。
我的问题是:如果一个不成功的回应，信息将立即被愤怒，或Pub/Sub将遵守确认的最后期限来重新发送消息？
更新：
我认为这个问题没有任何意义，我会解释原因。
由于您无法访问Pub/Sub函数中的Response对象，因此无法直接发送响应代码(我对此不太确定，因此如果我错了，请纠正我)。
因此，不成功的反应只能由以下几个方面引起：
超时，这是基于确认的最后期限，所以在这种情况下，确认的最后期限显然是尊重。
浏览 0提问于2019-07-08得票数 5
回答已采纳
我使用过spring cloud data flow、rabbitmq和kafka，但我想知道是否可以使用google pub/sub安装scdf。
我不想创建一个流(新的应用程序，spring云流)，它的源或宿都是gcp，我想让google pub/sub over spring cloud数据流服务器作为一个中间消息传递代理。
有什么建议吗？
浏览 1提问于2019-12-30得票数 1
我提交了一个GCP数据流管道，以便从GCP Pub/Sub接收我的数据，解析并存储到GCP数据存储。看起来很完美。
经过21天，我发现成本是144.54美元，工作时间是2,094.72小时。这意味着在我提交它之后，它将每秒钟充电一次，甚至没有从Pub/Sub接收(处理)任何数据。
这种行为正常吗？还是我设定了一个错误的参数？我认为CPU的使用时间只在接收到数据时计算。
有没有办法降低同一工作模式下的成本(从Pub/Sub接收并存储到Datastore)？
浏览 0提问于2018-10-23得票数 1
回答已采纳
我已经设置了一个GCloud数据流管道，它使用来自Pub/Sub订阅的消息，将它们转换为表行，并将这些行写入相应的BigQuery表。
表目的地是根据Pub/Sub消息的内容确定的，偶尔会导致表还不存在，必须先创建表的情况。为此，我使用create CREATE_IF_NEEDED，它工作得很好。
但是，我注意到，如果在数据流作业仍在运行时手动删除BigQuery中新创建的表，则Dataflow将被卡住，不会重新创建该表。相反，我得到了一个错误：
Operation ongoing in step write-rows-to-bigquery/StreamingInserts/Streamin
浏览 1提问于2020-03-21得票数 0
回答已采纳
利用GCP探索ETL工艺。我在数据流中使用Pub/Sub订阅BigQuery模板。
Pub/Sub订阅中的消息数据是csv格式，如下所示
53466,06/30/2020，特立尼达和多巴哥，2020-07-01:33:52,130，8.0,113.0
这将在加载到BigQuery表时留下一个错误。如何在模板中将CSV数据转换为JSON？
浏览 0提问于2021-03-10得票数 0
我有一个来自第三方的API (对于我和gcp)，我想知道是否有可能从API获得数据到PUBSUB，或者从我可以在我的环境中设置的包装API中。
基本模式：
(第三方API) -> PUBSUB -Cloud函数-> BigQuery
浏览 5提问于2022-09-01得票数 0
我用Spring函数库创建了一个简单的Google函数，以便在Pub/Sub消息到达时触发。我跟踪了样本。每当消息被触发到Pub/Sub时，就会按预期从Cloud函数打印消息。
但是，我想知道如何在Cloud中获得Pub/Sub消息的元数据。说
此元数据可通过调用时传递给函数的上下文对象访问。
如何访问Spring函数应用程序中的元数据(或上下文对象)？
更新:-版本spring-cloud-function-adapter-gcp:3.1.2
更新2:-我在中提出了一个问题，并解决了这个问题。感谢Spring功能团队。
浏览 4提问于2021-05-01得票数 0
回答已采纳
我注意到在创建云编写器环境时，自动创建了2个Pub/Sub主题和订阅，那么这里对Pub/Sub的需求是什么，composer的内部架构与pub/sub是如何关联的。
我需要这个概念上的澄清，因为我没有找到任何解释这一点的文档。
我理解，云编写器在那里使用pub/sub订阅来与其Kubernetes引擎服务代理进行通信，但我的问题是为什么它默认地创建两个主题而不是一个，我还注意到，当我从云编写器更改kubernetes配置( kubernetes集群的节点数目改变)/更新集群值时，它再次创建了另外两个主题&相同的订阅，所以我想了解它如何在内部工作，为什么在每次更新后创建新主题&订
浏览 4提问于2019-11-16得票数 4
回答已采纳
我们正在将部署在VM现场数据中心的.Net应用程序与云上Google平台中的发布/子资源主题集成起来。我有一个方案，我目前无法决定，将需要帮助和正确的方向。下面是用例的简要细节。请看一看，并提供你的想法。
目前有一个.Net应用程序部署在Windows上，部署在遗留的prem客户端数据中心上。它所做的是将XML消息发布到部署在同一个prem数据中心的EMS服务器上的Tibco主题上。部署在不同VM上的Java应用程序很少，它们订阅这个Tibco主题，并拉出消息并处理它们。这就是遗留流。
作为现代化的一部分，GCP正在进入混合进程。现在的场景是，on .Net应用程序发布到Tibco主题的XML
浏览 7提问于2021-02-06得票数 0
背景
我在GCP发布/订阅上有一个带有2个订阅者的发布服务器，这两个订阅服务器都运行一个NodeJS代码&一旦进程完成，即确认。
问题：
我如何知道是哪个订阅者破坏了消息？
假设我只有一个订阅者，我同时发送了10条消息，2条失败了，我怎么知道哪两条消息失败了？在GCP发布/订阅上发送的消息与ackId之间是否有任何映射？
浏览 0提问于2019-05-30得票数 0
1回答
我正在试用google部署管理器。
我已经创建了一个YAML文件，在该文件中，我要为主题创建一个主题和一个推送订阅。
resources:
- name: pubsub-topic
type: gcp-types/pubsub-v1:projects.topics
properties:
topic: "topic-01"
- name: pubsub-sub
type: gcp-types/pubsub-v1:projects.subscriptions
properties:
subscription:
浏览 2提问于2019-07-02得票数 1
回答已采纳
我正在使用GCP Bigquery存储一些数据。我已经为pub/sub Dataflow of event.Currently创建了一个工作，我面临着数据丢失的问题。有时，由于“没有互联网连接”，数据没有被上传到bigquery，并且丢失了那段时间的数据。我怎样才能克服这种局面。
或者我应该使用什么类型的数据库来脱机存储数据，然后在有连接性的情况下将其上传到网上。
提前谢谢你！
浏览 6提问于2020-08-27得票数 0
回答已采纳
1回答
我偶然发现了一个问题，决定征求意见，最终找到一个有同样业务需求(和问题)的人。
总结--我们最近将一个客户端的SQL服务从一个自托管的MySQL迁移到了Google CloudSQL MySQL 5.7服务，现在我们正在寻找一种方法，允许我们的客户端访问/查看和分析他们自己托管的ELK堆栈中的MySQL慢速日志。
这不是一个问题，因为我们可以访问SQL服务缓慢的日志文件，并设法“跟踪”，导出和索引这些日志在Elasticsearch中。下面是一个简单的示例，展示了一个特定的弹性搜索MySQL缓慢日志单文档的外观。
请注意，每一份文件都载有：
Time
User@Host
Query_time
浏览 0提问于2020-05-19得票数 0
1回答
因此，我跟踪这个关于如何使用pub子作为Laravel队列驱动程序的。但是，当我试图使用php artisan队列运行工作人员时，我被困住了:work-queue=clcej，这显示了错误。
No connector for [pubsub]
以下是我在config/Quee.php中添加的行
'default' => env('QUEUE_CONNECTION', 'pubsub'),
'pubsub' => [
'driver' => &
浏览 13提问于2022-07-20得票数 1
终端中是否有命令来获取Message body，如Google平台控制台订阅(与来自Nest门铃设备的事件触发器相关)所示？
如果不是，我如何向Pub/Sub服务发出API请求并接收GCP控制台中显示的相同的JSON有效负载？
谢谢
浏览 9提问于2022-02-02得票数 0
回答已采纳
早期版本的Google函数在错误发生时有重试的限制。此后，它们提供了一些增强功能，以解决这一问题。
我们使用Pub/Sub触发的云功能来确保电子邮件的传递。有时，电子邮件服务需要很长的时间来响应，并且我们的云功能在我们得到错误之前就终止了。由于消息已经被确认，我们的电子邮件丢失了。
当我们被调用时，云函数似乎在自动发送ACK -- Pub/Sub消息。是否有办法将ACK延迟到我们的代码成功完成？或者，是否有一种方法可以捕获超时并请求消息以进行传递？我们还能试试别的吗？
浏览 2提问于2017-05-12得票数 14
回答已采纳
我有一个云函数，叫做Pub/Sub。只有在正确处理消息时，它才应该对消息进行ACK。
我在日志中看到一个内存错误，然后有一条消息‘状态结束: ok’。
该消息被确认并从我的Pub / Sub主题中删除！
复制者：
import base64
import requests
def hello_pubsub(event, context):
""" Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
浏览 5提问于2022-06-29得票数 2
我正试图使用NodeJs客户端使用GCP Pub/Sub StreamingPull，而且我理解，发布子程序是为中提到的100%错误率而设计的。
所以，如果我在errorHandler中遇到错误，我必须重新启动监听器吗?还请告诉我应该查找哪些错误代码，以查看流连接是否已关闭。这是参考文献
const errorHandler=(error)=>{
if(errorCodeCheckCondition){
subscription.on('message', messageHandler);
subscription.removeLi
浏览 6提问于2022-07-10得票数 1
1回答
您希望从App应用程序发送和使用Cloud /Sub消息。Cloud /Sub目前已被禁用。您将使用服务帐户对应用程序进行API身份验证。您希望确保应用程序能够使用Cloud /Sub。你应该怎么做？
在GCP控制台上的API库中启用Cloud /Sub。
当服务帐户访问云Pub/Sub API时，依赖于它的自动启用。
使用部署管理器部署应用程序。依赖于正在部署的应用程序所使用的所有API的自动启用。
授予Admin默认服务帐户Cloud /Sub管理的角色。让您的应用程序在第一个连接到Cloud /Sub时启用API。
我意识到，如果我建立一个应用程序，使用pubsub。它在不手动启用pub
浏览 0提问于2019-09-05得票数 0
回答已采纳
1回答
我将默认的数据流模板GCS用于Pub/Sub。云存储中的输入文件大小为300 of，每一行有2-3百万行。
启动数据流批处理作业时，会引发以下错误
来自工作人员的错误消息: org.apache.beam.sdk.io.gcp.pubsub.PubsubIO$Write$PubsubBoundedWriter.processElement(PubsubIO.java:1160)：javax.naming.SizeLimitExceededException: Pub/Sub消息大小(1089680070)超过最大批处理大小(7500000)
从文档中可以看到: Pub/Sub在一批中最
浏览 6提问于2020-08-26得票数 1
我正在设计CDC管道，使用DataStreams和GCP上的Dataflow将数据从cloud传输到CloudStorage，数据部分工作良好，我可以看到数据正在以avro格式成功地传输到CloudStorage。
当涉及到DataFlow时，我使用的是DataFlow模板DataStream to BigQuery和屏幕截图中的配置
我可以看到DataFlow作业启动并运行，日志中没有错误，但是我看不到从Cloud到BigQuery的任何数据传输。
在我看来，还缺少一些东西，那就是云存储和Pub/Sub之间的链接，我认为应该有一个链接来将数据从GCS流到Pub/Sub，最终应该有从Pub/S
浏览 2提问于2022-08-17得票数 1
回答已采纳
我们将一些从AWS到GCP云存储的SQL转储存储为一个长期的辅助备份.For --在过去四天中，数据没有传输到GCP，根据分析，我们发现是由于夏时制的变化，并修复了这个问题。
现在，在未来，我们希望得到一些通知从GCP到电子邮件/短信积极的场景/pager责任负场景(仅电子邮件在这个时候)。电子邮件的正面场景是成功地将一个新文件上传到GCS。但是，由于谷歌没有任何本地支持电子邮件或文本，请建议我们一个解决方案。我已经配置了以下内容
配置桶通知对发布子的更改
将发布/sub通知配置为拉出传递类型
但是现在我如何从GCP发送电子邮件/文本。我们是AWS少校的店。我们是否可以使用SE
浏览 1提问于2018-11-08得票数 0
回答已采纳
我们即将选择/Sub作为我们的消息总线。有些消息需要在较低的延迟时间内发送，比如不到100到200 of。
我在某个地方读到，在大量的消息中，它执行得很好，但是对于每秒几百条消息这样的较小数量的消息，Pub/Sub可能会产生很高的延迟。
在前一个问题中，这个话题也不清楚。2016年的。
是否有任何关于Pub/Sub延迟以及与消息量的关系的定义度量？
浏览 0提问于2018-11-07得票数 6
回答已采纳
我有一个spring服务，订阅来自google cloud pubsub (拉取)主题的消息。它总体上工作正常。但我想要更多地控制重新发送的消息。我的服务有时需要阻止消息，或者只是让ackDeadline通过，这样我以后就会再次获得消息。在测试单个消息时，nack消息几乎立即返回给我，而那些我根本没有确认或nack的消息，在ackDeadline默认10秒后返回。我希望它推迟对这些消息的重复消费。我以为重试设置就是为这种情况设计的。我还应该提到的是，我目前正在使用模拟器进行本地测试，并从代码创建订阅。我正在使用PubSubAdmin进行管理。 根据此docu，我已尝试在我的配置文件配置中设置
浏览 37提问于2019-02-05得票数 3
回答已采纳
对于push订阅上的Cloud消息排序，如果我使用相同的排序键发布两条消息，比如消息#1和消息#2，那么消息#2只会在消息#1被确认之后才被推送吗？或者，排序是否意味着消息#2即使没有确认也会被某种无穷小的时间差推到消息#1之后？
从在github上使用发布/订阅. on工具脚本进行测试和注释ack调用，答案似乎是消息#2在消息#1被添加之前是不会传递的。但是这个测试是用拉来完成的，所以我不确定push的工作方式是否不同。
然而，文档似乎表明消息#2可以在消息#1被添加之前传递：。
当Pub/Sub服务使用排序键重新传递消息时，Pub/Sub服务还使用相同的排序键重新传递每个后续消息，包括已
浏览 1提问于2021-01-12得票数 1
试图在Google (GCP) Pub/Sub与Manager Kafka服务之间做出决定。
在最新的更新中，Pub/Sub添加了对以前处理过的消息的支持，这是一个值得欢迎的变化。
我在他们的文档中找不到的一个特点是，我们是否可以有类似于Kafka的消费者组，即有一组订阅者，每个用户处理来自同一主题的数据，并且能够从一开始就为一些订阅者(消费者组)重新处理数据，而其他人则不受其影响。例：
假设您有一个主题为StockTicks
你有两个消费群体
CG1:有两个消费者
CG2:和另外两个消费者
在Kafka中，我可以在这些组之间独立地阅读消息，但是我可以用Pub/Sub做同样的事情。
卡夫卡允许
浏览 0提问于2019-11-14得票数 1
回答已采纳
3回答
生成基于RSA的SSH密钥之后：
ssh-keygen -t rsa -f ~/.ssh/id_rsa -C id_rsa
#=>
Generating public/private rsa key pair.
Created directory '/. . ./.ssh'.
Enter passphrase (empty for no passphrase):
Enter same passphrase again:
Your identification has been saved in /. . ./.ssh/.id_rsa.
Your public key
浏览 3提问于2019-11-28得票数 2
我想计数最后一小时的消息数量(最后一小时指消息数据中的一个时间戳字段)。
我目前有一段代码可以同步计算消息(我正在使用Google /Sub同步拉)，但我注意到这需要很长时间。
我的代码将反复轮询预定义的订阅次数(我将其设置为100+)，因此我确信在最后一小时内不会有更多的消息出现故障。
这是一个不可接受的设计，因为它意味着用户必须等待5-10分钟的服务，以计数消息时，他们想要的度量！
在Pub 设计中是否存在解决此类问题的最佳实践？
这似乎是一个简单的问题来解决(计算上一个X时间框架内的事件数量)，所以我想可能有。
异步设计会有帮助吗？异步设计将如何工作？我不太确定异步和Python的fut
浏览 1提问于2019-10-01得票数 1
通过指定application.properties文件中的文件位置，传递服务帐户密钥文件(从GCP控制台生成)似乎很简单。然而，我尝试了以下所有选项：
1. spring.cloud.gcp.credentials.location=file:/home/my_user_id/mp6key.json
2. spring.cloud.gcp.credentials.location=file:src/main/resources/mp6key.json
3. spring.cloud.gcp.credentials.location=file:./main/resources/mp6key.j
浏览 6提问于2020-03-19得票数 3
回答已采纳
我是GCP的新手，在理解一些概念上有一些困难。因此，如果我想每次在邮箱中收到新邮件，我可以使用Pub/Sub吗？在这种情况下，推送通知是如何工作的？我理解订阅者的概念，但在发行者的概念上我有一些困难。有人能帮忙吗？
浏览 0提问于2018-07-11得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
