InfluxDB is an open source time series database that is developed in Go by InfluxData. InfluxDB is designed to query and store time series data with high performance. InfluxDB Reader allows you to read data from InfluxDB.

Notice

How it works

InfluxDB Reader connects to an InfluxDB instance by using a Java client, sends an SQL statement to the instance, and then obtains data points by performing scan operations. A sync node is split into 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).
  • 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 of InfluxDB, in the format of http://IP address:Port. Yes N/A
database The name of the InfluxDB database. Yes N/A
username The username that you can use to connect to the InfluxDB database. Yes N/A
password The password that you can use to connect to the InfluxDB database. Yes N/A
column The metrics to be synchronized. Yes N/A
beginDateTime The start time of the time range of the data points to be synchronized, in the format of yyyyMMddHHmmss. Specify the beginDateTime and endDateTime parameters to determine the time range of the data points to be synchronized. Yes N/A
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 synchronized, in the format of yyyyMMddHHmmss. Specify the beginDateTime and endDateTime parameters to determine the time range of the data points to be synchronized. Yes N/A
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

The codeless user interface (UI) is not supported for InfluxDB Reader.

Configure InfluxDB Reader by using the code editor

The following example shows how to configure a sync node to read data from an InfluxDB database in the code editor. For more information, see Create a sync node by using the code editor.
{
    "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"
}