MySQL Workbench で Apache Airflow のデータをクエリする方法
Apache Airflow 用のODBC Driver のSQL Gateway を使用すると、MySQL インターフェースを通じて Apache Airflow のデータ にクエリできます。以下の手順に従って、SQL Gateway のMySQL リモーティングサービスを起動し、MySQL Workbench でリアルタイムの Apache Airflow のデータ を操作してみましょう。
Apache Airflow のデータへの接続
まだ接続設定を行っていない場合は、データソース名（DSN）で必要な接続プロパティの値を入力してください。組み込みのMicrosoft ODBC データソースアドミニストレーターを使用してDSN を設定できます。これはドライバーインストールの最後のステップでもあります。Microsoft ODBC データソースアドミニストレーターを使用してDSN を作成・設定する方法については、ヘルプドキュメントの「はじめに」セクションを参照してください。
まず、Profile 接続プロパティをディスク上の ApacheAirflow プロファイルの場所に設定します（例：C:\profiles\ApacheAirflow.apip）。次に、ProfileSettings 接続プロパティを ApacheAirflow の接続文字列に設定します（以下を参照）。
ApacheAirflow API プロファイル設定
Apache Airflow 3 では、API 認証に JWT Bearer トークンを使用します。トークンは、Airflow Web UI の「Settings」から生成するか、Airflow CLI の airflow users create と /api/v2/auth/token エンドポイントを使って生成できます。なお、このプロファイルは /api/v2 REST API を使用する Apache Airflow 3.x を対象としています。Airflow 2.x で使われていた従来の /api/v1 エンドポイントには対応していません。
以下の接続プロパティを設定すると、接続できるようになります。
- AuthScheme：APIKey に設定します。
- APIKey：Apache Airflow の JWT Bearer トークンに設定します。
- Server：Airflow インスタンスのベース URL に設定します（例：http://localhost:8080）。
SQL Gateway の設定
SQL Gateway の概要を参照して、Apache Airflow のデータ への接続を仮想MySQL データベースとしてセットアップしてください。クライアントからのMySQL リクエストをリッスンするMySQL リモーティングサービスを設定します。このサービスはSQL Gateway UI で設定できます。
MySQL Workbench から Apache Airflow をクエリ
以下の手順では、SQL Gateway で作成した仮想 Apache Airflow データベースにMySQL Workbench から接続し、基本的なクエリを発行してリアルタイムの Apache Airflow のデータ を操作する方法を説明します。
SQL Gateway 経由で Apache Airflow に接続
- MySQL Workbench で、新しいMySQL 接続を追加するためにクリックします。
- 接続に名前を付けます（CData SQL Gateway for Apache Airflow）。
- SQL Gateway に接続するためのHostname、Port、Username パラメータを設定します。
- Store in Vault をクリックしてパスワードを設定・保存します。
- Test Connection をクリックして接続が正しく設定されていることを確認し、OK をクリックします。
NOTE: Username および Password は、SQL Gateway 用に作成したユーザーの資格情報を指します。
Apache Airflow のデータをクエリ
- 作成した接続（CData SQL Gateway for Apache Airflow）を開きます。
- File -> New Query Tab をクリックします。
- SELECT * FROM `CData API Sys`.DagRuns; のようなSQL クエリを記述して Apache Airflow のデータ を取得します。
MySQL Workbench からリアルタイムの Apache Airflow のデータ にアクセスできるようになりました。MySQL データベースと同じ感覚で Apache Airflow を簡単に操作できます。CData API Driver for ODBC とCData SQL Gateway の30日間の無償トライアルをぜひお試しください。