すべてのプロダクト
Search

このプロダクト

    AnalyticDB:DolphinSchedulerを使用したXIHE SQLジョブのスケジュール

    ドキュメントセンター

    AnalyticDB:DolphinSchedulerを使用したXIHE SQLジョブのスケジュール

    最終更新日:Apr 24, 2025

    DolphinSchedulerは、強力なDirected Acyclic Graph (DAG) ビジュアルインターフェイスを備えた、分散型で拡張可能なオープンソースのワークフローオーケストレーションプラットフォームです。 DolphinSchedulerは、大量のデータのワークフローを効率的に実行および管理するのに役立ちます。 DolphinSchedulerを使用して、AnalyticDB for MySQLのXIHE SQLジョブをスケジュールし、データ処理効率を向上させることができます。

    前提条件

    • DolphinSchedulerがインストールされています。 詳細については、「DolphinSchedulerドキュメント」をご参照ください。

    • DolphinSchedulerのインストールディレクトリにV8.0.0以降のMySQLドライバが設定されています。ダウンロードリンクの詳細については、「mysql-connector-java」をご参照ください。

    • DolphinSchedulerを実行するサーバーのIPアドレスが、AnalyticDB for MySQLクラスターのIPアドレスホワイトリストに追加されます。詳細については、「ホワイトリストの設定」をご参照ください。

    手順

    1. データソースを作成します。

      1. DolphinScheduler webインターフェイスにアクセスします。 上部のナビゲーションバーで、[Datasource] をクリックします。

      2. [DataSourceの作成] をクリックします。 [DataSourceタイプの選択] ダイアログボックスで、[MYSQL] を選択します。

      3. [CreateDataSource] ダイアログボックスで、次の表に示すパラメーターを設定します。

        パラメーター

        説明

        DataSource

        [MYSQL] を選択します。

        データソース名

        データソースの名前。

        IP

        AnalyticDB for MySQLクラスターのエンドポイント。 AnalyticDB for MySQLコンソールにログインし、[クラスター情報] ページに移動してエンドポイントを表示します。

        ポート

        AnalyticDB for MySQLクラスターのポート番号。 値を3306に設定します。

        ユーザー名

        AnalyticDB for MySQLクラスターのデータベースアカウントの名前。

        データベース名

        AnalyticDB for MySQLクラスターのデータベースの名前。

        説明

        その他のパラメータはオプションです。 詳細は、「MySQL」をご参照ください。

      4. [テスト接続] をクリックします。 データソースが接続テストに合格したら、[確認] をクリックします。

    2. プロジェクトを作成します。

      1. 上部のナビゲーションバーで、 [プロジェクト] をクリックします。

      2. [プロジェクトの作成] をクリックします。

      3. [プロジェクトの作成] ダイアログボックスで、 [プロジェクト名] や [所有ユーザー] などのパラメーターを設定します。 詳細については、「プロジェクト」をご参照ください。

    3. ワークフローの作成

      1. 作成したプロジェクトの名前をクリックします。 左側のナビゲーションウィンドウで、[ワークフロー]> [ワークフローの定義] を選択し、[ワークフローの定義] ページに移動します。

      2. [ワークフローの作成] をクリックして、ワークフローDAG編集ページに移動します。

      3. ページの左側のリストで、SQLを選択し、右側のキャンバスにドラッグします。

      4. [現在のノード設定] ダイアログボックスで、次の表に示すパラメーターを設定します。

        パラメーター

        説明

        データソースタイプ

        [MYSQL] を選択します。

        Datasourceインスタンス

        手順1で作成したデータソースを選択します。

        SQL タイプ

        SQLジョブのタイプ。 有効な値: QueryおよびNon Query。

        SQLステートメント

        SQL文。

      5. [確認]をクリックします。

      6. ページの右上隅にある [保存] をクリックします。 [基本情報] ダイアログボックスで、[ワークフロー名] などのパラメーターを設定します。

      7. [確認]をクリックします。

    4. ワークフローを実行します。

      1. 作成したワークフローを見つけ、[操作] 列のimageアイコンをクリックしてワークフローを公開します。

      2. [操作] 列のimageアイコンをクリックします。

      3. では、開始する前にパラメータを設定してくださいダイアログボックスで、パラメーターを設定します。

      4. [確認] をクリックしてワークフローを実行します。

    5. ワークフローの詳細を表示します。

      1. 左側のナビゲーションウィンドウで、[タスク]> [タスクインスタンス] を選択します。

      2. ワークフローのタスクを見つけ、[操作] 列のimageアイコンをクリックして、ワークフローの実行結果とログを表示します。