DataWorks で ADB for PostgreSQL ノードを使用すると、AnalyticDB for PostgreSQL のタスクを開発・スケジュール実行でき、他の処理と統合することも可能です。
DataWorks は、Alibaba Cloud AnalyticDB for PostgreSQL に対して SQL タスクを実行するための AnalyticDB for PostgreSQL ノードを提供します。これらのノードを使用して、SQL コードを記述し、定期実行をスケジュールし、AnalyticDB for PostgreSQL タスクをワークフロー内の他のノードタイプと統合できます。AnalyticDB for PostgreSQL の詳細については、「AnalyticDB for PostgreSQL」をご参照ください。
前提条件
開始する前に、以下の条件を満たしていることを確認してください。
作成済みの AnalyticDB for PostgreSQL ノード
SQL コードの作成
コードエディタで、AnalyticDB for PostgreSQL の SQL 構文に従って SQL ステートメントを作成します。
スケジューリング変数の使用
動的な値を実行時に渡すには、SQL コード内で ${変数名} 形式で変数を定義します。ノードが実行されるとき、DataWorks は各変数を、[スケジュール設定パラメーター] セクションで設定された値に置き換えます（このセクションは、[プロパティ] タブ上にあります）。このアプローチは、スケジュール実行ごとに値が変化する場合に使用します — たとえば、日付パーティション、テーブル名、またはフィルター条件などです。
右側のナビゲーションウィンドウで、[プロパティ] タブの [スケジューリングパラメーター] セクションでスケジューリングパラメーターの値を設定します。
次の例では、動的カラム名として ${var} を使用してテーブルを作成し、行を挿入しています。
CREATE TABLE employees (
id INT PRIMARY KEY,
name VARCHAR(100),
age INT,
department VARCHAR(50)
);
INSERT INTO employees (id, name, age, ${var}) VALUES
(1, 'Alice', 30, 'HR'),
(2, 'Bob', 25, 'Engineering'),
(3, 'Charlie', 35, 'Marketing');この例では、[スケジューリングパラメータ] セクションで、
${var}をdepartmentに設定します。
タスクの実行
[デバッグ設定] タブで、以下のパラメーターを設定します。
パラメーター 説明 コンピューティングリソース DataWorks に登録済みの AnalyticDB for PostgreSQL のコンピューティングリソースを選択します。 リソースグループ コンピューティングリソースに接続されているリソースグループを選択します。ネットワーク接続要件については、「ネットワーク接続ソリューション」をご参照ください。 コードエディタの上部で、[Select DataSource] をクリックし、AnalyticDB for PostgreSQL コンピューティングリソースを選択します。
ツールバーで[実行] をクリックして、タスクを実行します。
スケジュール設定、デプロイメント、モニタリング
タスクがエディタ上で正常に実行された後、本番環境向けにノードを設定します。
スケジューリングの設定: [プロパティ] タブで、スケジューリングの頻度およびその他のパラメーターを要件に応じて設定します。
ノードのデプロイ: 構成が完了したら、ノードをデプロイしてアクティブ化します。詳細については、「ノードのデプロイ」をご参照ください。
実行の監視: デプロイ後、オペレーションセンターでノードの実行ステータスと履歴を追跡します。詳細については、「オペレーションセンターの使用開始」をご参照ください。