Choreo でAmazon Athena とデータ連携するアプリを作成
Choreo は、ローコードおよびクラウドネイティブなSaaS 開発のための多機能かつ包括的なプラットフォームです。 開発者は、高度なコーディングスキルがなくても、Choreo のローコード環境を利用することで簡単にアプリケーションを構築することができます。 さらにCData Connect AI と連携することで、アプリケーションにAmazon Athena のデータへのクラウドベースのアクセスを即座に追加できます。 この記事では、Connect AI からAmazon Athena に接続し、Choreo からリアルタイムAmazon Athena のデータにアクセスするアプリケーションを作成する方法を紹介します。
CData Connect AI は、Amazon Athena にクラウドベースのインターフェースを提供し、ネイティブにサポートされているデータベースにデータを複製することなくChoreo でリアルタイムAmazon Athena のデータを使用するアプリケーションを構築できるようにします。 CData Connect AI は最適化されたデータ処理により、サポートされているすべてのSQL 操作（フィルタ、JOIN など）をAmazon Athena に直接発行し、サーバー側の処理を利用して要求されたAmazon Athena のデータを高速で返します。
Connect AI からAmazon Athena への接続
CData Connect AI を使うと、直感的なクリック操作ベースのインターフェースを使ってデータソースに接続できます。
- Connect AI にログインし、 Add Connection をクリックします。
- Add Connection パネルで「Amazon Athena」を選択します。
-
必要な認証プロパティを入力し、Amazon Athena に接続します。
Amazon Athena 接続プロパティの取得・設定方法
それでは、早速Athena に接続していきましょう。
データに接続するには、以下の接続パラメータを指定します。
- DataSource：接続するAmazon Athena データソース。
- Database：接続するAmazon Athena データベース。
- AWSRegion：Amazon Athena データがホストされているリージョン。
- S3StagingDirectory：クエリの結果を保存するS3 フォルダ。
Database またはDataSource が設定されていない場合、CData 製品はAmazon Athena の利用可能なデータソースからすべてのデータベースのリスト化を試みます。そのため、両方のプロパティを設定することでCData 製品のパフォーマンスが向上します。
Amazon Athena の認証設定
CData 製品は幅広い認証オプションに対応しています。詳しくはヘルプドキュメントの「はじめに」を参照してみてください。
AWS キーを取得
IAM ユーザーの認証情報を取得するには、以下のステップお試しください。
- IAM コンソールにサインインします。
- ナビゲーションペインでユーザーを選択します。
- ユーザーのアクセスキーを作成または管理するには、ユーザーを選択してからセキュリティ認証情報タブに移動します。
AWS ルートアカウントの資格情報を取得するには、以下のステップをお試しください。
- ルートアカウントの認証情報を使用してAWS 管理コンソールにサインインします。
- アカウント名または番号を選択します。
- 表示されたメニューでMy Security Credentials を選択します。
- ルートアカウントのアクセスキーを管理または作成するには、Continue to Security Credentials をクリックし、［Access Keys］セクションを展開します。
その他の認証オプションについては、ヘルプドキュメントの「Amazon Athena への認証」を参照してください。
- Create & Test をクリックします。
- Add Amazon Athena Connection ページのPermissions タブに移動し、ユーザーベースのアクセス許可を更新します。
パーソナルアクセストークンの取得
OAuth 認証をサポートしていないサービス、アプリケーション、プラットフォーム、またはフレームワークから接続する場合は、認証に使用する個人用アクセストークン（PAT）を作成できます。 きめ細かなアクセス管理を行うために、サービスごとに個別のPAT を作成するのがベストプラクティスです。
- Connect AI アプリの右上にあるユーザー名をクリックし、User Profile をクリックします。
- User Profile ページでPersonal Access Token セクションにスクロールし、 Create PAT をクリックします。
- PAT の名前を入力して Create をクリックします。
- 個人用アクセストークンは作成時にしか表示されないため、必ずコピーして安全に保存してください。
接続の設定が完了したら、Choreo からAmazon Athena のデータに接続できるようになります。
Choreo からAmazon Athena への接続
以下のステップでは、Choreo からCData Connect AI に接続し、リアルタイムAmazon Athena のデータにアクセスできる新しいアプリケーションを作成する方法を紹介します。
コンストラクトを作成する
-
Choreo プラットフォームにサインインします。Note：この記事は、Anonymously を選択した場合について説明しています。
-
左サイドバーからComponents を選択し、+Create をクリックします。次に、Manual Trigger を選択し、続けてStart from scratch を選択します。
-
マニュアルトリガーのName とDescription を入力し、Create をクリックします。
-
トリガーが作成されたら、Edit Code をクリックします。
-
Ballerina Low-Code IDE が表示されます。Choreo は、ローコードダイアグラムビューでコンストラクトを自動生成します。
このコンストラクトをハイライトしてゴミ箱アイコンをクリックし、削除します。
-
画面上部の + アイコンをクリックし、右サイドのAdd Constructs ツールバーにあるMain を選択します。
続けてFunction Configuration フォームでSave をクリックします。
CData Connect AI コネクタを追加する
- 楕円形のSTART とEND の間にある + アイコンをクリックして、Connector をクリックします。
- 右サイドバーのConnectors で「CData」を検索します。CData Connect をクリックしてConnector 設定ペインを開きます。
-
Connector 設定ペインで、構成の設定を入力します。
- 使用するEndpoint Name を入力します。例では「connectEndpoint」を使用しています。
- User フィールドに、CData Connect AI ユーザーのE メールアドレスを引用符で囲んで入力します（例："user@cdata.com"）。
- Password フィールドに、前述の生成されたPAT を引用符で囲んで入力します（例："SampleToken"）。
- Save をクリックすると、CData Connect AI のロゴがついたローコードエディタが表示されます。
クエリのアクションを追加する
- new とend の間の + アイコンをクリックし、Action を選択して既存のコネクタエンドポイントを選択します。
- connector Operation クエリを選択します。右側にAction ペインが表示されます。
- Amazon Athena のデータを取得するためのSQL クエリを、query のsqlQuery パラメータとして入力します。次に例を示します。
SELECT * FROM AmazonAthena1.AmazonAthena.Customers LIMIT 10
- クエリを入力する際、カタログにConnection Name を、スキーマにData Source Name を必ず指定してください。例えば、AmazonAthena1.AmazonAthena です。
- これらのパラメータはCData Connect AI ダッシュボードのConnections ページに表示されます。
Amazon Athena のデータを反復処理する
- コードエディタの右上にあるShow Source アイコンをクリックします。
- ballerina/io ライブラリをインポートするimport 文を追加します。
import ballerina/io;
- 次に、SQL クエリの結果を繰り返し処理するために、query アクションの後にfrom 文を追加します。
- コンストラクトのコードは次のようになります。
- Save をクリックしてアクションを保存します。次のようなダイアグラムになります。
check from record{} result in resultStream
do {
io:println("Full Customers details: ", result);
};
import ballerinax/cdata.connect;
import ballerinax/cdata.connect.driver as _;
import ballerina/io;
public function main() returns error? {
connect:Client connectEp = check new (user = "connect_cloud_username", password="connect_cloud_pat");
stream<record {}, error=""?> resultStream =
connectEp->query(sqlQuery = `SELECT * FROM AmazonAthena1.AmazonAthena.Customers LIMIT 10`);
check from record{} result in resultStream
do {
io:println("Full Customers details: ", result);
};
}
プログラムをデプロイする
必要とするアクションをすべてプログラムに追加したら、次のステップに進みます。
- Web エディタで最終的なソースコードをコミットしてプッシュし、その変更をChoreo プラットフォームに同期します。
- Choreo Console の左ナビゲーションバーでDeploy をクリックします。
- Build Area でConfigure & Deploy をクリックし、プログラムをデプロイします。
- プロンプトが表示されたら、先ほど使用したCData Connect AI のユーザー名とパスワードを入力し、Deploy をクリックします。
Choreo でリアルタイムAmazon Athena のデータにアクセスできるアプリケーションを作成できました。
CData Connect AI の入手
Choreo をCData Connect AI で連携するための詳細は、CData Connect Ballerina Guide を参照してください。 CData Connect AI の14日間無償トライアルを利用して、クラウドアプリケーションから100を超えるSaaS、ビッグデータ、NoSQL データソースへのダイレクトなSQL アクセスをお試しください！