python - 在 python 中使用 IOT 适配器和 google pub/sub api 将 MQTT 与 GCP 集成

Question

与来自 App Engine Standard 的 Cloud Pub/Sub API 集成

我正致力于在标准 Python 环境中开发 Google 应用引擎应用程序。对于代码的某些部分，我需要与 Google Cloud 发布/订阅 API 集成。

如前所述here , Pub/Sub 只能集成在 App Engine 灵活的环境中(顺便说一句，它也只是在 alpha 中)。有人可以描述如何在 App Engine 标准环境中与 Pub/Sub 集成吗？

我的用例描述

我正在尝试使用 Agosto IOT 代理将 MQTT 与谷歌应用引擎集成。我将为客户端(目前为移动平台)使用 MQTT，在服务器端，我计划使用 pub/sub 来接收/发送消息并将相关数据保存到数据库。

Answer 1

您可能想尝试使用新的 Google Cloud IoT Core产品(完全公开，我在研究它)而不是在 App Engine 上托管 MQTT。 Cloud IoT Core 让您可以连接到 Google 提供的 MQTT 网桥，该网桥会将您的数据放入 Google Cloud PubSub。您可以使用 Google Cloud DataFlow 将数据从 PubSub 移动到您的数据仓库进行分析，或者可以使用您自己的数据库作为 DataFlow 的输出。

与 Google Cloud IoT Core MQTT 桥通信的连接详细信息是 discussed in detail in the documentation但您需要注意的重要连接属性是主机名 (mqtt.googleapis.com) 端口(8883 或 443)和 MQTT 密码/客户端 ID，它们将基于您为服务。

需要根据您尝试访问 MQTT 桥的编程语言来选择您的实际 MQTT 客户端。如果您尝试使用 Android，您可以从 Java MQTT client sample 开始并可能以某种方式结束 like the Android Things Cloud IoT sensor hub connector来自 AndroidThings 团队。