场景：

目前接手一个物联网项目，目前基本整理出了如下2套解决方案

图一：是我新调研的架构（基于EMQX架）

图二：是我们之前的架构（基于非EMQX产品+Flink架构）

我始终相信，少一层，则快一点！！！

一、打通：边缘-网关-EMQX-Influxdb

1、边缘与网关

这块我们的项目，为从乙方的现场进行采集，然后将数据进行汇总，通过统一网关进行publish到broker，所以这里不做过多的说明。
关于这块如何我们进行自测，可以通过很多压测工具，将原来的url从http协议改为mqtt协议进行请求即可

非性能测试工具可以使用 MQTT X
地址：https://mqttx.app/?utm_source=mqttx&utm_medium=referral&utm_campaign=logo-to-homepage

2、EMQX

EMQX分为企业版和开源版
区别：开源版，无法直接将数据写入任何数据库，只能通过webhook
但是企业版，可以有10个免费的使用连接数

2.1 EMQX企业版

因为开源版还需要添加webhook的自建服务，所以这里不进行说明
如果使用企业版记得记得不要使用 v5.0

2.2 启动 EMQX

macos 环境
下载对应的release，解压缩文件到本地

./bin/emqx start

启动成功后可以通过地址访问dashboard：http://localhost:18083/

2.3 使用规则写入Influxdb

点击【规则】

3、InfluxDB

1、本地化部署

我们将日志进行 mount volume（挂载卷）

mkdir path/to/influxdb-docker-data-volume && cd $_

1.1、非后台运行方式

docker run \--name influxdb \-p 8086:8086 \--volume $PWD:/var/lib/influxdb2 \influxdb:2.6.1

1.2、后台运行方式

docker run \--name influxdb \-d -p 8086:8086 \--volume $PWD:/var/lib/influxdb2 \influxdb:2.6.1

telegraf --config http://localhost:8086/api/v2/telegrafs/0add4b0046fc3000

2、获取api-token

3、安装 MQTT插件

4、初识 Influxdb-dashboard