⭐️
TDengine
TDengine 源端连接器
描述
通过 TDengine 读取外部数据源的数据。
主要特性
支持查询 SQL，并可实现投影效果。
配置项
| 名称 | 类型 | 必填 | 默认值 |
|---|---|---|---|
| url | string | 是 | - |
| username | string | 是 | - |
| password | string | 是 | - |
| database | string | 是 | |
| stable | string | 是 | - |
| sub_tables | list | 否 | - |
| lower_bound | long | 是 | - |
| upper_bound | long | 是 | - |
| read_columns | list | 否 | - |
url [string]
选择 TDengine 时的连接 URL
例如：
jdbc:TAOS-RS://localhost:6041/
username [string]
选择 TDengine 时的用户名
password [string]
选择 TDengine 时的密码
database [string]
选择 TDengine 时的数据库名
stable [string]
选择 TDengine 时的超级表名
sub_tables [list]
TDengine 的子表名。如果不指定，则会选择所有子表；如果指定，则只选择指定的子表。
lower_bound [long]
迁移时间段的下界
upper_bound [long]
迁移时间段的上界
read_columns [list]
选择 TDengine 时的列名。如果不指定，则选择所有字段；如果指定，则只选择指定的字段。读取超级表时，请包含TAGS 字段，并放在末尾。
示例
source 配置示例
source {
TDengine {
url : "jdbc:TAOS-RS://localhost:6041/"
username : "root"
password : "taosdata"
database : "power"
stable : "meters"
sub_tables : ["meter_1","meter_2"]
lower_bound : "2018-10-03 14:38:05.000"
upper_bound : "2018-10-03 14:38:16.800"
plugin_output = "tdengine_result"
read_columns : ["ts","voltage","current","power"]
}
}
变更日志
Change Log
| Change | Commit | Version |
|---|---|---|
| [Feature][Connector-V2] Support multi-table sink feature for TDengine (#9215) | https://github.com/apache/seatunnel/commit/98b593f095 | 2.3.11 |
| [Feature][Checkpoint] Add check script for source/sink state class serialVersionUID missing (#9118) | https://github.com/apache/seatunnel/commit/4f5adeb1c7 | 2.3.11 |
| [Fix][Connector-V2] Fix NullPointerException when column or tag contains null value in TDengine sink (#9158) | https://github.com/apache/seatunnel/commit/a047cab546 | 2.3.11 |
| [Fix][Connector][TDEngine] TDEngine support NCHAR type (#8411) | https://github.com/apache/seatunnel/commit/88c92ae1b1 | 2.3.9 |
| [Improve][dist]add shade check rule (#8136) | https://github.com/apache/seatunnel/commit/51ef800016 | 2.3.9 |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03c | 2.3.9 |
| [Improve][Connector-V2] Close all ResultSet after used (#7389) | https://github.com/apache/seatunnel/commit/853e973212 | 2.3.8 |
| [Fix][Connector-tdengine] Fix sql exception and concurrentmodifyexception when connect to taos and read data | https://github.com/apache/seatunnel/commit/a18fca8006 | 2.3.7 |
| [Bugfix][TDengine] Fix the issue of losing the driver due to multiple calls to the submit job REST API #6581 (#6596) | https://github.com/apache/seatunnel/commit/470bb97434 | 2.3.5 |
| [improve][connector-tdengine] support read bool column from tdengine (#6025) | https://github.com/apache/seatunnel/commit/af39235ee3 | 2.3.4 |
| [Bugfix][TDengine] Fix the degree of multiple parallelism affects driver loading (#6020) | https://github.com/apache/seatunnel/commit/b6ebbd47b2 | 2.3.4 |
| [Improve][Common] Introduce new error define rule (#5793) | https://github.com/apache/seatunnel/commit/9d1b2582b2 | 2.3.4 |
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755) | https://github.com/apache/seatunnel/commit/8de7408100 | 2.3.4 |
| [Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260) | https://github.com/apache/seatunnel/commit/51c0d709ba | 2.3.4 |
| [Hotfix][Connector] Fixed TDengine connector using jdbc driver to cause loading error (#4598) | https://github.com/apache/seatunnel/commit/78f7989b81 | 2.3.2 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd601051 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab166561 | 2.3.1 |
| [Feature][Connector-V2] add tdengine source (#2832) | https://github.com/apache/seatunnel/commit/acf4d5b1b4 | 2.3.1 |