Skip to content

Latest commit

 

History

History
115 lines (80 loc) · 2.69 KB

README.md

File metadata and controls

115 lines (80 loc) · 2.69 KB

InfluxDBReader 插件文档

1 快速介绍

InfluxDBReader 插件实现了 DataX 从 InfluxDB 读取数据。 原厂大佬的代码犹如神仙打架 ，ლ(ٱ٥ٱლ) ，渣农含泪自研丐版。亲测可用，除非口罩戴的姿势不对！

作者信息： wowiscrazy@2020。有问题联系：wowiscrazy@163.com 。欢迎贡献意见或者源码持续改进。

（源码基于父项目，不包含在本项目中，如果觉得依赖配置麻烦，可直接使用打包好的influxdbreader插件， 位于target\datax\plugin\reader文件夹下，将其中的influxdbreader整个文件夹拷贝出来黏贴到DataX软件的datax\plugin\reader文件夹下即可安装完并使用。客官，下载后可用麻烦给点个小星星哦。）

2 功能说明

2.1 配置样例

  • 配置一个从 InfluxDB 数据库同步抽取数据到本地的作业(注意：查询语句中，time字段放在第一个)：
{
  "job": {
    "content": [
      {
        "reader": {
          "name": "influxdbreader",
          "parameter": {
            "dbType": "InfluxDB",
            "address": "http://xxx.xxx.xxx.xxx:8086",
            "username": "xxx",
            "password": "xxx",
            "database": "xxx",
            "querySql": "select time,xx,xx from xxxx limit 2020"
          }
        },
        "writer": {
          "name": "streamwriter",
          "parameter": {
            "encoding": "UTF-8",
            "print": true
          }
        }
      }
    ],
    "setting": {
      "speed": {
        "channel": 1
      }
    }
  }
}

2.2 参数说明

  • name

    • 描述：本插件的名称
    • 必选：是
    • 默认值：influxdbreader

  • parameter

    • dbType

      • 描述：目标数据库的类型
      • 必选：是
      • 默认值：无
      • 注意：目前仅支持 "InfluxDB"。

    • address

      • 描述：InfluxDB 的 HTTP 连接地址
      • 必选：是
      • 格式：http://IP:Port
      • 默认值：无

    • username

      • 描述：InfluxDB 的 用户名
      • 必选：否
      • 说明：如果有用户名请填写

    • password

      • 描述：InfluxDB 的 密码
      • 必选：否
      • 说明：如果有密码请填写

    • database

      • 描述：InfluxDB 的 数据库名称
      • 必选：是
      • 默认值：无

    • querySql

      • 描述：InfluxDB 的 查询sql语句
      • 必选：是
      • 默认值：无

2.3 类型转换

DataX 内部类型 InfluxDB 数据类型
String InfluxDB 数据点序列化字符串，包括 time、tags、fields 和 value