InfluxDB2 Reader¶

InfluxDB2Reader 插件实现了从 InfluxDB 2.0 及以上版本读取数据。

注意，如果你的 InfluxDB 是 1.8及以下版本，则应该使用 InfluxDBReader 插件

示例¶

以下示例用来演示该插件如何从指定表(即指标)上读取数据并输出到终端

创建 job 文件¶

创建 job/influx2stream.json 文件，内容如下：

job/influx2stream.json

{
  "job": {
    "content": {
      "reader": {
        "name": "influxdb2reader",
        "parameter": {
          "column": [
            "location",
            "height",
            "wet"
          ],
          "connection": [
            {
              "endpoint": "http://localhost:8086",
              "bucket": "test",
              "table": [
                "temperature"
              ],
              "org": "com.wgzhao"
            }
          ],
          "token": "YOUR_SECURE_TOKEN",
          "range": [
            "-1h",
            "-5m"
          ],
          "limit": 10
        }
      },
      "writer": {
        "name": "streamwriter",
        "parameter": {
          "print": "true"
        }
      }
    },
    "setting": {
      "speed": {
        "bytes": -1,
        "channel": 1
      }
    }
  }
}

运行¶

执行下面的命令进行数据采集

bin/addax.sh job/influx2stream.json

参数说明¶

配置项	是否必须	数据类型	默认值	描述
endpoint	是	string		无
token	是	string	无	访问数据库的 token
table	否	list	无	所选取的需要同步的表名（即指标)
org	是	string	无	指定 InfluxDB 的 org 名称
bucket	是	string	无	指定 InfluxDB 的 bucket 名称
column	否	list	无	所配置的表中需要同步的列名集合，详细描述见 rdbmreader
range	是	list	无	读取数据的时间范围
limit	否	int	无	限制获取记录数

column¶

如果不指定 column, 或者指定 column 为 ["*"] ，则会读取所有有效的 _field 字段以及 _time 字段否则按照指定字段读取

range¶

range 用来指定读取指标的时间范围，其格式如下:

{
  "range": ["start_time", "end_time"]
}

range 由两个字符串组成的列表组成，第一个字符串表示开始时间，第二个表示结束时间。其时间表达方式要求符合 Flux 格式要求,类似这样:

{
  "range": ["-15h", "-2h"]
}

其中第二个结束时间如果不想指定，可以不写，类似这样：

{
  "range": ["-15h"]
}

类型转换¶

当前实现是将所有字段当作字符串处理

限制¶

当前插件仅支持 2.0 及以上版本