実行中の同期ソリューションに対するソーステーブルの追加または削除 -

Hologres にデータを同期するために使用されるソリューションでは、ソリューションの実行中にソーステーブルを追加または削除できます。このトピックでは、実行中の同期ソリューションに対するソーステーブルの追加または削除方法について説明します。

前提条件

Hologres にデータを同期するために使用される同期ソリューションが作成され、実行されています。詳細については、「Hologres にデータを同期するためのリアルタイム同期ソリューションの作成」をご参照ください。

同期ソリューションへのソーステーブルの追加

[タスク] ページで、目的のソリューションを見つけ、[詳細] > [構成の変更] を選択して、ソリューション構成ページに移動します。

同期ソリューションにソーステーブルを追加し、ソーステーブルとデスティネーションテーブル間のマッピングを更新します。

ソーステーブル[同期ソースとルールの設定] ステップの ソーステーブル選択されたソーステーブル セクションで、リストから同期ソリューションに追加するソーステーブルを選択し、アイコンをクリックして、テーブルをリストに移動します。
[次のステップ] をクリックします。
ソーステーブルとhologresテーブルのマッピングを更新[デスティネーションテーブルの設定] ステップでをクリックして、ソーステーブルとデスティネーション Hologres テーブル間のマッピングを更新します。

マッピングの進捗状況、ソーステーブル、およびマッピングされたデスティネーションテーブルを表示します。

Progress of mapping the source tables to destination tables

番号	説明
1	ソーステーブルをデスティネーションテーブルにマッピングする進捗状況。説明多数のテーブルからデータを同期する場合、マッピングに時間がかかることがあります。

[次のステップ] をクリックします。

データ定義言語（DDL）メッセージを処理するためのルールを構成します。

MySQL などのソースには、DDL メッセージが含まれている場合があります。[DDL メッセージの処理ポリシーの設定] ステップで、ビジネス要件に基づいて、さまざまな DDL メッセージに対して構成された処理ルールを変更できます。

[リアルタイム同期の DDL メッセージの処理ポリシー] セクションのパラメータを構成します。 Processing rules for DDL messages

次の表に、さまざまな DDL メッセージの処理ルールを示します。

DDL メッセージ	ルール
CreateTable	DataWorks は、関連タイプの DDL メッセージを受信した後、次のルールに基づいてメッセージを処理します。標準: メッセージをデスティネーションに送信します。次に、デスティネーションがメッセージを処理します。各デスティネーションは、独自のビジネスロジックに基づいて DDL メッセージを処理できます。CreateTable に標準を選択した場合、DataWorks はメッセージを転送するだけです。無視: メッセージを無視し、デスティネーションに送信しません。アラート: メッセージを無視し、リアルタイム同期ログにアラートを記録します。さらに、アラートには、実行時エラーのためにメッセージが無視されたことを示す理由に関する情報が含まれています。エラー: リアルタイム同期ソリューションの実行時にエラーを返し、リアルタイム同期ソリューションを終了します。
DropTable
AddColumn
DropColumn
RenameTable
RenameColumn
ChangeColumn
TruncateTable

[次のステップ] をクリックします。

同期ソリューションに必要なリソースを構成します。

[ソリューション実行のリソースの設定] ステップで、必要に応じてパラメータを設定します。 Set Resources for Solution Running

オフライン同期

パラメータ	説明
オフラインタスク名ルール	ソースの全データを同期するために使用されるバッチ同期ノードの名前。同期ソリューションが作成されると、DataWorks は最初にバッチ同期ノードを生成して全データを同期し、次にリアルタイム同期ノードを生成して増分データを同期します。
フルバッチ同期ノードのリソースグループ	バッチ同期ノードを実行するために使用される Data Integration の専用リソースグループ。

スケジューリング設定

パラメータ

説明

スケジューリングリソースグループの選択

ノードを実行するために使用されるスケジューリングのリソースグループ。

同期ソリューションを実行するには、Data Integration の専用リソースグループのみを使用できます。このパラメータは、購入した Data Integration の専用リソースグループの名前に設定できます。詳細については、「リソースの計画と構成」をご参照ください。

説明専用リソースグループがない場合は、[新しい専用リソースグループの作成] をクリックして作成します。

増分同期
パラメータ 説明
増分バッチ同期ノードのリソースグループ
リアルタイム同期ノードを実行するために使用される専用リソースグループ。

チャネル設定

パラメータ	説明
ソース読み取りでサポートされる最大接続数	ソースで許可される Java Database Connectivity（JDBC）接続の最大数。ソースのリソースに基づいて適切な数を指定します。デフォルト値: 20。

[構成の完了] をクリックして、[タスク] ページに戻ります。
ソーステーブルを追加したソリューションを見つけ、その他 > 送信して実行[操作] 列で 送信して実行OK を選択します。メッセージで、をクリックしてソリューションを実行します。
ソーステーブルを追加したソリューションを送信して実行すると、システムは元のソリューションのソーステーブルと新しいソリューションのソーステーブルを比較します。新しいソーステーブルが検出されると、システムはソーステーブルを追加するプロセスを実行します。
説明特定の時点に同期ソリューションにソーステーブルを追加すると、システムはこの時点から新しく追加されたソーステーブルにデータのロードを開始します。データのロードが終了すると、システムはこれらのソーステーブルのデータをデスティネーションに同期し始めます。たとえば、同期ソリューションが 08:00 に実行を開始し、09:00 にもまだ実行されているとします。09:00 にソリューションにソーステーブルを追加します。その後、システムは 09:00 からテーブルへのデータのロードを開始し、ロードは 10:00 に終了します。この場合、システムは実行中のリアルタイム同期ノードを停止し、新しく追加されたソーステーブルで 09:00 から 10:00 に生成されたデータをデスティネーション Hologres テーブルに同期し始めます。実行中の同期ソリューションへのソーステーブルの追加は、同期前後のデータの一貫性のみを保証できます。
ソーステーブルの追加の詳細を表示します。
1. [タスク] ページで、ソーステーブルを追加した同期ソリューションを見つけ、実行の詳細[操作] 列のをクリックして、同期ソリューションの詳細ページに移動します。
2. [ステップ] セクションで、[追加または削除されたソーステーブルの表示] ノードを見つけ、[ステータス] 列の [実行の詳細] をクリックします。
  [追加または削除されたテーブルの表示] ノードの状態が [成功] の場合、同期ソリューションに新しいソーステーブルが追加されます。
3. 同期ソリューションに追加された新しいソーステーブルを表示します。

同期ソリューションからのソーステーブルの削除

[タスク] ページで、目的のソリューションを見つけ、[詳細] > [構成の変更] を選択して、ソリューション構成ページに移動します。

同期ソリューションからソーステーブルを削除し、残りのソーステーブルとデスティネーションテーブル間のマッピングを更新します。

ソーステーブル[同期ソースとルールの設定] ステップの 選択されたソーステーブルソーステーブル セクションで、リストから同期ソリューションから削除するソーステーブルを選択し、アイコンをクリックして、テーブルをリストに戻します。
[次のステップ] をクリックします。
ソーステーブルと Hologres テーブルのマッピングを更新[デスティネーションテーブルの設定] ステップでをクリックして、ソーステーブルとデスティネーション Hologres テーブル間のマッピングを更新します。