GCP pus/sub。如何在一段时间内通过订阅请求数据量？
在GCP（Google Cloud Platform）中，可以通过Pub/Sub（Publish/Subscribe）服务来实现在一段时间内通过订阅请求数据量。
Pub/Sub是一种可扩展的、全托管的消息传递服务，用于在应用程序和服务之间进行可靠且高效的异步消息传递。它基于发布-订阅模式，其中发布者将消息发布到主题（Topic），而订阅者则通过订阅这些主题来接收消息。
要通过订阅请求数据量，可以按照以下步骤进行操作：
- 创建主题（Topic）：在GCP控制台或使用Pub/Sub API创建一个主题，用于发布消息。
- 创建订阅（Subscription）：在GCP控制台或使用Pub/Sub API创建一个订阅，用于接收发布到主题的消息。
- 发布消息：使用Pub/Sub API或相关的客户端库，将消息发布到指定的主题。
- 订阅消息：使用Pub/Sub API或相关的客户端库，订阅指定的主题以接收消息。
- 处理消息：在订阅者端，可以编写代码来处理接收到的消息。可以根据业务需求进行数据处理、存储或其他操作。
通过以上步骤，您可以在一段时间内通过订阅请求数据量。Pub/Sub提供了可靠的消息传递机制，确保消息的可靠性和一致性。同时，它还具有高度可扩展性，可以处理大规模的消息流量。
对于GCP中的Pub/Sub服务，推荐的相关产品是Google Cloud Pub/Sub。您可以通过以下链接了解更多关于Google Cloud Pub/Sub的详细信息和使用方式： https://cloud.google.com/pubsub/docs/overview
相关·内容
我想注意到在Cloud /Sub(GCP)中不能在订阅服务器上处理的剩余消息。我不想让酒吧/潜艇在没有通知的情况下失去一些信息。但我不知道如何用:0.26.0-beta调用api。我发现我可以使用"gcloud beta公共订阅</
浏览 1提问于2017-10-30得票数 0
回答已采纳
我有一个google-pubsub的java客户机。我的订户每小时被触发一次，然后在公共广播上循环，直到它是空的。// A hotfix as cofman is too slow for ack // Fetch messages by order List<Received
浏览 0提问于2018-05-09得票数 3
回答已采纳
1回答
--我试图查询从bigquery到python的数据，但我遇到了一些问题。这是主要代码:import pandas_gbq{{})df = pandas_gbq.read_gbq('SELE
浏览 1提问于2019-12-22得票数 1
所以我们想知道Kafka vs PUB/Sub。基本上，我想知道在Kafka和Pub/sub中是如何维护消息一致性、消息可用性和消息可靠性的
谢谢
浏览 0提问于2016-07-25得票数 101
1回答
我正在使用使用RabbitMQ和MassTransit的pub/sub消息来集成几个RabbitMQ模块。大多数邮件订阅应该是持久的。但有些应该是暂时的。这如预期的那样起作用。
现在我正在尝试实现请求/响应消息。问题来了，因为现在发送方必须决定路由到哪个交换。这是错误的，因为我希望接收者决定是使用持久的还是暂时性的队列。假设一个模块中的所有请求使用者都是持久的或短暂的。是否可以声明一个“模块”-exchange，然后绑定到持久队列或临时队列？因此，发送方处理模块交换，模块决定要绑定到哪
浏览 1提问于2017-11-08得票数 0
在技巧方面，用户可以为ISP购买订阅服务，而在Web中，我需要知道用户是否订阅了该ISP。我怎么能做到这一点，甚至有可能？到目前为止我尝试过的
首先，我尝试通过ask-sdk调用我的技能的lambda函数，并请求我的技能的"getEntitledProducts“意图。但是，如何在技能会话之外使用ask-sdk获得正确的访问令牌？我尝试使用LwaClient，如所描述的，但在这里，我甚至不知道在调用LwaClient.get_access_token_for_scope(sco
浏览 1提问于2021-05-08得票数 1
回答已采纳
Facebook为第三方应用程序提供了一个，但它们似乎没有提供任何细粒度的用户管理功能。
我可能可以挂起OAuth ID，并为前两个需求在我的数据库中添加一个条目，但我不知道如何将Facebook用户白名单。
浏览 3提问于2017-10-18得票数 1
我们即将开始集成ActiveMerchant以处理该服务的经常性订阅费的过程。价格较高的计划对其账户中的数据量(例如用户、项目等)有更大的限制。
当计划价格发生变化时，我们希望在一段时间内(如6个月)为现有用户遵守以前的价格，然后开始收取更高的费率。
浏览 4提问于2009-01-23得票数 33
回答已采纳
我们正在考虑使用Azure blob存储作为备份的存储。但我们不确定交易价格在现实中对我们意味着什么。(它们收取每个存储卷的成本和每个事务的成本)
浏览 0提问于2013-01-10得票数 18
回答已采纳
假设我们有一个使用HttpWebRequest类的简单异步web请求{
HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create
浏览 0提问于2011-12-14得票数 5
回答已采纳
1回答
本教程有一个脚注，说明可以通过端口8080从集群外部访问这些服务。
但是在集群中，我有3个服务器和3个客户机，我应该将DNS指向哪里？有故障转移指向这3个客户端的DNS是否就足够了？
浏览 3提问于2021-06-05得票数 1
回答已采纳
4回答
我想监控“C：\Inetpub\ftproot\san”目录下所有文件夹的活动。.User可以处理任何类型的文件，而不仅仅是text files.Since，我们为每个用户提供了1 1GB的空间(比方说)，所以用户可以做任何事情来利用这个空间。
现在我想监控用户在其文件夹中执行的活动，比如创建新文件、删除现有文件或编辑文件。我想监控用户的活动，因为我必须跟踪分配给用户的空间，以便我可以限制用户只能使用1 1GB的空间，而且不能超过1 1GB。除了FileSystemWatcher之外，是否还有其他类可以使用，因为它只能在控制台应用程序中使用，而不能在and应用程序中使用？？任何帮助都会得到高度
浏览 0提问于2010-06-25得票数 1
本质上，我们构建了一个批量导入(基本上是批处理)解决方案，它通过客户帐户下的所有OneNote笔记本，分析每个用户的章节和页面数据，以及下载和存储所有页面内容--包括链接文档和图像。经过一段时间后，即使我们以相对较低的速率发送查询，我们也开始得到429个错误。
在数据量方面，客户笔记本电脑的平均版面大小为50-70页.每页平均包含到大约5个文档的链接供下载。为了不淹没Graph服务并保持在节流范围内，我们进行了大量的实验，并逐渐降低了请求率，使我们的请求率每4秒仅为一个查询。也就是说，在最大900图形AP
浏览 1提问于2018-04-10得票数 2
回答已采纳
我正在尝试通过c#(5.0)和python (3.9)应用程序通过ZeroMQ进行通信。对于.Net，我使用NetMQ和python。
只要两个应用程序使用同一种语言，我就可以让它们进行通信。我首先尝试了PUB-SUB原型模式，但由于没有成功，我尝试了REQ-REP，所以代码中仍然可以找到"PUB-SUB"-version的一些剩余部分。
浏览 2提问于2020-12-13得票数 1
回答已采纳
我正在开发一个基于Python的项目，可以访问各种Google API，如Google Contacts API，Pub/Sub API，Gmail API等。通过OAuth 2.0获取这些API的相关令牌和凭据目前是通过Google API控制台高度手动的。如何在注册过程中获得所有这些API的凭据，以便将凭据json文件保存到数据库中，然后管理邮箱？“注册谷歌”功能只产生一个基本的凭证，我不知道如何将用户路由到相关的页面，在那里我请求他/她允许使用API(谷歌联系人
浏览 1提问于2018-04-11得票数 3
3回答
微服务客户确认和事件源
、、、、
支付API和通知API分别订阅各自的事件。一旦完成，付款和通知API需要确认回订API。发布事件后，我的预订服务无法阻止呼叫并返回到客户端(前端)。
浏览 3提问于2019-01-30得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
