如果我多次订阅同一主题，会发生什么情况？(Python，Google Pubsub)
如果您多次订阅同一主题，在Google Pubsub（谷歌云平台的消息传递服务）中会发生以下情况：
- 消息被所有订阅者接收：每个订阅者都会独立接收到相同的消息副本。这意味着，如果有N个订阅者订阅了同一主题，那么每个订阅者都会独立地接收到相同的消息。
- 每个订阅者独立确认消息：每个订阅者都需要独立确认已经接收和处理了消息。这样可以确保消息被每个订阅者都可靠地处理。
- 每个订阅者具有自己的订阅状态：即使多个订阅者订阅同一主题，它们的订阅状态是相互独立的。每个订阅者可以自由地确认、拉取和管理自己的消息进度。
- 消息不会被跳过：即使多个订阅者同时接收到消息，每个订阅者都有机会处理该消息。不会因为其他订阅者已经接收到消息而跳过某个订阅者。
Google Pubsub是Google Cloud Platform（GCP）提供的一种可扩展的实时消息传递服务，适用于构建分布式、事件驱动的应用程序和服务。它可以帮助您在应用程序之间可靠地传递和传输消息，支持高吞吐量、低延迟的消息传递需求。
关于Google Pubsub的相关产品是Google Cloud Pub/Sub，您可以在以下链接中了解更多信息： https://cloud.google.com/pubsub/
相关·内容
如果我有以下代码，会发生什么不好的事情吗？它会尝试创建新的订阅吗？subscribe是幂等运算吗？subscriber = pubsub_v1.SubscriberClient()
print(msg.data) msg.acksubscriber.subscribe(self.path, callback=f)
time.sleep(60)
create_subscriptions() <e
浏览 31提问于2019-05-24得票数 0
回答已采纳
我正在建立一个概念的简单证明，以学习Google中的一些概念，特别是PubSub和Dataflow。我有一个PubSub主题greetingconst escapeHtml = require('escape-html');const { PubSub } =
浏览 0提问于2019-05-16得票数 7
我部署了一个云运行服务，带有一个事件弧触发器，它在幕后创建一个pubsub主题，该触发器将订阅该主题。我之前已经多次重新部署了服务，订阅从未像这样消失过。删除并重新创建触
浏览 0提问于2021-06-17得票数 1
4回答
我正在使用Pubsub(推送)和Cloud Run，我将在其中部署一个使用Spring Boot构建的Java应用程序。 我有两个案子。假设我有Service A在云上运行时，由于负载较高，需要运行10个容器/实例。我想： 推送消息(来自云函数)到全部(广播)的容器Service A 推送消息(来自云函数)到单一任意容器Service A 背景：我的Cloud Run服务将使用服务器发送的事件将数据直接推送到客户端在某些情况下，我需要将消息推
浏览 69提问于2021-02-14得票数 1
我的google云中有项目A和项目B。我将我的配置设置为项目A，但是当我尝试使用我的发布/订阅依赖的python脚本时，在项目B中查找订阅，然后会给出这个错误：我应该注意，我没有在我
浏览 0提问于2017-10-08得票数 0
当创建新的Dataflow Pub/Sub到BigQuery模板时，可以指定PubSub topic。似乎无法提供现有的PubSub subscription，相反，每当数据流模板运行时都会创建一个新的订阅。就我所理解的PubSub模型而言，确保我们继续从主题的同一位置读取数据的唯一方法是重用相同的订阅，这里似乎没有这样的选项。
当用户想重新部署这样的数据流模板时会发生什么？我们会失去部署之间的所有数据吗？
浏览 0提问于2018-09-18得票数 2
回答已采纳
我期待着将数据从OGG流到BQ中。做这件事最好的方法是什么？来自Oracle Golden的数据可以直接流到BigQuery中吗?或者我们需要一些连接器吗？
请建议最好的方法来做这件事？
浏览 20提问于2020-07-05得票数 0
我有一个Google主题，它有时包含数千条消息，有时甚至没有消息。这些消息表示每个任务可能需要超过一个小时的任务。最好我能够使用Cloud来实现这一点，因为它能够很好地适应需求，如果发布了一千条消息，我希望云运行实例的100多个可以旋转起来。这些运行实例是通过推送订阅启动的。如果没有，PubSub将其超时，并再次发送，导致任务重新启动，直到第一个任务最终确认它为止(这将导致同一任务多次运行)。云运行
浏览 0提问于2019-08-05得票数 11
我有一个包含2个复制节点的AWS ElastiCache实例(集群模式禁用)。我能够使用redisson (在同一集群中运行的服务)通过我的java客户端进行连接。但是，当我使用python redis客户端时，它似乎无法连接。或者它似乎连接了，但没有订阅。我没有看到任何关于连接的错误，但是当我订阅一个发布/订阅主题时，我也没有得到任何确认。即使是返回成功订阅的1的第一条
浏览 25提问于2021-08-16得票数 0
回答已采纳
我正在尝试使用谷歌提供的模板PubSub to BigQuery设置一个数据流作业。我看到一个用于指定云发布/订阅输入主题的选项，但我没有看到任何用于在GCP控制台UI中指定发布/订阅输入订阅的选项。
如果我提供了主题，job会自动创建一个订阅来读取所提供的主题中的消息。这样做的问题是，在数据流作业启动后，作业将仅看到发布到主题</em
浏览 3提问于2018-01-12得票数 3
回答已采纳
我试过google pubsub dead lettering。
我使用控制台云为1个订阅启用死字标记。我已经将死信主题和maxAttemptDelivery属性设置为5。我的期望是，如果一条消息在一次订阅中重新发送超过5次，该消息将自动从订阅队列中删除。但是它并没有发生，消息仍然在队列中无限循环。当我打印属性deliveryAttempt时，值始终为空。我在代码
浏览 18提问于2020-05-09得票数 0
我正在尝试构建一个流/批处理管道，它从发布/订阅中读取事件，并使用python3.6将它们写入BigQuery 根据文档，云发布/订阅会为每条消息分配唯一的message_id和timestamp，用于检测订阅者收到的重复消息(https://cloud.google.com/pubsub/docs/faq) 要求如下: 1)消息可以以任意顺序传入(异步消息) 2)唯一Id和时间戳(当记录被
浏览 13提问于2019-10-16得票数 0
(UnaryCallable.java:112) ~[gax-1.49.1.jar:1.49.1] at com.google.cloud.pubsub.v1.TopicAdminClient.crea
浏览 25提问于2020-03-13得票数 1
如何在GCP Pub/Sub中将消息从一个主题大容量地移动到另一个主题？具体来说，用例用于将死信主题中的消息移回原始主题以进行再处理。
浏览 7提问于2020-07-29得票数 1
我有两个项目--A项目和B项目。TestIamPermissionsRequest iamreq = new
浏览 4提问于2016-02-29得票数 0
是否有可能在一个项目中设置一个公共主题/订阅者，在同一个或另一个google项目中进行http推送到云功能？我知道有一些PubSub触发器，但是当发布子主题在另一个google项目中时，这些触发器不起作用。奇怪的是，这是否甚至可以通过一个订户推送。如果我试图创建它，我就会得到thiis pubsub错误INVALID_ARGUMENT。我不确定这是否是因
浏览 0提问于2018-04-06得票数 2
我创建了一个订阅一个主题的参与者来获取消息。这是唯一订阅此主题的行为者。当主题参与者没有订阅某个主题的订阅者时，它会将自己从接待员中取消
浏览 0提问于2022-07-26得票数 1
1回答
我试图使用Google PubSub在两个服务之间传递和接收消息。但是，发送的一些消息似乎是随机删除的，并且没有被订阅者的回调方法处理。subscription_path = subscriber.subscription_path(GOOGLE_CLOUD_PROJECT消息是从发布服务器
浏览 0提问于2018-09-05得票数 1
1回答
我准备了几件事：
当我使用来自回购的片段时，我可以在这个模拟的项目中很好地处理主题和订阅。但是，在我的(Python)管道中使用DirectRunner
浏览 9提问于2022-11-17得票数 0
我正在学习Google /Sub，并遵循以下正式文档：
发生了内部错误: 403用户未被授权执行此操作。我想是因为身份验证问题吧？任何帮助都将不胜感激。
浏览 2提问于2016-06-03得票数 16
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
