InfluxDB is an open-source time series database developed by InfluxData. InfluxDB is written in Go and is designed for querying and storing time series data with high performance. InfluxDB Reader allows you to read data from InfluxDB.

Currently, you can only configure InfluxDB Reader by using the code editor. For more information, see InfluxDB.

How it works

InfluxDB Reader connects to an InfluxDB instance through the Java client, sends an SQL statement to the instance, and obtains data points through the scan operations. A sync node is split to multiple export tasks based on the database, metric, and time range.

Limits

  • The specified start time and end time are automatically converted to on-the-hour time. For example, if you set the time range to [3:35, 4:55) on April 18, 2019, the time range is converted to [3:00, 4:00).
  • Currently, only InfluxDB 0.9 and later are supported.

Data types

Category Data Integration data type InfluxDB data type
String String String to which a data point in InfluxDB is serialized, including the timestamp, metric, tags, and value

Parameters

Parameter Description Required Default value
endpoint The HTTP endpoint for connecting to InfluxDB, in the format of http://IP:Port. Yes None
database The name of the InfluxDB database. Yes None
username The username for connecting to the InfluxDB database. Yes None
password The password for connecting to the InfluxDB database. Yes None
column The metrics to be migrated. Yes None
beginDateTime The start time of the time range of the data points to be migrated, in the format of yyyyMMddHHmmss. Specify the beginDateTime and endDateTime parameters to determine the time range of the data points to be migrated. Yes None
Note The start time and end time of the time range are automatically converted to on-the-hour time. For example, if you set the time range to [3:35, 4:55) on April 18, 2019, the time range is converted to [3:00, 4:00).
endDateTime The end time of the time range of the data points to be migrated, in the format of yyyyMMddHHmmss. Specify the beginDateTime and endDateTime parameters to determine the time range of the data points to be migrated. Yes None
Note The start time and end time of the time range are automatically converted to on-the-hour time. For example, if you set the time range to [3:35, 4:55) on April 18, 2019, the time range is converted to [3:00, 4:00).

Configure InfluxDB Reader by using the codeless UI

Currently, the codeless user interface (UI) is not supported for InfluxDB Reader.

Configure InfluxDB Reader by using the code editor

In the following code, a node is configured to read data from an InfluxDB database.

```json
{
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "concurrent": 1,
            "throttle": true
        }
    },
    "steps": [
        {
            "category": "reader",
            "name": "Reader",
            "parameter": {
                "endpoint": "http://host:8086",
                "database": "",
                "username": "",
                "password": "",
                "column": [
                    "xc"
                ],
                "endDateTime": "20190515180000",
                "beginDateTime": "20190515170000"
            },
            "stepType": "influxdb"
        },
        {
            "category": "writer",
            "name": "Writer",
            "parameter": {},
            "stepType": ""
        }
    ],
    "type": "job",
    "version": "2.0"
}
```