Dundas BI でApache Airflow のデータを使ってダッシュボードを構築
CData のApache Airflow 用 ODBC ドライバーは、ODBC 標準経由でApache Airflow のリアルタイムデータにアクセスし、使い慣れた SQL クエリで各種 BI、レポート、ETL ツールからApache Airflow のデータを利用可能にします。この記事では、汎用 ODBC データプロバイダーとしてApache Airflow に接続し、Dundas BI でApache Airflow のデータを基にしたチャート、レポート、ダッシュボードを作成する方法を解説します。
Apache Airflow のデータへの接続設定
- まだ設定していない場合は、データソース名（DSN）で必要な接続プロパティを指定します。DSN の設定は組み込みの Microsoft ODBC データソースアドミニストレーターを使用して行えます。これはドライバーインストールの最終ステップでもあります。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）。
DSN を設定する際には、Max Rows 接続プロパティも設定することをお勧めします。これにより返される行数が制限され、レポートやビジュアライゼーションの設計時にパフォーマンスを向上させるのに役立ちます。
- Dundas BI インターフェースを開き、メニューから New Data Connector をクリックします。
- Dundas BI の Data Connector を設定します：
- Data Connector の名前を入力します。
- Data Provider として「ODBC generic」を選択します。
- 「Use System DSN」チェックボックスをオンにします。
- 適切なシステム DSN を選択します。
Apache Airflow のデータをダッシュボードに追加
これでApache Airflow のデータを使ってダッシュボードを作成する準備が整いました。
- ホームページに移動します。
- Explore Data をクリックします。
- 適切な Data Connector を展開します。
- Connector から関連するデータをパネルにドラッグします。
- 「テーブル」全体を選択して追加することもできますが、適切なビジュアライゼーションを作成するには Metric Set からメジャーや行を削除する必要があるかもしれません。あるいは、ビジュアライゼーションに含めたいフィールドのみを選択することもできます。
- フィールドを選択した状態で、メジャーと行にフィルタや条件を追加し、ビジュアライゼーションをさらにカスタマイズできます。
- メニューバーから Re-visualize をクリックし、データに適したビジュアライゼーションを選択します。
- Add To New Dashboard をクリックして、ビジュアライゼーションを新しいダッシュボードに追加します。
- Apache Airflow のデータを使ったダイナミックなビジュアライゼーションを作成してダッシュボードを設定します。
