Excel からMicrosoft Query を使ってApache Airflow に接続する方法



Microsoft Query を使うことで、Excel からデータベースやファイル、外部データソースにアクセスしてデータをインポート、更新できます。CData ODBC Driver for API はMicrosoft Query の連携先を拡張して、270種類以上のCRM、ERP、MA、会計ツールなどのデータソースへのアクセスを実現します。 この記事では、Microsoft Query を使ってApache Airflow のデータをスプレッドシートにインポートする方法をご紹介します。

CData ODBC ドライバとは？

CData ODBC ドライバでは、1.データソースとしてApache Airflow の接続を設定、2.Microsoft Query でODBC Driver との接続を設定、という2つのステップだけでデータソースに接続できます。以下に具体的な設定手順を説明します。

Apache Airflow への接続を設定

まずは、本記事右側のサイドバーからAPI ODBC Driver の無償トライアルをダウンロード・インストールしてください。30日間無償で、製品版の全機能が使用できます。

ODBC ドライバーのインストール完了時に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）。

Microsoft ODBC データソースアドミニストレーターで必要なプロパティを設定する方法の詳細は、ヘルプドキュメントの「はじめに」を参照してください。

Excel で［データ］タブを開き［その他のデータソースから］->［Microsoft Query から］を選びます。

マシンにインストールされているMicrosoft Office のバージョンに合わせて、32 bit CData Apache Airflow Source または64 bit CData Apache Airflow Source x64 DSN を選びます。Query Wizard を使うオプションを選択し、クエリを作成／編集します。

Query Wizard で、スプレッドシートにインポートしたいテーブルのノードを展開します。インポートしたいカラムを選択し、矢印をクリックしてクエリに追加します。あるいはテーブル名を選択して、テーブルにあるすべてのカラムを追加します。

［Filter Data］ページではクライテリアを指定できます。例えば、日付の範囲を設定して結果を絞れます。

クエリでパラメータを使いたい場合は、Microsoft Query でクエリを編集するオプションを選択します。

クエリにパラメータを設定するには、SQL を直接修正する必要があります。その場合は、［Query Editor］の［SQL］ボタンをクリックします。フィルタクライテリアを事前に設定している場合は、クエリ内にWHERE 句が存在します。

パラメータを使うには、WHERE 句のフィールド値にワイルドカード文字として "?" を使います。例えばDagRuns をインポートしている場合は、"DagId=?" を設定できます。

SQL ステートメントの編集が終わったら［SQL］ダイアログを閉じます。パラメータ値を入力するように促されますが、次のステップでセルを選択して値を入れることになるので、このダイアログではボックスは空のままにしておきます。

Microsoft Query を閉じます。［Import Data］ダイアログが表示されます。結果をインポートするセルを入力します。

［Import Data］ダイアログを閉じます。パラメータ値を入力するように促されます。パラメータボックスの隣にあるボタンをクリックしてセルを選択します。値が変更されたらスプレッドシートを自動的にリフレッシュするオプションを選択します。

データはこれでExcel にインポートされました。セルB1の値を変更すると、データは指定した検索クライテリアによってフィルタされます。

おわりに

このようにCData ODBC ドライバと併用することで、270を超えるSaaS、NoSQL データをMicrosoft Query からコーディングなしで扱うことができます。30日の無償評価版が利用できますので、ぜひ自社で使っているクラウドサービスやNoSQL と合わせて活用してみてください。

日本のユーザー向けにCData ODBC ドライバは、UI の日本語化、ドキュメントの日本語化、日本語でのテクニカルサポートを提供しています。