ルートモジュールは、ソーステーブルを結果テーブルにマッピングするルールを定義します。この Topic では、ルーティングルールを定義するための構文について説明します。
パラメーター
パラメーター | 説明 | 必須 | 備考 |
| ソーステーブルを指定します。 | 必須 | 正規表現をサポートします。 |
| 結果テーブルを指定します。 | 必須 | |
| 結果テーブル名の中で、ソーステーブル名に置き換えられる文字列を指定します。 | オプション | たとえば、 |
| ルーティングルールの説明。 | オプション |
新しいルールを適用するには、ルートモジュールを変更した後にステートレススタートアップを実行します。
例
ソーステーブルから結果テーブルへのデータ同期
ソーステーブル mysql_db.web_order から結果テーブル sink_db.ods_web_order にデータをルーティングします。
route:
- source-table: mysql_db.web_order
sink-table: sink_db.ods_web_order
description: ソーステーブルから結果テーブルへのデータ同期ソーステーブルから複数の結果テーブルへのデータ同期
ソーステーブルから複数の結果テーブルにデータをコピーするには、複数のルーティングルールを定義します。次のコードは、mydb.orders から sink_db.orders と backup_sink_db.orders に同時にデータをレプリケートします。
route:
- source-table: mydb.orders
sink-table: sink_db.orders
- source-table: mydb.orders
sink-table: backup_sink_db.orders複数のソーステーブルから複数の結果テーブルへのデータ同期
YAML リストインジケーターであるハイフン (-) を使用して複数のルールを定義します。これらのルールはすべて同時に適用されます。
route:
- source-table: mydb.orders
sink-table: ods_db.ods_orders
description: orders テーブルを ods_orders に同期
- source-table: mydb.shipments
sink-table: ods_db.ods_shipments
description: shipments テーブルを ods_shipments に同期
- source-table: mydb.products
sink-table: ods_db.ods_products
description: products テーブルを ods_products に同期複数のソーステーブルから 1 つの結果テーブルへのデータ同期
source_db データベースのすべてのテーブルをターゲットの sink_db.merged テーブルにマージします。
route:
- source-table: source_db.\.*
sink-table: sink_db.merged
description: 複数のソーステーブルから 1 つの結果テーブルへのデータ同期データベース同期
source_db データベースのすべてのテーブルを、テーブル名を変更せずに sink_db データベースの対応するテーブルに同期します。
route:
- source-table: source_db.\.*
sink-table: sink_db.<>
replace-symbol: <>
description: source_db 内のすべてのテーブルを sink_db にルーティング<> シンボルはソーステーブル名のプレースホルダーであり、ソーステーブルから結果テーブルへの 1 対 1 のマッピングを可能にします。