すべてのプロダクト
Search
ドキュメントセンター

DataWorks:PostgreSQL

最終更新日:Feb 26, 2026

DataWorks の PostgreSQL ノードを使用して、定期的な PostgreSQL タスクを開発およびスケジューリングし、他のタスクと統合できます。この Topic では、これらのタスクの開発方法について説明します。

背景情報

PostgreSQL は、強力で柔軟なオープンソースのリレーショナルデータベース管理システム (RDBMS) です。強力なデータモデル、安定性、高いスケーラビリティ、豊富なコア機能を特徴としています。詳細については、PostgreSQL をご参照ください。

前提条件

  • ビジネスフローを作成する。

    DataStudio はビジネスフローごとに開発を整理します。ノードを作成する前に、ビジネスフローを作成する必要があります。詳細については、「ワークフローの作成」をご参照ください。

  • PostgreSQL データソースを作成済みであること。

    ご利用の PostgreSQL データベース内のデータにアクセスする前に、そのデータベースを PostgreSQL データソースとして DataWorks に追加する必要があります。詳細については、「PostgreSQL データソース」をご参照ください。

    説明

    PostgreSQL ノードは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された PostgreSQL データソースのみをサポートします。

  • (オプション。RAM ユーザーの場合は必須) RAM ユーザーをワークスペースに追加し、[開発者] または [ワークスペース管理者] のロールを割り当てます。ワークスペース管理者のロールは権限が高いため、付与には注意してください。詳細については、「ワークスペースへのメンバーの追加」をご参照ください。

制限事項

サポート対象リージョン:中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、ドイツ (フランクフルト)、米国 (シリコンバレー)、および米国 (バージニア)。

ステップ 1:PostgreSQL ノードの作成

  1. DataStudio ページに移動します。

    DataWorks コンソールにログインします。上部のナビゲーションバーで、目的のリージョンを選択します。左側のナビゲーションウィンドウで、データ開発とO&M > データ開発 を選択します。表示されたページで、ドロップダウンリストから目的のワークスペースを選択し、データ開発へ をクリックします。

  2. 対象のビジネスフローを右クリックし、ノードの作成 > データベース > PostgreSQL を選択します。

  3. ノードの作成 ダイアログボックスで、ノードの 名前 を入力し、OK をクリックします。

ステップ 2:PostgreSQL タスクの開発

(任意) PostgreSQL データソースの選択

ご利用のワークスペースに複数の PostgreSQL データソースがある場合は、ノード設定タブで必要なデータソースを選択します。利用可能な PostgreSQL データソースが 1 つしかない場合は、それがデフォルトで使用されます。

説明

PostgreSQL ノードは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された PostgreSQL データソースのみをサポートします。

SQL コードの開発:簡単な例

PostgreSQL ノードのコードエディタでタスクコードを記述できます。次のサンプルコードは、PostgreSQL データベース内のすべてのベーステーブルに関する情報を照会します。

SELECT * FROM information_schema.tables
WHERE table_type = 'BASE TABLE';

SQL コードの開発:スケジューリングパラメーターの使用

DataWorks は、定期的なタスクのコードに動的な値を渡すために使用できる スケジューリングパラメーター を提供します。ノードタスクでは、${変数名} のフォーマットを使用して変数を定義できます。その後、右側のナビゲーションウィンドウの スケジュール タブにある スケジューリングパラメーター セクションで、変数に値を割り当てることができます。スケジューリングパラメーターでサポートされているフォーマットと設定の詳細については、「スケジューリングパラメーターでサポートされているフォーマット」および「スケジューリングパラメーターの設定と使用」をご参照ください。

例:データベース内のすべてのベーステーブルに関する情報を照会します。この例では、スケジューリングパラメーター a の値が BASE_TABLE に設定されています。image

コードは次のとおりです。

SELECT * FROM information_schema.tables
WHERE table_type = '${a}';

ステップ 3:タスクスケジューリングの設定

タスクをスケジューリングするには、右側の スケジューリング設定 をクリックしてプロパティを設定します。詳細については、「概要」をご参照ください。

説明

送信する前に、再実行プロパティ依存する上流ノード を設定してください。

ステップ 4:タスクコードのデバッグ

タスクをデバッグして、正しく実行されることを確認します。

  1. (任意) デバッグ用のリソースグループを選択し、パラメーター値を割り当てます。

    • ツールバーの 高级运行 アイコンをクリックします。パラメーター ダイアログボックスで、リソースグループを選択します。

    • デバッグ用にスケジューリングパラメーターに値を割り当てます。パラメーターの割り当てロジックの詳細については、「タスクのデバッグプロセス」をご参照ください。

  2. タスクコードを保存して実行します。

    保存 アイコンをクリックして保存し、运行 アイコンをクリックして実行します。

  3. (任意) スモークテストを実行します。

    送信中または送信後にスモークテストを実行して、開発環境での実行を検証します。詳細については、「スモークテストの実行」をご参照ください。

ステップ 5:タスクの送信と公開

ノードを送信して公開し、スケジュールを有効化します。

  1. ツールバーの 保存 アイコンをクリックしてノードを保存します。

  2. ツールバーの 提交 アイコンをクリックしてノードタスクを送信します。

    送信 ダイアログボックスで、変更の説明 を入力し、コードレビューオプションを選択します。

    説明
    • 送信する前に、再実行プロパティ依存する上流ノード を設定してください。

    • コードレビューは品質を保証します。有効になっている場合、公開前にレビュー担当者がコードを承認する必要があります。詳細については、「コードレビュー」をご参照ください。

標準モードのワークスペースでは、右上の 公開 をクリックして本番環境にデプロイします。詳細については、「タスクの公開」をご参照ください。

次のステップ

タスクが送信されて公開されると、ノードの設定に基づいて定期的に実行されます。ノード設定タブの右上隅にある O&M をクリックして、オペレーションセンターに移動できます。オペレーションセンターでは、定期的なタスクのスケジューリングと実行ステータスを確認できます。詳細については、「定期的なタスクの管理」をご参照ください。