Amazon Athena のデータ のPostgreSQL インターフェースを作成

PostgreSQL には多くの対応クライアントがあります。標準のドライバーからBI、アナリティクスツールまで、PostgreSQL はデータ接続の人気のインターフェースです。JDBC ドライバーを使用することで、簡単に任意の標準クライアントから接続できるPostgreSQL エントリポイントを作成できます。

Amazon Athena にPostgreSQL データベースとしてアクセスするには、CData JDBC Driver for AmazonAthena とJDBC foreign data wrapper (FDW) を使用します。この記事ではFDW をコンパイルしてインストールし、PostgreSQL サーバーからAmazon Athena にクエリを実行します。

JDBC データソースとしてAmazon Athena のデータに接続する

JDBC データソースとしてAmazon Athena に接続するには、以下が必要です。

• Driver のJAR パス：JAR ファイルは、インストールディレクトリのlib サブフォルダにあります。

• Driver クラス

  cdata.jdbc.amazonathena.AmazonAthenaDriver
  

• JDBC URL: URL は、"jdbc:amazonathena:" で始まり、セミコロンで区切られた名前と値の組み合わせで任意の接続プロパティを含めることができます。

  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 ユーザーの認証情報を取得するには、以下のステップお試しください。

  1. IAM コンソールにサインインします。
  2. ナビゲーションペインでユーザーを選択します。
  3. ユーザーのアクセスキーを作成または管理するには、ユーザーを選択してからセキュリティ認証情報タブに移動します。

  AWS ルートアカウントの資格情報を取得するには、以下のステップをお試しください。

  1. ルートアカウントの認証情報を使用してAWS 管理コンソールにサインインします。
  2. アカウント名または番号を選択します。
  3. 表示されたメニューでMy Security Credentials を選択します。
  4. ルートアカウントのアクセスキーを管理または作成するには、Continue to Security Credentials をクリックし、［Access Keys］セクションを展開します。

  その他の認証オプションについては、ヘルプドキュメントの「Amazon Athena への認証」を参照してください。

  ビルトイン接続文字列デザイナ

  JDBC URL の構成については、Amazon Athena JDBC Driver に組み込まれている接続文字列デザイナを使用できます。JAR ファイルのダブルクリック、またはコマンドラインからJAR ファイルを実行します。

  java -jar cdata.jdbc.amazonathena.jar
  

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

  

  以下は一般的なJDBC URL です。

  jdbc:amazonathena:AccessKey='a123';SecretKey='s123';Region='IRELAND';Database='sampledb';S3StagingDirectory='s3://bucket/staging/';
  

JDBC FDW を構築する

FDW は、PostgreSQL を再コンパイルせずに、PostgreSQL の拡張機能としてインストールできます。例としてjdbc2_fdw 拡張子を使用します。

1. ご使用のバージョンのJRE 共有オブジェクトから、/usr/lib/libjvm.so にシンボリックリンクを追加します。コマンド例：

   ln -s /usr/lib/jvm/java-6-openjdk/jre/lib/amd64/server/libjvm.so /usr/lib/libjvm.so
   

2. ビルドするには、以下のコマンドを実行してください。

   make install USE_PGXS=1
   

Amazon Athena のデータをPostgreSQL データベースとしてクエリする

拡張機能をインストールした後、以下のステップに従ってAmazon Athena へのクエリの実行を開始します。

1. データベースにログイン
2. データベースの拡張機能をロード

   CREATE EXTENSION jdbc2_fdw;
   

3. Amazon Athena のオブジェクトを作成

   CREATE SERVER AmazonAthena
   FOREIGN DATA WRAPPER jdbc2_fdw OPTIONS (
   drivername 'cdata.jdbc.amazonathena.AmazonAthenaDriver',
   url 'jdbc:amazonathena:AccessKey='a123';SecretKey='s123';Region='IRELAND';Database='sampledb';S3StagingDirectory='s3://bucket/staging/';',
   querytimeout '15',
   jarfile '/home/MyUser/CData/CData\ JDBC\ Driver\ for\ Salesforce MyDriverEdition/lib/cdata.jdbc.amazonathena.jar');
   

4. PostgreSQL デーモンに認識されているユーザーのユーザー名とパスワードのユーザーマッピングを作成

   CREATE USER MAPPING for postgres SERVER AmazonAthena OPTIONS (
   username 'admin',
   password 'test');
   

5. ローカルデータベースに外部テーブルを作成

   postgres=# CREATE FOREIGN TABLE customers (
   customers_id text,
   customers_Name text,
   customers_TotalDue numeric)
   SERVER AmazonAthena OPTIONS (
   table_name 'customers');
   

postgres=# SELECT * FROM customers;

おわりに

このようにCData JDBC Driver for AmazonAthena を使って簡単にAmazon Athena のデータを取得して検索対象にすることができました。ぜひ、30日の無償評価版 をお試しください。