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

パラメータ | 説明 |
データの転送先 | 現在のプロジェクトで利用可能な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 |
{"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で設定することを示します。}}}}
フィードバック