自主掌控设备接入
为 Google Cloud 应用管理 MQTT 连接、设备认证和消息路由。
EMQX FOR GOOGLE CLOUD
Google Cloud 上的企业级 MQTT
在 Google Cloud 上使用 EMQX 连接设备、处理 MQTT 数据，并将数据实时传输至 Pub/Sub 和 BigQuery。
- 物联网设备
- 500M+
- 车联网连接
- 25M+
- Docker 下载量
- 50M+
- 集群部署
- 500K+
概览
为什么在 Google Cloud 上选择 EMQX
结合 Google Cloud 基础设施与 EMQX，构建可靠、可扩展的物联网消息服务。
运行在 Kubernetes 上
在 Google Kubernetes Engine（GKE）上部署 EMQX 企业版，使用 EMQX Operator 将集群与其他 Kubernetes 工作负载统一管理。
连接 Google Cloud 服务
将选定的 MQTT 数据发送到 Pub/Sub 供事件驱动应用使用，或写入 BigQuery 进行查询和分析。
只发送需要的数据
在投递前过滤无用消息、只保留有用字段，减少下游服务需要处理的数据量。
架构
EMQX 与 Google Cloud 集成架构
以 EMQX 作为中央数据枢纽，连接设备与 Google Cloud 服务。
传感器
车辆
设备
工业设备
网关
EMQX 企业版
MQTT Broker
规则引擎
数据集成
直接集成
Pub/Sub
将处理后的事件发布到 Pub/Sub 主题。
直接集成
BigQuery
将处理后的记录写入 BigQuery 表。
下游 Google Cloud 工作流
通过 Pub/Sub 订阅和 Google Cloud 数据管道衔接处理、存储和报表。
- Dataflow
- Bigtable
- Data Studio
核心能力
将设备连接至 Google Cloud
处理消息、管控设备访问，并将数据投递到应用所用的 Google Cloud 服务。
MQTT 5.0 支持
支持 MQTT 3.x 和 5.0 客户端接入，可根据应用需要使用共享订阅、用户属性等特性。
使用 SQL 过滤和转换
在数据转发到云端应用之前，匹配 MQTT 主题、选取 Payload 字段并转换字段值。
使用 JWT 认证设备
由 EMQX 校验客户端 Token，并根据您的身份系统和设备凭证配置签名密钥与 Claim 校验规则。
管控设备访问
使用 TLS 保护 MQTT 连接，通过客户端认证和主题权限控制哪些客户端可以连接、发布和订阅。
发布到 Google Cloud Pub/Sub
将规则处理结果转发到指定的 Pub/Sub 主题，再通过订阅对接下游应用和数据处理管道。
灵活选择部署模式
可在 Google Cloud 上使用全托管的 EMQX Cloud，在自己的项目中使用 BYOC，也可在 Compute Engine 或 GKE 上自托管。
工作原理
三步完成从 MQTT 到 Pub/Sub 的数据流转
连接设备、处理消息，并将结果发布到指定的 Pub/Sub 主题。
- 1
连接设备
在 MQTT 客户端中配置 EMQX 连接地址和凭证，然后将遥测数据发布到应用使用的主题。
- 2
处理消息
创建规则来选择主题和字段、过滤无用事件，并转换 Payload 中的值以适配 Pub/Sub。
- 3
发布并验证
使用所需凭证配置 Pub/Sub 连接器和 Sink。发布一条测试消息，确认订阅中能收到该消息。
迁移
用 EMQX 替代 IoT Core
IoT Core 已停用，可为原有应用重新规划设备连接、认证和 Pub/Sub 路由。
以 MQTT 为核心
设备通过标准 MQTT 协议接入，再用 SQL 规则为 Google Cloud 应用处理消息。
规划认证与切换
配置 EMQX 认证，更新客户端连接地址和凭证，并在正式上线前测试连接与重连行为。
重新对接数据管道
配置并测试从 EMQX 到 Pub/Sub 的数据投递，确保下游应用收到预期的主题和 Payload。
部署
选择在 Google Cloud 上运行 EMQX 的方式
可选择由 EMQX Cloud 托管运维，在自己的项目中使用 BYOC，或在 Compute Engine、GKE 上自托管。
Google Cloud 上的 EMQX Cloud
在 Google Cloud 上运行 EMQX Cloud Dedicated Flex，使用专属资源，由平台托管 Broker 运维。
Google Cloud 上的 BYOC
在您自己的 Google Cloud 项目内运行托管 EMQX 集群，将基础设施和数据保留在您的环境中。
了解 BYOC在 Compute Engine 或 GKE 上自托管
在 Compute Engine 或 GKE 上部署和管理 EMQX 企业版，全面掌控基础设施。
下载 EMQX 企业版资源
探索 Google Cloud 上的 EMQX
FAQ
常见问题
EMQX 提供 MQTT 设备连接、JWT 认证和基于 SQL 的消息处理，可将处理后的数据发布到 Pub/Sub，供下游应用使用。从 IoT Core 迁移时，需要提前规划并测试设备连接地址、凭证、主题映射和客户端切换。
EMQX 内置 Pub/Sub 和 BigQuery 数据集成。Pub/Sub 可以为下游应用和 Dataflow 管道提供数据。其他目标服务可能需要兼容的连接器或单独的数据接入流程。请根据您的 EMQX 版本和部署方案确认相应集成是否可用。
如需托管运维，可在支持的 Google Cloud 区域使用 EMQX Cloud Dedicated Flex；如需在自己的项目中运行托管集群，可选择 BYOC。如需自托管，可在 Compute Engine 或 GKE 上运行 EMQX 企业版，并自行管理基础设施。
可以。在已配置的 Sink 将结果转发到下游之前，SQL 规则可以匹配主题、选择字段、过滤消息并转换 Payload 中的值。
首先需要一个支持 Pub/Sub 集成的 EMQX 部署。创建 Pub/Sub 主题，提供网络访问以及具有发布权限的凭证，然后配置连接器、规则和 Sink。最后发布一条有代表性的消息，并通过订阅确认消息已送达。