⽹聚云联 王⽂庭 基于边缘架构的可编程MQTT服务 CONTENTS 背景说明 O1 O2 O4 HPMQ简介 HPMQ开发说明 HPMQ未来规划 O3 1. 背景说明 物联⽹时代带来的变化 海量 连⽹ 设备 海量数据处理？ 设备安全性？ 共性：边缘 原来以数据中 ⼼为核⼼的云 端架构是否还 满⾜需求？ 01 02 03 边缘架构 ⼀种分布式计 算架构 物联⽹设备的纽带 2. HPMQ 简介 HPMQ是基于Rust语⾔开发的 下⼀代可编程边缘分布式 MQTT软件，主要有以下⼏个 核⼼特性： • Geo-Distributed • 可编程性 • 云边⼀体化 • 兼容异构设备 HPMQ （Hyperconverged Programmable MQTT) • 性能（C/C++/Rust） • 开发效率 (Rust/Golang/Java) ⼀句话概括，让设备具备边缘计算的能⼒。⽬前主要提供两种接⼊⽅式： 1）设备对接内置HPMQLite程序 2）设备通过MQTT协议透明接⼊ 为什么需要可编程性 带来什么好处？ 设备 程序 mqtt HPMQLite 上层MQTT Broker 设备 程序 HPMQ 上层MQTT Broker 通过边缘函数的⽅式快速兼容多⼚商 1）⾃定义协议+⾃定义函数 2）对接标准协议+公共函数

Configuration baetyl-function-manager Configuration baetyl-function-python Configuration baetyl-remote-mqtt Configuration baetyl-timer Configuration Device connect to Baetyl with Hub service Workflow Connection Message Synchronize between Baetyl-Hub and Baidu IoTHub via Baetyl- Remote-MQTT module Workflow Message Synchronize via Baetyl-Remote-MQTT module Development How to write a python script for Python runtime Convention Start/Stop Convention SDK Troubleshooting FAQ Resources Download Golang download MQTT download What is Baetyl Baetyl [https://baetyl.io] is an open edge computing framework of Linux

Configuration . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 41 i 6.7 baetyl-remote-mqtt Configuration . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 41 6.8 baetyl-timer Baetyl-Remote-MQTT module 69 10.1 Workflow . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 69 10.2 Message Synchronize via Baetyl-Remote-MQTT module . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 115 18.2 MQTT download . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

based on the MQTT protocol [http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt- v3.1.1-os.html], and supports four access methods: TCP, SSL, WS, and WSS; The official module baetyl-remote-mqtt is used to bridge two MQTT Servers for message synchronization and supports configuration of multiple message route rules. ; The official module baetyl-function-manager provides computing power based on MQTT message application OTA. baetyl-hub: Provides an MQTT-based message routing service. baetyl-remote-mqtt: Provides a bridge services for synchronizing messages between Hub and remote MQTT services. baetyl-function-manager:

. . . . . . . . . . . . . . . . . . . . . . . . . 71 10.2 Message Synchronize via baetyl-remote-mqtt service . . . . . . . . . . . . . . . . . . . . . . . . . . 72 11 Image capturing and AI model inference . . . . . . . . . . . . . . . . . . . . . . . . 118 18 FAQ 121 19 Resources Download 125 19.1 MQTT download . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . publishing functions based on the MQTT protocol, and supports four access methods: TCP, SSL, WS, and WSS; • The official module baetyl-remote-mqtt is used to bridge two MQTT Servers for message synchronization

27 8. MQTT. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.1. MQTT Quality . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.2. MQTT Retain Messages . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 514 87.32. Interceptor MQTT . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

27 8. MQTT. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.1. MQTT Quality . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.2. MQTT Retain Messages . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 514 87.32. Interceptor MQTT . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

27 8. MQTT. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.1. MQTT Quality . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.2. MQTT Retain Messages . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 512 87.32. Interceptor MQTT . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

27 8. MQTT. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.1. MQTT Quality . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.2. MQTT Retain Messages . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 512 87.32. Interceptor MQTT . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .

26 8. MQTT. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.1. MQTT Quality . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 28 8.2. MQTT Retain Messages . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 503 87.32. Interceptor MQTT . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .