我正在使用google cloud pubsub，我想知道如何在pubsub中获取未送达、已送达和未送达消息的数量。google pubsub为此提供了可用的api吗？
浏览 4提问于2016-08-24得票数 3
我正在使用Pubsub作为一个排队机制工具，我想知道驻留在Pubsub主题中的消息的计数。出于同样的目的，我决定使用Google API指标pubsub.googleapis.com/subscription/num_undelivered_messages，但我不知道如何使用python客户端库</
浏览 6提问于2019-04-10得票数 2
回答已采纳
我想实现PubSub订阅的批量消费，检索流程开始时订阅中的所有消息。为此，我使用以及consumer.ack()和consumer.nack()函数来准确处理我想要的消息数量，并使订阅重新传递我已收到但尚未处理的消息。我的问题是，我没有设法找到一种方法来检索我的订阅中的实时消息计数。我已经开始从Google C
浏览 5提问于2021-10-01得票数 1
我像这里描述的那样设置我的HorizontalPodAutoscaler来根据来自我的发布/订阅的未确认消息的数量来监听尺度。我的愿望是，如果有超过1条未确认的消息，则pods可以扩展。( current / target )
"pubsub.googleapis.compods:
浏览 11提问于2020-05-26得票数 1
1回答
我试图在gcp中的pubsub上设置警报，以监视队列中旧消息的数量。具体来说，超过20分钟的未确认消息的数量。
我想要一个警告，因为未被确认的信息的数量会在hugh的消息数量突然增加的情况下迅速上升。并且只使用最古老的<e
浏览 25提问于2022-07-28得票数 1
1回答
我需要在不使用stackdriver api(不启用stackdriver api)的情况下获取GCP指标。例如。pubsub.googleapis.com/subscription/ack_message_count.的发布/订阅指标->
浏览 1提问于2019-09-24得票数 0
我是谷歌PubSub的新手。我使用GoLang作为客户端库。我已经成功地向Google PubSub发布了一条消息。现在我想看看这个指标，但我在Google Stackdriver中找不到这些指标。
浏览 4提问于2020-05-27得票数 2
我有一个来自第三方的API (对于我和gcp)，我想知道是否有可能从API获得数据到PUBSUB，或者从我可以在我的环境中设置的包装API中。基本模式：
(第三方API) -> PUBSUB -Cloud函数-> BigQuery
浏览 5提问于2022-09-01得票数 0
我正在尝试使用java-grpc-prometheus库获取一些指标。我想得到一些如下的指标 gRPC会话、调用数量、各自的持续时间、对内部API进行的API调用数量、超时、接口重置 我的问题是，我们正在使用双向流API，我读到它是在单个TCP会话上设置的，该会话被客户端重用如何</e
浏览 99提问于2021-10-11得票数 0
有人有关于如何通过CURL类型的命令直接从PubSub发布消息到GCP PubSub主题的工作示例吗？
我试图不使用CLI，也不使用客户端库，而且我被OAUTH的东西挂断了。我很高兴能有一个运行在Linux上的bash脚本需要做的事情的子弹列表，如果有人有这样的或者可以拼凑在一起的话，我会非常感激的。我已经拥有
浏览 5提问于2018-01-11得票数 7
回答已采纳
与App Engine标准的云发布/订阅API集成
我正在开发一个标准的Python环境中的谷歌应用程序引擎应用程序。对于代码的某些部分，我需要与Google Cloud发布/订阅API集成。正如前面提到的，发布/订阅只能集成在App Engine灵活的环境中(顺便说一句，它也只是alpha版)。有人能描述一下如何在App Engine标准环境中集成P
浏览 2提问于2017-06-25得票数 2
如何在PubSub中获取离线消息？使用Smack库。经过搜索，我找到了一个类似于以下内容的答案：PubSubManager mgrextends Item> items = node.getItems(100);
但是node.getItems(100)返回最后100条消息</em
浏览 0提问于2017-09-28得票数 10
1回答
我们使用自己的日志记录解决方案，因为stackdriver是su...bpar。我想获取pubsub中有多少未确认消息的度量。我开始阅读关于这方面的文档，它们到处都是。找到这个页面：尽管在api之下，它没有描述任何api调用，但包含了我想要提取的指标的描述。现在我想我需要使用监控api以某种方式提取我需要的东西：
所以我使用<e
浏览 0提问于2017-09-13得票数 0
1回答
我正在构建一个Dataflow管道，它从pubsub读取并向第三方API发送请求。管道使用THROUGHPUT_BASED自动标度。然而，当我对它进行负载测试时，在它自动划分为4项工作之后，它就赶上了pubsub中的积压，但似乎在工作之间分散了相同的工作量，但总体吞吐量并没有显著增加。U
浏览 0提问于2018-07-24得票数 2
在beam中，pubusbIO read提供了使用message id：去重复消息的选项。当我签出Pubsub (用于java和python)时，我看不到使用messages来去复制消息的类似选项。
如果
浏览 0提问于2020-09-23得票数 0
回答已采纳
1回答
我正在尝试实现一个以自己的速度使用google pubsub订阅的服务。我的意思是，我需要对何时需要消费消息进行精细控制，例如获取一批消息，暂停一段时间，不超过X条消息……
使用谷歌客户端库，我没有找到一种方法，因为MessageReceiver是在它自己的线程中运行的，我无法控制到底发生了什么基本上，能够以同步的</e
浏览 7提问于2017-06-29得票数 2
回答已采纳
1回答
我为我的python代码编写了一个api，如下所示： ## in real life this implementationreturn greets + " " + name
但只有python开发人员才能使用我的api。我想做的是同样的事情，但是使用不同的
浏览 7提问于2018-12-06得票数 0
我可以按以下方式确认订阅的所有消息：(尽管在确认所有消息之前，我经常要反复运行这个程序但是，我不想承认它们，我只想看到所有未被确认的消息(或者只是统计一下有多少条未被确认的消息也是有帮助的)。我想可能是：
gcloud pubsub subscriptions pull --limit=1
浏览 11提问于2022-06-09得票数 0
2回答
我想在python中使用google应用程序引擎的pubsub API来实现MQTT。如何在标准库中运行pub子库？如果我需要运行此API的旧版本，任何人都可以提供该示例。此外，最新库的一个问题是它是alpha版本。稍后，我将使用GCP-IOT协议连接MQTT客户端。
浏览 21提问于2017-06-24得票数 0
GCE实例组可以根据Google、PubSub队列计数或其他异步任务队列(如PSQ )进行缩放吗？
浏览 2提问于2016-04-15得票数 3
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
