DataWorks は、AnalyticDB for PostgreSQL タスクを開発して定期的にスケジュールし、タスクを他のタイプのタスクと統合するために使用できる AnalyticDB for PostgreSQL ノードを提供します。このトピックでは、AnalyticDB for PostgreSQL ノードを使用してタスクを開発する方法について説明します。
前提条件
AnalyticDB for PostgreSQL ノードが作成されていること。
背景情報
AnalyticDB for PostgreSQL ノードは、Alibaba Cloud AnalyticDB for PostgreSQL に接続するために使用されます。詳細については、「AnalyticDB for PostgreSQL」をご参照ください。
手順
AnalyticDB for PostgreSQL ノードの構成タブで、次の操作を実行してタスクを開発します。
SQL コードを開発する
コードエディターで、タスクコードを開発します。タスクコードでは ${変数名} 形式で変数を定義し、ノード構成タブの右側ナビゲーションウィンドウにある [プロパティ] タブの [スケジューリングパラメーター] セクションでスケジューリングパラメーターを構成して、スケジューリングパラメーターを変数に値として割り当てることができます。 これにより、ノードが実行されるようにスケジュールされると、ノードコード内のスケジューリングパラメーターの値が動的に置き換えられます。サンプルコード:
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フィールドに設定できます。AnalyticDB for PostgreSQL ノードのコードエディターで、AnalyticDB for PostgreSQL でサポートされている構文に基づいて SQL 文を記述します。詳細については、「SQL 構文」をご参照ください。
タスクを実行する
[デバッグ構成] タブで、[計算リソース] パラメーターと [リソースグループ] パラメーターを構成します。
計算リソースドロップダウンリストから、DataWorks に登録した AnalyticDB for PostgreSQL 計算リソースの名前を選択します。
リソースグループドロップダウンリストから、計算リソースに接続されているスケジューリング用のリソースグループを選択します。詳細については、「ネットワーク接続ソリューション」をご参照ください。
コードエディターの上部にある [データソースの選択] ドロップダウンリストをクリックします。ポップアップで、作成した AnalyticDB for PostgreSQL 計算リソースを選択し、上部ツールバーの [実行] をクリックします。
ノードを定期的に実行する場合は、ビジネス要件に基づいてスケジューリング情報を構成します。
ノードを構成した後、ノードをデプロイします。詳細については、「ノードのデプロイ」をご参照ください。
ノードをデプロイした後、オペレーションセンターでノードの実行ステータスを表示します。詳細については、「オペレーションセンターの概要」をご参照ください。