# Influx数据中继

**Repository Path**: luischen/databridge

## Basic Information

- **Project Name**: Influx数据中继
- **Description**: 接收post数据，进行转换后发送到自定义目的地。
支持influxdb数据转发，支持自定义数据格式的转发插件
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 4
- **Forks**: 0
- **Created**: 2021-07-29
- **Last Updated**: 2025-04-14

## Categories & Tags

**Categories**: Uncategorized

**Tags**: 数据传输

## README

# DataBridge

#### 介绍
接收post格式的数据，通过自定义的转换方式，输出到任意目的地。

#### 软件架构
![输入图片说明](https://images.gitee.com/uploads/images/2021/0729/160347_f2440e0c_4809353.png "屏幕截图.png")

![输入图片说明](https://images.gitee.com/uploads/images/2021/0729/162304_ae815b6f_4809353.png "屏幕截图.png")

#### 安装教程

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%E6%95%B0%E6%8D%AE%E6%8E%A5%E5%85%A5MQTT/  

#### 参与贡献

1.  Fork 本仓库
2.  提交issue