google-cloud-platform - 使用推送订阅作为负载均衡器的细节

Question

我正在尝试使用推送订阅发送 IoT 命令。我有两个原因。首先，我的设备经常处于不稳定的连接状态，所以通过 pubsub 让我可以重试，并且在我发送消息时我不必等待 QoS 1 超时(我仍然需要它，因为我将其记录下来以备后用) .第二个原因是推送订阅可以充当负载均衡器。据我了解，如果多个消费者收听同一个推送订阅，每个消费者都会收到一部分消息，从而有效地平衡了我的工作量。现在我的问题是，这种平衡是我在拉取订阅中观察到的一种行为，我想知道:

推送订阅的行为是否相同？

这是平衡工作量的可靠方法吗？

如果有 15 个实例监听该订阅，我是否保证这些命令最多执行一次？

这是我想要实现的图表:

这里的想法是，我仅在实例接收到要处理的设备子集时(当推送订阅触发时)与 IoT Core 交互。另请注意，我不需要这个完美的 1 个实例来进行 1 个设备平衡。我只需要以半均等的方式分配工作量。
编辑:问题不清楚，所以我重写了它。

Answer 1

我认为您对 Pub/Sub 背后的概念有些困惑。通常，您将消息发布到 的主题。一个 或 多个 订户。我更喜欢将 Pub/Sub 与由大型出版公司出版的杂志进行比较。喜欢该杂志的人可以通过订阅获得该杂志的副本。然后，当该杂志的新版本到来时，将向杂志订阅者发送一份副本，在所有订阅者中具有完全相同的内容。
对于 Pub/Sub，您可以为一个主题创建多个推送订阅，每个主题最多 10,000 个订阅(也是每个项目)。您可以在 documentation 中阅读有关这些配额的更多信息。 .这些推送订阅可以包含不同的端点，在您的情况下，代表您的 IoT 设备。回到出版公司的例子，这些推送端点可以看作是订阅者的地址。
这是 example IoT Core 架构，专注于处理从设备到商店的数据。反过来也可以。将消息(包括设备/注册表 ID)从您的前端发送到包装在 API 网关中的云函数。然后，此云函数将消息发布到主题，主题将消息发送到使用 MQTT 协议(protocol)发布消息的云函数。我为您制定了松散耦合的两个流程，因此如果您的设备或处理出现任何问题，数据不会丢失。
存储设备:

设备

物联网核心

发布/订阅

云功能/数据流

存储(BigQuery 等)

前端到设备:

前端(点击按钮)

API 网关/云端点

云函数(发送命令到 pub/sub)

发布/订阅

云功能(使用 MQTT 向设备发送命令)

设备(执行命令)