Cognos BI でApache Airflow のデータを使ってデータビジュアライゼーションを作成
CData ODBC Driver for API を使って、Apache Airflow のデータをドラッグアンドドロップ スタイルのCognos Report Studio に連携できます。この記事では、データビジュアライゼーションをSQL を書かずに作成するグラフィカルアプローチと、Apache Airflow がサポートする任意のSQL クエリを実行する方法の両方について説明します。
CData ODBC ドライバとは？
CData ODBC ドライバは、以下のような特徴を持った製品です。
- Apache Airflow をはじめとする、CRM、MA、会計ツールなど多様なカテゴリの270種類以上のSaaS / オンプレデータソースに対応
- 多様なアプリケーション、ツールにApache Airflow のデータを連携
- ノーコードでの手軽な接続設定
- 標準SQL での柔軟なデータ読み込み・書き込み
CData ODBC ドライバでは、1.データソースとしてApache Airflow の接続を設定、2.Cognos BI 側でODBC Driver との接続を設定、という2つのステップだけでデータソースに接続できます。以下に具体的な設定手順を説明します。
CData ODBC ドライバのインストールとApache Airflow への接続設定
まずは、本記事右側のサイドバーからAPI ODBC Driver の無償トライアルをダウンロード・インストールしてください。30日間無償で、製品版の全機能が使用できます。
下記の手順に従って、［Cognos Administration］ツールのライブ Apache Airflow に接続を確立します。この接続はCognos BI 全体で使えます。このドライバーを使って、すべてのユーザーは一貫したデータおよびメタデータ：リアルタイムApache Airflow を利用できます。
-
接続プロパティの指定がまだの場合は、ODBC DSN （データソース名）で行います。Microsoft ODBC データソースアドミニストレーターを使ってODBC DSN を作成および設定できます。
64ビット版のマシンからCognos を実行している場合は、32ビット版ODBC データソースアドミニストレーターを起動する必要があります。以下のコマンドで開くことができます：
C:\Windows\sysWOW64\odbcad32.exeまず、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）。
Microsoft ODBC データソースアドミニストレーターで必要なプロパティを設定する方法は、ヘルプドキュメントの「はじめに」をご参照ください。
-
［Cognos Administration］を開いて新しいデータソースを追加します。［Data Source Connections］をクリックして［ODBC］オプションを選択したら、システム DSN とユーザーフレンドリーな名前を入力します。［Retrieve Objects］をクリックして CData Apache Airflow データベースオブジェクトを選択します。
データビジュアライゼーションをレポートに追加
これで、［Source Explorer］からレポートオブジェクトにカラムをドラッグアンドドロップしてCognos Report Studio のApache Airflow のデータ にレポートを作成できます。以下では、最新データを表示するチャートを持つシンプルなレポートを作成する方法を説明します。
レポートをビルドすると、Cognos Report Studio はSQL クエリを生成して実行をドライバーに依存します。ドライバーはクエリをApache Airflow API へのリクエストに変換します。ドライバーはリアルタイムApache Airflow へのクエリの実行を基になるAPI に依存します。
アグリゲートに基づきチャートを作成
［Source Explorer］からオブジェクトのdimentions にカラムをドラッグアンドドロップするだけで、Cognos レポートオブジェクトとしてApache Airflow のデータを使うことができます。チャートのSeries dimension のカラムは自動的にグループ化されます。
さらにCognos は、measure dimesion のロジカルなデフォルトアグリゲート関数をデータタイプに基づいて設定します。この例では、デフォルトをオーバーライドしています。［Data Items］タブの State カラムをクリックしてAggregate Function プロパティを Not Applicableに設定します。Rollup Aggregate Function プロパティは Automatic に設定する必要があります。
Query オブジェクトをSQL に変換
必要なクエリを把握している、あるいは生成されたクエリを調整したい場合は、query オブジェクトをSQL ステートメントに変換します。クエリがSQL に変換されると、UI コントロールはquery オブジェクトで利用できなくなります。下記の手順に従って、ユーザー定義のSQL でチャートを埋めます。
Cognos はユーザー定義クエリの実行をドライバーに依存します。ドライバーのSQL エンジンを使うと、キャッシュデータのコピーがないためクエリは常に最新の結果を返します。
- ［Query Explorer］の上にカーソルを置き、［Queries］フォルダをクリックしてレポートにquery オブジェクトを表示します。
-
自動生成されたクエリを編集したい場合は、Generated SQL プロパティにあるquery オブジェクトのボタンをクリックします。ダイアログが表示されたら、［Convert］をクリックします。
新たにSQL ステートメントを入力したい場合は、query オブジェクトと一緒にSQL オブジェクトをドロップします。
- SQL オブジェクトのプロパティを編集：SQL プロパティでApache Airflow のデータソースを選択してSQL Syntax プロパティをNative に設定します。
SQL プロパティのボタンをクリックし、ダイアログが表示されたらSQL クエリを入力します。この例では以下のクエリを使います：
SELECT DagRunId, State FROM DagRuns WHERE DagId = 'example_dag'query オブジェクトのプロパティを編集：Processing プロパティを［Limited Local］に設定します。この値はquery オブジェクトをSQL に変換するために必要です。
クエリ結果をチャートで使用
これで［Data Items］タブのオブジェクトとしてSQL クエリ結果にアクセスできるようになりました。下記の手順に従って、クエリ結果を使ってチャートを作成します；例えば、DagRuns テーブルからState を各DagRunId へ。
- ［Page Explorer］ 上にカーソルを置きpage オブジェクトをクリックしてページに戻ります。
- 円グラフをツールボックスからワークスペース上にドラッグします。
- チャートのプロパティで、Query プロパティに先ほど作成したクエリの名前を設定します。
- ［Data Items］タブをクリックしてカラムをx およびy 軸上にドラッグします。この例ではDagRunId カラムをSeries (pie slices) ボックスに、State カラムをDefault Measure ボックスにドラッグします。
-
Default Measure (State 値) のデフォルトのプロパティを編集します：［Aggregate Function］ボックスで "Not Applicable" オプションを選択します。
レポートを実行してクエリ結果を追加します。
