AnalyticDB:DataWorks Data Integration

ユースケース

• Data Integration の同期タスクを使用して、AnalyticDB for PostgreSQL から他のデータソースにデータをエクスポートし、後続の処理を行います。このプロセスをデータエクスポートと呼びます。

• Data Integration の同期タスクを使用して、他のデータソースから処理済みデータをAnalyticDB for PostgreSQL にインポートします。このプロセスをデータインポートと呼びます。

同期タスクの作成方法、データソースとジョブの構成方法、ホワイトリストの設定方法などの詳細な手順については、DataWorks ドキュメントの Data Integration セクションをご参照ください。このトピックでは、AnalyticDB for PostgreSQL を使用したデータインポートおよびデータエクスポートの手順を説明します。

前提条件

Data Integration タスクの準備：

1. DataWorks サービスを有効化します。

2. MaxCompute を有効化します。デフォルトの MaxCompute データソースが自動的に作成されます。次に、Alibaba Cloud アカウントを使用してDataWorks にログオンします。

3. ワークスペースを作成します。DataWorks でワークフローの共同作業を行い、データとタスクを管理するには、ワークスペースが必要です。

AnalyticDB for PostgreSQL の準備：

1. データをインポートする前に、PostgreSQL クライアントを使用して、AnalyticDB for PostgreSQL に宛先のデータベースとテーブルを作成します。

2. データをエクスポートする前に、AnalyticDB for PostgreSQL コンソールにサインインし、ホワイトリストの設定 で IP アドレスを構成します。詳細については、「ホワイトリストの追加」をご参照ください。

データインポート

DataWorks コンソールでソースのデータソースを追加します。詳細な手順については、「AnalyticDB for PostgreSQL データソースの構成」をご参照ください。

同期タスクを構成します：

データソースを構成した後、同期タスクを構成してAnalyticDB for PostgreSQL にデータをインポートします。同期タスクは、[ウィザードモード]と[コードエディタ]の 2 つのモードで構成できます。

• ウィザードモード：次の手順に従って同期タスクを構成します。

  1. データ同期ノードを作成します。

  2. データソースを選択します。

  3. データの宛先を選択します。宛先はAnalyticDB for PostgreSQL である必要があります。

  4. ソースフィールドを宛先フィールドにマッピングします。

  5. 最大転送レートと、ダーティデータの処理ルールを構成します。

  6. スケジューリング属性を構成します。

  説明

  詳細な手順については、DataWorks ドキュメントの「ウィザードを使用した同期タスクの構成」をご参照ください。

• スクリプトモード：次の手順に従って同期タスクを構成します。

  1. データ同期ノードを作成します。

  2. テンプレートをインポートします。

  3. 同期タスクのリーダーを構成します。

  4. 同期タスクのライターを構成します。ライターはAnalyticDB for PostgreSQL である必要があります。

  5. ソースフィールドを宛先フィールドにマッピングします。

  6. 最大転送レートと、ダーティデータの処理ルールを構成します。

  7. スケジューリング属性を構成します。

  説明

  詳細な手順については、DataWorks ドキュメントの「スクリプトエディターを使用した同期タスクの構成」をご参照ください。

データエクスポート

データのエクスポート手順は、データのインポート手順と同様です。データエクスポートの場合は、AnalyticDB for PostgreSQL をデータソースとして構成し (「AnalyticDB for PostgreSQL データソースの構成」を参照)、別のデータソースタイプを宛先として構成します。

関連ドキュメント

Data Integration の詳細については、DataWorks ドキュメントをご参照ください。