tencent cloud

Tencent Cloud WeData

TDengineデータソース

ダウンロード
フォーカスモード
フォントサイズ
最終更新日: 2026-10-29 16:00:28
AI翻訳

利用制限

TAOS-RS接続方式のみをサポートしています。
3.1.1.0、3.1.1.35バージョンをサポートします。
1つのsuper_tableに過剰なchild_tableとtagを作成することは推奨されません。同期速度に著しく影響するためです。

TDengineオフライン単一テーブル読み取りノードの設定


パラメータ
説明
データソース
現在のプロジェクトで利用可能なTDengineデータソースを選択します。
データベース
選択、または手動で読み取り先のライブラリ名を入力できます。
デフォルトでは、データソースにバインドされているデータベースがデフォルトデータベースとして使用されます。その他のデータベースは、データベース名を手動で入力する必要があります。
データソースのネットワークが不通でライブラリ情報を直接取得できない場合は、データベース名を手動で入力できます。Data Integrationのネットワークが接続されている場合は、引き続きデータ同期を実行できます。
テーブルタイプ
通常テーブルまたはスーパーテーブルを選択できます。
テーブル名
通常テーブルまたはスーパーテーブルのテーブル名を選択または入力できます。
サブテーブル
テーブルタイプでスーパーテーブルを選択した場合にこの項目が表示され、1つまたは複数のサブテーブルを選択できます。
説明:
この項目が空の場合、すべてのサブテーブルを選択することを意味します。
複数のサブテーブルを選択した場合、ソース側はデフォルトで最初のテーブルのフィールド情報を自動的に取得します。
フィルタ条件
データ型に応じて対応するフィルタリングステートメントを入力します。このステートメントは、同期対象データのフィルタリング条件として使用されます。

TDengineオフライン単一テーブル書き込みノードの設定




パラメータ
説明
データの転送先
現在のプロジェクトで利用可能なTDengineデータソースを選択します。
データベース
選択、または手動で読み取り先のライブラリ名を入力できます。
デフォルトでは、データソースにバインドされているデータベースがデフォルトデータベースとして使用されます。その他のデータベースは、データベース名を手動で入力する必要があります。
データソースのネットワークが不通でライブラリ情報を直接取得できない場合は、データベース名を手動で入力できます。Data Integrationのネットワークが接続されている場合は、引き続きデータ同期を実行できます。
テーブルタイプ
通常テーブルまたはスーパーテーブルを選択できます。
テーブル名
通常テーブルまたはスーパーテーブルのテーブル名を選択または入力できます。
サブテーブル
テーブルタイプでスーパーテーブルを選択した場合にこの項目が表示され、サブテーブルを1つ選択できます。
バッチコミットサイズ
一度にバッチ送信されるレコード数です。この値により、データ同期システムとRedis間のネットワーク通信回数を大幅に削減し、全体のスループットを向上させることができます。この値が大きすぎる場合、データ同期プロセスでOOM例外が発生する可能性があります。

データ型変換のサポート

読み取り

TDengine データ型
内部型
TINYINT、SMALLINT、INTEGER、BIGINT
LONG
FLOAT、DOUBLE
DOUBLE
TIMESTAMP
DATE
BOOLEAN
BOOL
BINARY、VARBINARY、VARCHAR
BYTES
NCHAR、OTHER
STRING

書き込み

内部型
TDengine データ型
LONG
TIMESTAMP、TINYINT、SMALLINT、INT、BIGINT
DOUBLE
FLOAT、DOUBLE
STRING
TIMESTAMP、BINARY、NCHAR
BOOL
BOOL
DATE
TIMESTAMP
BYTES
BINARY

TDengineスクリプトデモ

オフラインタスクを構成する際に、スクリプトモードで構成する場合、タスクスクリプト内で、スクリプトの統一フォーマット要件に従って、スクリプト内のreaderパラメータとwriterパラメータを記述する必要があります。
{
"job": {
"content": [
{
"reader": {
"name": "tdenginereader",
"parameter": {
"username": "root", // 必須、ユーザー名
"password": "******", //必須、パスワード
"connection": [
{
"table": [ // 必須、ソーステーブル集合
"source_table"
],
"jdbcUrl": [
"jdbc:TAOS-RS://ip:port/test?timestampFormat=TIMESTAMP"
]
}
],
"column": [ //列名
"ts",
"current"
],
"where": "ts>=0", //フィルタ条件
"beginDateTime": "2017-07-14 10:40:00", //データの開始時間。JobはbegineDateTimeからendDateTimeまでのデータを移行します。形式はyyyy-MM-dd HH:mm:ssです。
"endDateTime": "2017-08-14 10:40:00" //データの終了時間。JobはbegineDateTimeからendDateTimeまでのデータを移行します。形式はyyyy-MM-dd HH:mm:ssです。
}
},
"writer": {
"name": "tdenginewriter",
"parameter": {
"username": "root", // 必須、ユーザー名
"password": "******", //必須、パスワード
"column": [ //列名
"tbname",
"time"
],
"connection": [
{
"table": [ // 必須、ターゲットテーブル集合
"target_table"
],
"jdbcUrl": "jdbc:TAOS-RS://ip:port/test"
}
],
"batchSize": 100, //バッチ送信サイズ
"ignoreTagsUnmatched": true //tableがTDengine内の1つの子テーブルである場合、tableはtag値を持ちます。データのtag値がtableのtag値と等しくない場合、データはtableに書き込まれません。
}
}
}
],
"setting": {
"errorLimit":{
"record": 0 //ダーティデータしきい値
},
"speed": {
"channel": 1, //同時実行数
"byte": -1 //同期速度を制限しません。正の整数は最大転送速度をbyte/sで設定することを示します。
}
}
}
}


ヘルプとサポート

この記事はお役に立ちましたか?

フィードバック