使用 EMQX Cloud 桥接数据到 GCP Pub/Sub

84 阅读 0 评论 56 点赞

我是靠谱客的博主活泼小蝴蝶，最近开发中收集的这篇文章主要介绍使用 EMQX Cloud 桥接数据到 GCP Pub/Sub，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

前不久，Google 宣布其旗下的 GCP IoT Core 即将在 2023 年 8 月 16 日停止提供服务。这意味着大量使用 GCP IoT Core 的用户可能需要将他们的 IoT 应用迁移到其他物联网云服务。除了云服务的迁移，很多用户也在直接利用谷歌云生态，使用 GCP 上丰富的数据服务来处理物联网数据。

作为和 GCP IoT Core 一样基于 MQTT 的全托管消息云服务，EMQX Cloud 支持部署在 GCP 多个区域，是替代 IoT Core 的理想选择。此外，EMQX Cloud 新增的 GCP Pub/Sub 数据桥接支持，可以帮助用户轻松无缝连接之前在 GCP 其他数据服务中创建的物联网应用，快速完成迁移且不影响现有业务。

GCP Pub/Sub 介绍

GCP Pub/Sub 是 Google Cloud Platform (GCP) 中的一项消息传递服务，可以让用户在应用程序之间进行实时数据流传递。它提供了丰富的 API，用户可通过各种语言对消息进行发布和订阅。此外，GCP Pub/Sub 还提供了丰富的数据处理工具，帮助用户对接收到的消息进行复杂的处理和分析。

充分利用 GCP 的大数据能力

GCP Pub/Sub 提供了丰富的数据处理服务，EMQX Cloud 支持数据桥接到 GCP Pub/Sub 后，用户就可以利用 GCP 的大数据分析能力，对物联网设备的数据进行更深入的分析，为物联网应用提供更为丰富的信息支持。同时，之前使用 GCP IoT Core 的用户，很有可能已经在 GCP 的数据处理服务中建立了完整的应用，那么此时更换云平台，只需建立数据连接，就可以使用之前创建的服务。

更强的数据处理能力

GCP Pub/Sub 提供了丰富的 API，用户可以通过编程方式对数据进行更精细的控制，实现更复杂的数据处理。

为出海用户提供更多便利

使用 EMQX Cloud，您可以得到最高 7*24 来自 EMQX Cloud 技术支持工程师的帮助，相较于和 GCP 海外的工作人员使用邮件沟通，效率会大大提升。并且 EMQX Cloud 提供了丰富的帮助文档和教学视频，助您轻松上手使用。

支持数据桥接到 GCP pub/sub 后，EMQX Cloud 可以为用户提供更为丰富的数据集成能力，让物联网应用更好地与 GCP 平台集成，为之前使用 GCP IoT Core 相关服务的物联网出海用户提供了极大的便利。

更多关于 Pub/Sub 的信息及使用方式，可以参考：用于应用和数据集成的 Pub/Sub | Google Cloud

如何使用数据集成功能桥接数据到 GCP Pub/Sub

如您需要使用 GCP Pub/Sub 服务，请访问 EMQX Cloud 海外站点注册账号使用，并且推荐您选择 GCP 平台创建部署。

创建 GCP 平台的专业版部署

选择云平台为 GCP，并按需选择规格，创建部署。

配置 GCP Pub/Sub

访问 GCP Pub/Sub 控制台，创建一个新的 topic。在此我们设置 Topic ID 为 my-topic。

配置数据集成桥接数据到 GCP Pub/Sub

访问 EMQX Cloud 控制台，在 Data Integration 页面中选择 GCP PubSub。

填写 Service Account JSON 和其他信息，并测试是否资源可用。

您可以在 GCP 控制台中，通过如下操作创建 Service Account JSON

选择 appropriate project - IAM & Admin - Service Accounts - Email，点击 KEYS，生成一个用于身份验证的 JSON 文件。

编写 SQL 规则并添加相关动作。

在此提供一段示例，您可以使用以下 SQL 语句创建新规则

SELECT
timestamp as up_timestamp,
clientid as client_id,
payload.temp as temp,
payload.hum as hum
FROM
"temp_hum/emqx"

测试规则是否成立。填写测试用 payload、topic 和 client 信息，点击 SQL Test 进行测试。

添加动作。在此我们使用上述创建的 GCP Pub/Sub topic 和信息模版。

# GCP Pub/Sub message template
{"up_timestamp": ${up_timestamp}, "client_id": ${client_id}, "temp": ${temp}, "hum": ${hum}}

将动作绑定到规则上后，点击 View details 可查看刚才创建的 SQL 语句规则和动作。

使用 MQTT X 进行消息收发测试。

您需要替换 broker.emqx.io 为您创建的部署的连接地址（可以在 Deployment Overview 页面找到），并添加设备认证信息。

测试结果如下，您也可以在 EMQX Cloud 控制台和 GCP 控制台看到相应的消息处理和数据转发情况。