MicroStrategy Desktop で CData ODBC Driver for Apache Airflow を使用
MicroStrategy は、データドリブンなイノベーションを可能にする分析およびモビリティプラットフォームです。CData ODBC Driver for Apache Airflow と組み合わせることで、MicroStrategy からリアルタイムのApache Airflow のデータにデータベースのようにアクセスでき、レポートや分析の機能を拡張できます。本記事では、MicroStrategy Desktop で Apache Airflow をデータソースとして追加し、Apache Airflow のデータ の簡単なビジュアライゼーションを作成する手順を説明します。
CData ODBC Driver は、ドライバーに組み込まれた最適化されたデータ処理により、MicroStrategy でリアルタイムのApache Airflow のデータを操作する際に比類のないパフォーマンスを発揮します。MicroStrategy から Apache Airflow に複雑な SQL クエリを発行すると、ドライバーはフィルタや集計などのサポートされている SQL 操作を Apache Airflow に直接プッシュし、サポートされていない操作(多くの場合 SQL 関数や JOIN 操作)は組み込みの SQL エンジンを使用してクライアント側で処理します。動的なメタデータクエリ機能が組み込まれているため、ネイティブの MicroStrategy データ型を使用してApache Airflow のデータを可視化・分析できます。
ODBC データソースとして Apache Airflow に接続
Apache Airflow への接続に関する情報と、Windows および Linux 環境での 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 接続プロパティも設定することをお勧めします。これにより返される行数を制限でき、レポートやビジュアライゼーションを設計する際のパフォーマンス向上に特に効果的です。
Windows
まだ設定していない場合は、ODBC DSN(データソース名)で接続プロパティを指定してください。これはドライバーインストールの最後のステップです。Microsoft ODBC データソースアドミニストレーターを使用して ODBC DSN を作成・設定できます。
Linux
Linux 環境で CData ODBC Driver for Apache Airflow をインストールする場合、ドライバーのインストール時にシステム DSN が事前定義されます。システムデータソースファイル(/etc/odbc.ini)を編集して、必要な接続プロパティを定義することで DSN を変更できます。
/etc/odbc.ini
[CData API Sys]
Driver = CData ODBC Driver for Apache Airflow
Description = My Description
Profile = C:\profiles\ApacheAirflow.apip
AuthScheme = APIKey
ProfileSettings = 'APIKey = your_jwt_token
Server = http://localhost:8080'
これらの設定ファイルの使用方法の詳細については、ヘルプドキュメント(インストール版およびオンライン版)を参照してください。
MicroStrategy Desktop を使用して Apache Airflow のデータに接続して可視化
MicroStrategy エンタープライズ製品で Apache Airflow に接続するだけでなく、MicroStrategy Desktop でも Apache Airflow に接続できます。以下の手順に従って、Apache Airflow のデータ をデータセットとして追加し、Apache Airflow のデータ のビジュアライゼーションとレポートを作成してください。
- MicroStrategy Desktop を開き、新しいドシエを作成します。
- データセットパネルで「New Data」をクリックし、「Databases」を選択して、インポートオプションとして「Type a Query」を選択します。
- 新しいデータソースを追加し、「DSN data sources」を選択します。
- 以前に設定した DSN(通常は CData API Sys)を選択し、Version メニューで「Generic DBMS」を選択します。
- DSN の User と Password プロパティを設定し(またはプレースホルダー値を使用)、データソースに名前を付けます。
- 新しいデータベースインスタンスを選択してテーブルを表示します。「Available Tables」セクションでテーブルを表示するには、検索アイコンを手動でクリックする必要がある場合があります。
- Apache Airflow のデータ 用の SQL クエリを作成し(以下を参照)、「Execute SQL」をクリックしてクエリをテストします。
SELECT * FROM DagRuns
注意:ライブ接続を作成するため、SELECT * クエリを実行し、MicroStrategy 製品にネイティブのフィルタリングや集計機能を利用できます。 - 「Finish」をクリックし、ライブ接続を選択します。
- ビジュアライゼーションを選択し、表示するフィールドを選択し(データ型は動的メタデータ検出により自動的に検出されます)、フィルタを適用してApache Airflow のデータの新しいビジュアライゼーションを作成します。可能な場合、フィルタや集計によって生成された複雑なクエリは Apache Airflow にプッシュダウンされ、サポートされていない操作(SQL 関数や JOIN 操作を含む場合があります)はドライバーに組み込まれた CData SQL エンジンによってクライアント側で管理されます。

- ドシエの設定が完了したら、「File -> Save」をクリックします。
MicroStrategy Desktop で CData ODBC Driver for Apache Airflow を使用すると、Apache Airflow のデータ の堅牢なビジュアライゼーションとレポートを簡単に作成できます。その他の例については、MicroStrategy で Apache Airflow に接続や MicroStrategy Web で Apache Airflow に接続に関する記事もご覧ください。