跳到主要内容
版本：Next

TDengine

TDengine 源端连接器

描述​

从 TDengine 超级表读取数据。

该 Source 以批处理方式按时间范围读取一个超级表的数据。可以读取该超级表下的所有子表，也可以只读取指定子表；同时支持只读取部分列。

每个 source 分片会读取一个 TDengine 子表。输出字段会自动把 subtable_name 放在第一列，用来保留原始子表名；如果下游继续写入 TDengine，TDengine sink 也会使用这一列作为目标子表名。

主要特性​

配置项​

名称类型必填默认值
urlstring是-
usernamestring是-
passwordstring是-
databasestring是-
stablestring是-
sub_tableslist否-
lower_boundstring是-
upper_boundstring是-
read_columnslist否-

url [string]​

TDengine REST JDBC 连接地址。

例如：

jdbc:TAOS-RS://localhost:6041/

username [string]​

连接 TDengine 使用的用户名。

password [string]​

连接 TDengine 使用的密码。

database [string]​

TDengine 数据库名称。

stable [string]​

TDengine 超级表名称。

sub_tables [list]​

TDengine 子表名称列表。不配置时读取该超级表下的所有子表；配置后只读取指定子表。

lower_bound [string]​

查询时间范围的下界，包含该时间点。连接器会为每个子表查询加上 timestamp_column >= lower_bound 条件。请使用 TDengine 可识别的时间字符串，例如 2018-10-03 14:38:05.000。

upper_bound [string]​

查询时间范围的上界，不包含该时间点。连接器会为每个子表查询加上 timestamp_column < upper_bound 条件。请使用 TDengine 可识别的时间字符串，例如 2018-10-03 14:38:16.801。

read_columns [list]​

要读取的列名列表。不配置时读取所有列。读取超级表时，请将 TAGS 字段放在列表末尾。不要在这里配置 subtable_name，连接器会自动把它作为第一列输出。

read_columns 的顺序会决定 subtable_name 之后的输出字段顺序。如果后续继续写入 TDengine Sink，请保持普通列在前、TAGS 字段在后，这样 Sink 才能正确区分普通列和 TAGS 值。

示例​

按时间范围读取所有子表​

env {
  parallelism = 2
  job.mode = "BATCH"
}

source {
  TDengine {
    url = "jdbc:TAOS-RS://localhost:6041/"
    username = "root"
    password = "taosdata"
    database = "power"
    stable = "meters"
    lower_bound = "2018-10-03 14:38:05.000"
    upper_bound = "2018-10-03 14:38:16.801"
    plugin_output = "tdengine_result"
  }
}

从 TDengine 读取并写入 TDengine​

env {
  parallelism = 2
  job.mode = "BATCH"
}

source {
  TDengine {
    url = "jdbc:TAOS-RS://tdengine-src:6041/"
    username = "root"
    password = "taosdata"
    database = "power"
    stable = "meters"
    lower_bound = "2018-10-03 14:38:05.000"
    upper_bound = "2018-10-03 14:38:16.801"
    plugin_output = "tdengine_result"
  }
}

sink {
  TDengine {
    url = "jdbc:TAOS-RS://tdengine-sink:6041/"
    username = "root"
    password = "taosdata"
    database = "power2"
    stable = "meters2"
    timezone = "UTC"
  }
}

读取指定子表和指定列​

source {
  TDengine {
    url = "jdbc:TAOS-RS://localhost:6041/"
    username = "root"
    password = "taosdata"
    database = "power"
    stable = "meters"
    lower_bound = "2018-10-03 14:38:05.000"
    upper_bound = "2018-10-03 14:38:16.801"
    sub_tables = ["d1001", "d1002"]
    read_columns = ["ts", "current", "voltage", "phase", "off", "nc", "location", "groupid"]
  }
}

变更日志​