代码拉取完成，页面将自动刷新
接收post格式的数据，通过自定义的转换方式，输出到任意目的地。
git clone https://gitee.com/luischen/databridge.git cd databridge && mvn install
注意，本项目不是一个开箱即用的App，而是提供了一种处理InfluxDB数据的思路，是一个类似脚手架性质的项目。 开发人员可以通过fork项目来定义自己的处理逻辑。
接收的输入格式：
model,item_code=A_TA1_TL1_TW001_TE01_XM001 value=77.9 1628577970371000000
model,item_code=A_TA1_TL1_TW001_TE01_XM001_U value=100 1628577970371000000
model,item_code=A_TA1_TL1_TW001_TE01_XM001_D value=80 1628577970371000000
可以直接通过配置选择已经支持的destination，也可以自定义destination。
| 配置项 | 是否必需 | 默认值 | 说明 |
|---|---|---|---|
| server.port | 是 | NA | 服务监听端口 |
| companyCode | 否 | POC | 公司编码，数据指标的前缀 |
| buffer-size | 否 | 20 | 消息缓冲的数量 |
| delay-minute | 否 | 1 | 消息发送的延迟时间 |
| send-interval | 否 | 500 | 定时任务的时间，单位ms |
| sample-count | 否 | -1 | 定时任务周期内采样的数量，-1表示全量发送 |
| outbound.destination | 是 | NA | 消息目的地，可选项rc、influx2、http,默认console |
| mqtt.broker.* | 否 | NA | 消息输出目标为mqtt的时候必填 |
| http.* | 否 | NA | 消息输出目标为http的时候必填 |
可参考文章：
https://luischen.github.io/2021/12/22/InfluxDB数据接入MQTT/
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手