车联网设备接入一消息流转一API服务全链路标准架构

1. 用途和受众

1.1 预期用途

• 指导华为云上车联网设备接入、消息流转和API服务全链路的设计和开发。
• 为售前、解决方案设计、实施和审查提供可重用的架构模式。
• 作为解决方案手册、交付包或实际部署的架构基础。
• 定义安全性、可靠性、性能、成本、运营和合规性护栏。

1.2 目标受众

• 华为云 IoTDA 用户和车联网设备接入开发人员
• 车联网平台架构师和后端服务开发人员
• 车队管理系统和车主 App 开发团队
  
• 关注车联网数据实时处理与 AI 分析（异常检测、驾驶安全模型）的数据工程师和算法工程师
• 华为云 APIG 用户和 API 网关运维管理员

2. 参考架构概述

2.1 架构描述

本架构以车联网设备接入为核心场景，构建从设备端到API服务交付的全链路标准架构。设备通过IoTDA（IoT设备接入服务）接入云平台，经WAF（Web应用防火墙）防护后由ELB（弹性负载均衡）分发流量至APIG（API网关）。APIG将请求路由至后端服务，业务消息通过Kafka消息队列实现异步解耦与流转，CS（流计算服务）对实时消息流进行处理，SMN（消息通知服务）触发事件通知。计算层采用CCE（云容器引擎）部署微服务和FunctionGraph（函数服务）处理事件驱动逻辑。数据层由GaussDB（数据库）存储结构化数据、OBS（对象存储）存储非结构化数据、DCS（分布式缓存）提供低延迟缓存。ModelArts（AI开发平台）提供模型训练与推理能力，DLI（数据湖探索）进行大数据分析。IAM（身份认证）统一管理访问权限，CES（云监控）和AOM（应用运维）提供全链路监控与运维能力。

2.2 业务背景

2.3 架构优点

• 全链路标准化：从IoTDA设备接入到APIG API服务交付，各层职责清晰，组件间通过标准协议对接，降低集成复杂度。
• 异步解耦与高吞吐：Kafka消息队列将设备消息生产与消费解耦，支持百万级设备并发接入，峰值流量通过消息缓冲平滑处理。
• 安全纵深防御：WAF在入口拦截Web攻击，IAM统一身份认证与权限管控，APIG提供API级别的鉴权与限流，形成多层安全防护体系。
• 弹性伸缩：CCE支持微服务按需弹性扩缩容，FunctionGraph事件驱动自动伸缩，应对流量波峰波谷无需预留资源。
• 数据分层存储：GaussDB支撑事务型结构化数据、OBS存储海量非结构化数据、DCS提供低延迟缓存，按数据特征选择最优存储方案。
• AI与数据分析融合：ModelArts支持模型训练与在线推理，DLI对数据湖中海量车联网数据进行交互式分析，实现数据驱动决策。
• 全链路可观测：CES监控云资源指标，AOM提供应用层链路追踪与日志聚合，实现从基础设施到应用代码的端到端可观测性。

2.4 设计关注点

2.5 典型架构

典型架构图

用实际服务替换通用节点。显示相关的区域、可用区、VPC、子网、信任边界、入口和出口边界。

2.6 流程描述

1. 设备接入：车联网终端设备通过MQTT/HTTP协议连接IoTDA（IoT设备接入服务），IoTDA完成设备身份认证与注册，建立设备与云平台的长连接通道。
2. 安全防护与流量分发：设备/API请求经WAF（Web应用防火墙）进行安全过滤，拦截恶意请求后由ELB（弹性负载均衡）将流量均匀分发至后端APIG实例。
3. API路由与鉴权：APIG（API网关）接收请求后进行API级别的身份认证、限流和路由，将合法请求转发至后端CCE微服务或FunctionGraph函数。
4. 消息生产与流转：业务服务将设备消息发布至Kafka消息队列，消息按Topic分区存储，实现生产者与消费者的异步解耦。
5. 流式实时处理：CS（流计算服务）订阅Kafka消息流，对设备遥测数据进行实时清洗、聚合和规则计算，输出处理结果至下游存储或通知服务。
6. 事件通知：SMN（消息通知服务）根据规则触发告警或业务通知，将事件推送到订阅端（邮件、短信、HTTP回调等）。
7. 数据持久化：结构化业务数据写入GaussDB（数据库），非结构化数据（如设备文件、日志）存入OBS（对象存储），热点查询数据缓存至DCS（分布式缓存）。
8. AI推理与分析：ModelArts（AI开发平台）加载训练好的模型对设备数据进行在线推理，DLI（数据湖探索）对OBS/GaussDB中海量数据进行交互式查询与统计分析。
9. 监控与运维：CES（云监控）采集云资源指标，AOM（应用运维）提供应用链路追踪与日志聚合，IAM（身份认证）全程管控访问权限，保障全链路安全可观测。

2.7 云服务产品清单

3. 参考链接

• 产品文档：
• 实施指南：
• 源代码或 IaC：
• 操作手册：
• 安全性和合规性映射：

4. 使用限制

• IoTDA标准版设备连接数有上限，超大规模场景需评估是否需要升级实例规格或分租户接入。
• Kafka消息默认保留时间有限（通常7天），需根据业务合规要求调整保留策略，长期数据需归档至OBS。
• FunctionGraph函数执行有超时限制（最长9分钟），长时间运行的任务需拆分为异步任务或迁移至CCE。

附录 A. 术语和缩略语