DataWorks では、AnalyticDB for PostgreSQL ノードを使用して、AnalyticDB for PostgreSQL タスクを開発し、定期的にスケジュールを設定し、AnalyticDB for PostgreSQL タスクを他のタイプのタスクと統合できます。このトピックでは、AnalyticDB for PostgreSQL ノードを使用してタスクを開発する方法について説明します。
前提条件
ワークフローが作成されていること。
DataStudio では、ワークフローに基づいてさまざまなタイプの計算エンジンの開発操作を実行できます。そのため、ノードを作成する前にワークフローを作成する必要があります。詳細については、「ワークフローを作成する」をご参照ください。
サーバーレスリソースグループ(推奨)または スケジューリング専用の排他的リソースグループ が購入されていること。
背景情報
AnalyticDB for PostgreSQL nodes are used to connect to AnalyticDB for PostgreSQL of Alibaba Cloud. For more information, see AnalyticDB for PostgreSQL.
ステップ 1: AnalyticDB for PostgreSQL ノードを作成する
DataStudio ページに移動します。
DataWorks コンソール にログインします。上部のナビゲーションバーで、目的のリージョンを選択します。左側のナビゲーションウィンドウで、 を選択します。表示されたページで、ドロップダウンリストから目的のワークスペースを選択し、[データ開発に移動] をクリックします。
[スケジュールされたワークフロー] ウィンドウで、目的のワークフローを右クリックし、 を選択します。
[ノードの作成] ダイアログボックスで、[名前] フィールドにノード名を入力し、[確認] をクリックします。ノードが作成されます。ノードに基づいてタスクを開発および構成できます。
ステップ 2:ノードに基づいて AnalyticDB for PostgreSQL タスクを開発する
(オプション)AnalyticDB for PostgreSQL 計算リソースを選択する
ワークスペースに複数の AnalyticDB for PostgreSQL 計算リソースがある場合は、AnalyticDB for PostgreSQL ノードの構成タブで適切なリソースを選択します。追加されている AnalyticDB for PostgreSQL 計算リソースが 1 つだけの場合は、そのリソースがデフォルトで開発に使用されます。
SQL コードを開発する
AnalyticDB for PostgreSQL ノードのコードエディターで、AnalyticDB for PostgreSQL でサポートされている構文に基づいて SQL 文を記述します。
ステップ 3:AnalyticDB for PostgreSQL タスクのスケジューリングプロパティを構成する
作成したノードで AnalyticDB for PostgreSQL タスクを定期的に実行する場合は、ノードの構成タブの右側のナビゲーションウィンドウで [プロパティ] をクリックし、ビジネス要件に基づいてタスクのスケジューリングプロパティを構成します。詳細については、「概要」をご参照ください。
タスクをコミットする前に、[プロパティ] タブで [再実行] パラメーターと [親ノード] パラメーターを構成する必要があります。
ステップ 4:タスクコードをデバッグする
次のデバッグ操作を実行して、ビジネス要件に基づいてタスクが想定どおりに構成されているかどうかを確認できます。
オプション。リソースグループを選択し、カスタムパラメーターを変数に割り当てます。
ノードの構成タブの上部ツールバーにある
アイコンをクリックします。[パラメーター] ダイアログボックスで、タスクコードのデバッグと実行に使用するスケジューリング用のリソースグループを選択します。タスクコードでスケジューリングパラメーターを使用する場合は、デバッグのために、スケジューリングパラメーターを変数に値として割り当てることができます。スケジューリングパラメーターの値割り当てロジックについては、「デバッグ手順」をご参照ください。
SQL 文を保存して実行します。
上部ツールバーの
アイコンをクリックして SQL 文を保存します。次に、
アイコンをクリックして SQL 文を実行します。オプション。スモークテストを実行します。
タスクをコミットするとき、またはタスクをコミットした後に、開発環境でタスクのスモークテストを実行できます。詳細については、「スモークテストを実行する」をご参照ください。
ステップ 5:タスクをコミットしてデプロイする
ノードでタスクを構成した後、タスクをコミットしてデプロイする必要があります。タスクをコミットしてデプロイした後、スケジューリング構成に基づいてタスクを定期的に実行できます。
上部ツールバーの
アイコンをクリックして、タスクを保存します。上部ツールバーの
アイコンをクリックして、タスクをコミットします。[送信] ダイアログボックスで、[変更の説明] パラメーターを構成します。次に、ビジネス要件に基づいて、タスクのコミット後にタスクコードを確認するかどうかを決定します。
説明[再実行] パラメーターと [親ノード] パラメーターを構成した後でのみ、タスクをコミットできます。
コードレビュー機能を使用して、タスクのコード品質を確保し、無効なタスクコードによって発生するタスク実行エラーを防ぐことができます。コードレビュー機能を有効にすると、コミットされたタスクコードは、コードレビューに合格した後でのみデプロイできます。詳細については、「コードレビュー」をご参照ください。
標準モードのワークスペースを使用する場合は、タスクをコミットした後に、本番環境にタスクをデプロイする必要があります。ノードにタスクをデプロイするには、ノードの構成タブの右上隅にある [デプロイ] をクリックします。詳細については、「ノードをデプロイする」をご参照ください。
次のステップ
タスクをコミットしてデプロイすると、スケジューリング構成に基づいてタスクが定期的に実行されます。ノードの構成タブの右上隅にある [オペレーションセンター] をクリックしてオペレーションセンターに移動し、タスクのスケジューリングステータスを表示できます。詳細については、「自動トリガーノードの表示と管理」をご参照ください。