Mule アプリケーションからSnowflake のデータにアクセス：CData JDBC Driver

こんにちは！ドライバー周りのヘルプドキュメントを担当している古川です。

CData JDBC Driver for Snowflake はSnowflake のデータをMule アプリケーションと連携することで、読み、書き、更新、削除といった機能をおなじみのSQL クエリを使って実現します。JDBC ドライバーを使えば、Snowflake のデータをバックアップ、変換、レポート作成、分析するMule アプリケーションをユーザーは簡単に作成できます。

本記事では、Mule プロジェクト内でCData JDBC Driver for Snowflake を使用して、Snowflake のデータのWeb インターフェースを作成する方法を紹介します。作成したアプリケーションを使えば、HTTP 経由でSnowflake のデータをリクエストして、JSON 形式で結果を取得できます。まったく同様の手順で、すべてのCData JDBC ドライバで250 を超えるデータソースのWeb インターフェースを作成できます。手順は以下のとおりです。

1. Anypoint Studio で新しいMule プロジェクトを作る。
2. Message Flow にHTTP コネクタを追加する。
3. HTTP コネクタのアドレスを設定する。
4. HTTP コネクタの追加後、Database Select コネクタを同じフローに追加する。
5. データベースへの新しい接続を作成し（または既存の接続を編集し）、プロパティを設定する。
   • 接続を「Generic Connection」に設定
   • Required Libraries セクションでCData JDBC ドライバのJAR ファイルを指定する(例：cdata.jdbc.snowflake.jar)。
   • Snowflake の接続文字列にURL を指定

     Snowflake データベースに接続するには、認証に加えて次のプロパティを設定します。

     • Url：自身のSnowflake URL、例えばhttps://orgname-myaccount.snowflakecomputing.com。
       • Legacy URL を使用する場合：https://myaccount.region.snowflakecomputing.com
       • 自身のURL を見つけるには：
         1. Snowflake UI の左下にある自身の名前をクリックします。
         2. Account ID にカーソルを合わせます。
         3. Copy Account URL アイコンをクリックして、アカウントURL をコピーします。
     • Database（オプション）：本製品によって公開されるテーブルとビューを、特定のSnowflake データベースのものに制限します。
     • Schema（オプション）：本製品によって公開されるテーブルとビューを、特定のSnowflake データベーススキーマのものに制限します。

     Snowflake への認証

     本製品は、Snowflake ユーザー認証、フェデレーション認証、およびSSL クライアント認証をサポートしています。認証するには、User とPassword を設定し、AuthScheme プロパティで認証メソッドを選択します。

     キーペア

     ユーザーアカウントに定義されたプライベートキーを使用してセキュアなトークンを作成することにより、キーペア認証を使用して認証できます。この方法で接続するには、AuthScheme をPRIVATEKEY に設定し、次の値を設定します。

     • User：認証に使用するユーザーアカウント。
     • PrivateKey：プライベートキーを含む.pem ファイルへのパスなど、ユーザーに使用されるプライベートキー。
     • PrivateKeyType：プライベートキーを含むキーストアの種類（PEMKEY_FILE、PFXFILE など）。
     • PrivateKeyPassword：指定されたプライベートキーのパスワード。

     その他の認証方法は、ヘルプドキュメントの「Snowflake への認証」セクションを参照してください。

     組み込みの接続文字列デザイナ

     JDBC 用のURL の作成にサポートが必要な場合は、Snowflake JDBC Driver に組み込まれた接続文字列デザイナを使用できます。JAR ファイルをダブルクリックするか、コマンドラインからJAR ファイルを実行してください。

     java -jar cdata.jdbc.snowflake.jar

     接続プロパティを入力して、接続文字列をクリップボードにコピーします。

   • Driver クラス名をcdata.jdbc.snowflake.SnowflakeDriver に指定します。
   • 「接続テスト」をクリックします。
6. SQL Query Text をSnowflake のデータをリクエストするためのSQL クエリに設定します。例えば、SELECT Id, ProductName FROM Products。
7. Transform Message コンポーネントをフローに追加します。
8. Output スクリプトを次のように設定して、ペイロードをJSON に変換します。

   %dw 2.0
   output application/json
   ---
   payload
           

9. Snowflake のデータを閲覧するには、HTTP コネクタ用に設定したアドレスに移動します（デフォルトでは、localhost:8081）：http://localhost:8081。Web ブラウザおよびJSON エンドポイントを使用可能な他のツール内で、Snowflake のデータをJSON として利用できます。

これで、カスタムアプリケーションおよび他のさまざまなBI、帳票、ETL ツールからSnowflake のデータを（JSON データとして）扱うための簡易なWeb インターフェースを作成できました。Mule アプリケーションからお好みのデータソースにアクセスできる、JDBC Driver for Snowflake の30日の無償評価版のダウンロードはこちらから。