JDBCコネクターを使用したAmazon Athenaへの接続

このサンプルでは、Java JDBCドライバーを使用してAmazon Athenaサービスに接続し、Talend StudioのAmazon Athenaサービスを利用する方法を示します。

Amazon Athenaに接続するためのJDBC接続の設定

Before you begin

Amazon Athenaは現在、一部のAWSリージョンでのみご利用いただけます。[AWS global infrastructure region table] (AWSグローバルインフラストラクチャーリージョンテーブル)からサービスが利用可能かどうか確認します。
必須の追加ライブラリーであるAthenaJDBC42-2.X.X.jarの準備ができていること。まだダウンロードしていない場合は、こちらからAthena JDBCドライバーをダウンロードします。
Amazon Athenaからのクエリー結果はAmazon S3に保存される必要があるため、S3出力フォルダーを作成します。Amazon Athena、Amazon S3、JDBCの詳細は、以下をご覧ください。

Procedure

Talend Studioの[Repository] (リポジトリー)ツリービューで[Metadata] (メタデータ)ノードを展開し、[DB Connections] (DB接続)を右クリックして、[Create Connection] (接続を作成)を選択します。

[Database Connection] (データベース接続)ウィザードが開きます。
接続名と目的を指定し、[Next] (次へ)をクリックします。
[DB Type] (DBタイプ)リストから[JDBC]を選択します。
[JDBC URL]フィールドには、AWSユーザーIDとパスワードを含むJDBC URLの詳細が表示されます。
```
jdbc:awsathena://AwsRegion=<AWS Region>;User=<AWS Access Key>;Password=<AWS Secret Key>;S3OutputLocation=<S3 folder>
```
必要な他のライブラリーもインストールします。
1. [Drivers] (ドライバー)テーブルで、[+]ボタンをクリックして線を追加し、[...]ボタンをクリックして[Module] (モジュール)ダイアログボックスを開きます。
2. [Install a new module] (新しいモジュールをインストール)オプションを選択し、[...]ボタンをクリックしてダウンロードされたjarファイルを参照します。
3. OKをクリックしてダイアログボックスを閉じます。
[Database connection] (データベース接続)ウィザードに戻り、[Select class name] (クラス名を選択)ボタンをクリックし、Amazon Athenaと通信できるようにするドライバーのメインクラスを選択します。
[User Id] (ユーザーID)および[Password] (パスワード)フィールドにデータベースユーザー認証データを入力します。
[Test connection] (接続テスト)をクリックし、[Finish] (終了)をクリックしてウィザードを閉じます。
[Repository] (リポジトリー)ツリービューで、作成した JDBC 接続を右クリックし、接続されているAmazon Athenaサービスのテーブルスキーマを取得するため[Retrieve schema] (スキーマを取得)を選択します。

Amazon Athenaに接続するためのジョブの設定

Procedure

Talend標準ジョブを作成し、そのデザインワークスペースに2つのコンポーネントを配置します:tDBInputとtLogRowを入力し、必要に応じてラベルを付けます。
tDBInputコンポーネントをダブルクリックし、DatabaseリストからJDBCを選択して、[Apply] (適用)をクリックします。
[Row] (行) > [Main] (メイン)接続を使用してtDBInputコンポーネントとtLogRowコンポーネントに接続します。
[Repository] (リポジトリー)ツリービューで、作成したばかりのJDBC接続を展開し、目的のテーブルスキーマを選択して、それをtDBInputコンポーネントに配置します。
接続情報、テーブル名、およびスキーマは自動的に設定されます。
[Guess Query] (クエリーを推測)をクリックしてクエリー句を生成し、必要に応じて編集します。
tLogRowコンポーネントの[Basic settings] (基本設定)ビューで[Sync columns] (カラムを同期)をクリックし、入力コンポーネントと同一のスキーマがあることを確認します。Table (each is key/value list)オプションを選択すると、コンソール表示が読みやすくなります。
F6を押してジョブを実行します。

Results

[Run] (実行)コンソールは、Amazon Athenaサービスから読み取られたデータを表示します。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください