谷歌云PubSub在Python中调用不正确
谷歌云PubSub是一种消息传递服务，用于在分布式系统中进行可靠的异步通信。它可以帮助开发人员构建可扩展的、事件驱动的应用程序，并实现解耦和高可靠性。
在Python中调用谷歌云PubSub时，需要使用Google Cloud Pub/Sub客户端库。以下是正确调用谷歌云PubSub的步骤：
- 安装Google Cloud Pub/Sub客户端库：
- 安装Google Cloud Pub/Sub客户端库：
- 导入必要的模块：
- 导入必要的模块：
- 创建Pub/Sub客户端：
- 创建Pub/Sub客户端：
- 创建主题（Topic）：
- 创建主题（Topic）：
- 发布消息（Publish）：
- 发布消息（Publish）：
- 创建订阅（Subscription）：
- 创建订阅（Subscription）：
- 接收消息（Pull）：
- 接收消息（Pull）：
谷歌云PubSub的优势包括：
- 可靠性：谷歌云PubSub提供了持久化存储和传递消息的能力，确保消息不会丢失。
- 可扩展性：Pub/Sub可以处理大规模的消息流量，并具有自动缩放的能力。
- 解耦性：Pub/Sub允许发送者和接收者之间解耦，使系统更加灵活和可维护。
谷歌云PubSub的应用场景包括：
- 实时数据处理：Pub/Sub可以用于处理实时生成的数据流，如日志、传感器数据等。
- 异步任务处理：Pub/Sub可以用于将任务分发给多个消费者进行并行处理。
- 事件驱动架构：Pub/Sub可以用于构建事件驱动的架构，实现系统之间的解耦和松耦合。
腾讯云提供了类似的消息传递服务，称为消息队列（Tencent Cloud Message Queue，CMQ）。您可以通过以下链接了解更多关于腾讯云CMQ的信息：
请注意，以上答案仅针对谷歌云PubSub在Python中的调用，并且不包含其他云计算品牌商的相关信息。
相关·内容
2回答
我在绞尽脑汁，但我不明白为什么会发生这个问题，我也找不出原因。我正在尝试读取图像并将其传递给pubsub。一旦消息通过pubsub发送，它就会被重定向到AutoML模型，以识别或预测给定的图像。file.filename) flash('File upload successful', 'info')
# Initializing PubSubpublisher,subscriber,topic,sub
浏览 15提问于2018-08-31得票数 2
回答已采纳
我们使用PubSub来排队，使用指向一个PubSub云函数的推送订阅。根据文档Cloud和According都将对来自PubSub的请求进行身份验证，云功能没有列出。我们使用了其他谷歌服务，比如调度程序来调用需要身份验证的函数，但在PubSub中却没有成功。我的问题是，云函数是否通过订阅目标帐户集支持来自PubSub的身份验证，还是需要该函数读取并处理JWT本身以进行身份验证？
浏览 1提问于2021-02-01得票数 5
回答已采纳
1回答
我有一个数据管道链，通过管道特定的Pub/Sub主题相互通信。每个管道都是完全无状态的，可以根据各自的pub/sub队列大小水平扩展。pipeline #2使用第三方API。此API有小时/日费率限制。是否有办法将发布/子主题/订阅吞吐量限制为每小时/一天特定数量的消息？
答案肯定是否定的。如果是的话，我的其
浏览 4提问于2022-06-15得票数 2
当尝试使用beam.ParDo调用如下所示的函数时 def start_bundle(self): return blobs
我认为start_bundle的全部目的是初始化self.someProperty，然后在'
浏览 1提问于2018-05-24得票数 1
我正在AWS Lambda函数上导入Stackdriver logging python库，如下所示： from google.cloud.logging.handlers') stackdriver.addHandler(handler)
我看到了这个错误，但它似乎不是来自我的代码中的任何特定行gapic_google_cloud_logging_v2-0.91.3-py3.6-nspkg
浏览 7提问于2017-07-30得票数 0
2回答
我有一个需要触发云功能的需求，一旦文件被放入另一个项目的google云存储桶中，云函数就会触发数据流作业。谷歌文档说这是不可能的，请看这里的这方面的任何投入都是非常感谢的
浏览 1提问于2021-03-12得票数 0
回答已采纳
使用案例： 我必须每天在谷歌云存储中存储请求/响应对象，希望每天创建文件夹(存储桶/年/月/日格式)，并存储当前日期/天内的所有对象。我的典型流程如下： Json消息发送给PubSub --> Cloud Function (Python) -> Google Cloud storage每日一次。查询:由于云函数可以并行触发PubSub中的每个事件(每天数百万条消息)，并且
浏览 26提问于2020-04-25得票数 0
回答已采纳
我目前正在从事一个谷歌云项目，该项目涉及将数据从PubSub转移到Datastore。这是在作为常驻应用程序运行的google云应用程序实例上运行的。我首先开始处理数据存储部分，没有遇到任何麻烦，但是当我尝试将其包含进来时，当涉及到支持pubsub的时候，应用程序就会崩溃。datastoreconst datastore = Datastore();
浏览 1提问于2018-07-10得票数 2
回答已采纳
我们目前正在向云PubSub发布有关来自谷歌云存储的SFTP到达的事件，我们可以很容易地实时处理这些事件，但当我们尝试从谷歌云存储读取ZIP文件时，我们会遇到一个问题。apache beam的Python端使得它与API中的这个类非常无缝，例如：为了能够相对轻松地从Google Cloud Storage中提取文件，我想知道在</e
浏览 0提问于2017-10-02得票数 0
我需要使用python脚本通过pubsub将文件批处理/流式传输到google云存储中。我已经使用了下面的python文件，能够看到从topic发布到订阅的消息，现在我想将这些单独的消息上传到一个文件中，需要加载到云存储中。你能建议我们在哪里可以修改以下脚本中的代码，将消息数据作为文件加载到云存储中(批量处理单个消息)
在path下面我们有python脚
浏览 1提问于2018-04-20得票数 0
1回答
GCP多账户自动成本控制服务
、、、、
我已经使用GCP指南中的示例代码来创建Python函数，以便在预算警报表明项目超出支出限制时发送消息并禁用项目计费。预算警报使用pubsub来激活Cloud函数。使用示例代码方法，云函数在被监视的项目中。该项目由一个特定的Google帐户拥有，当发布预算警报时，该帐户拥有使用pubsub的预算。
我想提供云功能到其他谷歌帐户作为一项服务。我想要做的是，当我自己的帐户之外的Google帐户中触发一个预算警报时，就会向我的Google帐户下的一个项目的云函
浏览 4提问于2021-10-20得票数 1
我有一个从电子商务网站抓取数据的网络刮板，现在，我的数据从熊猫数据帧中存储在BigQuery表中。但这些都是我手动完成的。例如，从GCP站点启动VM实例，然后使用远程SSH连接我的本地计算机，然后在项目文件夹上打开终端并运行才能开始抓取。然后，在该过程完成后，我再次手动关闭VM实例。我在寻找云函数，我看到的最大时间限制是540秒。由于我的程序执行时间太长，我不确定Cloud functions是否适用于我的情况。
有
浏览 1提问于2021-10-27得票数 0
与App Engine标准的云发布/订阅API集成
我正在开发一个标准的Python环境中的谷歌应用程序引擎应用程序。对于代码的某些部分，我需要与Google Cloud发布/订阅API集成。正如前面提到的，发布/订阅只能集成在App Engine灵活的环境中(顺便说一句，它也只是alpha版)。有人能描述一下如何在App Engine标准环境中集成Pub/Sub吗？我将在客户端(目前是移动平台)使用MQTT，在服务器端，我计划使
浏览 2提问于2017-06-25得票数 2
我正在尝试设置一个谷歌云数据流管道(流模式)，它读取pubsub主题消息，从发布的消息中提取信息(谷歌云存储中的对象名称)，然后启动另一个管道(批处理模式)来处理存储在谷歌云存储中的对象。是否可以在管道内启动另一个管道？
浏览 0提问于2017-01-09得票数 2
我正忙于使用谷歌云处理PubSub，我已经实现了谷歌PubSub订阅者，堆栈工作正常，但有时我会遇到一个问题，即回调超时，然后订阅者线程似乎挂起，如下所示：
DEBUG 2019-08-14 09:49:13,130 google.cloud.pubsub_v1.subscriber.policy.thread.dispatch_callback:287- Handling 1 batched requestsDEBUG 2019-08-14 09:49:15,441 google.cl
浏览 19提问于2019-08-14得票数 0
我使用的是python标准环境，我想向google pub/sub发布一条消息。然而，谷歌云库似乎没有包含在环境中，至少在没有某种额外配置的情况下是这样的。from google.cloud import pubsub这是在已部署的实例上运行的。google给出的使用pub/sub的例子是在灵活的环境中。
浏览 3提问于2017-04-26得票数 3
1回答
我试图使用将谷歌的PubSub消息写入。PubSub消息以json格式出现，我要执行的唯一操作是从json到parquet文件的转换。在官方文档中，我找到了一个由google提供的模板，它从Pub/Sub主题中读取数据，并将Avro文件写入指定的云存储桶()。问题是模板源代码是用Java编写的，而我更喜欢使用Python。
浏览 0提问于2020-07-21得票数 0
回答已采纳
我们正在使用Cloud sleuth来检测使用PubSub的微服务(使用spring cloud stream绑定器)。目前，PubSub跟踪不会自动传播到GCP云跟踪。因此，我们使用内部调用traces的谷歌云跟踪服务客户端来编写跟踪。对于每个跨度，我们还必须设置开始时间和结束时间。为了处理重试场景，我需要获取span的开始时间。
浏览 23提问于2021-08-16得票数 0
1回答
我有一个GCS (谷歌云服务)桶和一个谷歌PubSub主题，我希望这个桶中的事件自动发送到PubSub主题。当我运行此命令时我不断地得到
AccessDeniedException
浏览 5提问于2017-12-19得票数 0
回答已采纳
我需要从谷歌云pubsub.The数据是由一个物联网devices.Whenever产生的物联网设备发送数据到云我需要这些数据被从pubsub转移到firebase实时数据库。我只需要在database.How中的最后更新的值，我可以做到。
浏览 15提问于2018-07-27得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
