DataHub:Hologres 同期タスクの作成

事前準備

同期タスクの作成

1. DataHub で、Topic をクリックして詳細ページを開きます。

2. Topic 詳細ページの右上隅にある アイコンをクリックします。

3. 新規コネクタページで、Hologres をクリックします。新規コネクタダイアログボックスでパラメーターを設定し、[作成] をクリックします。

4. Hologres では、パーティションテーブルへの同期がサポートされています。Hologres でパーティションテーブルを作成した後、同期タスクは自動的にパーティションフィールドに基づいてデータを同期します。

   

   パラメーターの説明：

   パラメーター	説明	備考
   インスタンス	Hologres インスタンスの ID。	Hologres コンソール に移動し、左側のナビゲーションウィンドウで インスタンス一覧 をクリックして、インスタンス ID を確認します。
   データベース	Hologres データベースの名前。	該当なし
   テーブル	データを受信する Hologres テーブルの名前。	該当なし
   プライマリキー同期ポリシー	Hologres テーブルにプライマリキーが設定されている場合の、DataHub からのデータ同期ポリシー。	置き換え：書き込み操作時にプライマリキーの競合が発生した場合、新規データが既存データを上書きします。 無視：書き込み操作時にプライマリキーの競合が発生した場合、新規データは無視され、既存データが保持されます。
   同期シナリオ	DataHub から Hologres へのデータ同期モード。	デフォルト：DataHub のデータを 1 Record ずつ Hologres に書き込みます。 dts_old：追加カラムに関する新規ルールを無効化します。 dts：追加カラムに関する新規ルールを有効化します。
   インポートフィールド	Hologres にインポートするフィールド。	必要に応じて、一部またはすべてのフィールドをインポートできます。
   認証モード	デフォルト値は AK です。	該当なし
   AccessId	Hologres インスタンスにアクセスするための AccessKey ID。	AccessKey 管理 をクリックして、AccessKey ID を取得します。
   AccessKey	Hologres インスタンスにアクセスするための AccessKey Secret。	AccessKey 管理 をクリックして、AccessKey Secret を取得します。
   開始時刻	データ同期を開始する最も早い時刻。	該当なし
   TimestampUnit	同期時の時間単位。	データに TIMESTAMP 型のフィールドが含まれる場合、その値は指定された TimestampUnit に基づいて変換され、その後、下流システムの日付型フィールドに書き込まれます。

   説明

   • dts および dts_old の同期モードは、Data Transfer Service (DTS) から DataHub へデータが書き込まれ、その後 Hologres へ同期されるシナリオ向けです。

   • 追加カラムに関するルールの詳細については、「DataHub からのデータインポート」をご参照ください。

5. DataHub から Hologres へのデータ同期を実行します。

   コネクタが作成された後、Topic 詳細ページの 同期タスク タブで、リアルタイムのデータ同期ステータスを確認できます。

6. Hologres でのデータクエリを実行します。

   Hologres インスタンスを開発者ツールに接続し、同期されたデータをリアルタイムでクエリします。詳細については、「Hologres インスタンスへの接続」をご参照ください。以下に検索文のサンプルを示します。

   SELECT COUNT(*) FROM lineitem;

付録 1：よくある質問

 ErrorCode=NoPermission; ErrorMessage=Rejected by IP whitelist