Apache Airflow のデータから SSAS テーブルモデルを作成

Dibyendu Datta
Dibyendu Datta
Lead Technology Evangelist
CData ドライバーを使用してApache Airflow のデータから SQL Server Analysis Services のテーブルモデルを構築する方法を解説します。



SQL Server Analysis Services(SSAS)は、意思決定支援やビジネス分析に使用される分析データエンジンです。Power BI、Excel、Reporting Services レポート、その他のデータビジュアライゼーションツールなど、ビジネスレポートやクライアントアプリケーション向けのエンタープライズグレードのセマンティックデータモデルを提供します。CData API Driver for ODBC と組み合わせることで、Apache Airflow のデータ からテーブルモデルを作成し、より深く高速なデータ分析を実現できます。

Apache Airflow のデータへの接続を作成

まだ行っていない場合は、ODBC DSN(データソース名)で接続プロパティを設定します。これはドライバーインストールの最後のステップです。Microsoft ODBC データソースアドミニストレーターを使用して 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)。

Apache Airflow のデータソースを作成

まず、Visual Studio で新しい Analysis Services テーブルプロジェクトを作成します。テーブルモデルデザイナーダイアログで、互換性レベル 1400 以上を選択してください。次に、プロジェクトに Apache Airflow のデータソースを作成します。

  1. テーブルモデルエクスプローラーで Data Sources を右クリックし、「New Data Source」を選択します
  2. Other タブから「ODBC」を選択し、「Connect」をクリックします コネクタとして ODBC を選択
  3. 先ほど設定した DSN を選択します DSN の選択(Salesforce の例)
  4. 認証オプションとして「Default or Custom」を選択し、「Connect」をクリックします DSN への接続(Salesforce の例)

テーブルとリレーションシップの追加

データソースを作成したら、テーブルをインポートしてテーブル間のリレーションシップを定義します。

  1. 新しいデータソースを右クリックし、「Import New Tables」をクリックしてインポートするテーブルを選択します テーブルのインポート(Salesforce の例)
  2. テーブルのインポート後、「Relationships」を右クリックし、「Create Relationships」をクリックします
  3. テーブルを選択し、外部キー、カーディナリティ、フィルタの方向を設定します テーブル間のリレーションシップの設定(Salesforce の例)

メジャーの作成

テーブルのインポートとリレーションシップの定義が完了したら、メジャーを作成します。

  1. メジャーを作成するテーブルのカラムを選択します
  2. Extensions メニューから「Columns」->「AutoSum」をクリックし、集計方法を選択します メジャーの作成(Salesforce の例)

モデルのデプロイ

メジャーを作成したら、モデルをデプロイする準備が整いました。ソリューションエクスプローラーでプロジェクトを右クリックし、「Properties」を選択してターゲットサーバーとデータベースを設定します。「Deployment Server」プロパティを設定し、「OK」をクリックします。

デプロイ先データベースの設定

デプロイサーバーの設定後、「Build」メニューを開き、「Deploy Solution」をクリックします。これで SSAS インスタンスにApache Airflow のデータのテーブルモデルが作成され、分析、レポート作成、表示の準備が整いました。CData API Driver for ODBC の 30 日間無料トライアルをぜひお試しください。

はじめる準備はできましたか?

API Driver で Apache Airflow のライブデータに接続

Apache Airflow に接続