Google BigQueryアダプターの紹介

フォローする
 ／ 公開日
更新日

Google BigQueryアダプターについてご紹介させていただきます。
このアダプターで使えるコンポーネントは次の通りです。

CDataGoogleBigQueryGet.png GoogleBigQueryへSELECT文を発行して結果セットをストリームとして出力します。
CDataGoogleBigQueryPut.png GoogleBigQueryのテーブルに対して更新を行います。
CDataGoogleBigQuerySQLCall.png 任意のSQLを実行します。

今回は、Google BigQueryアダプターを使うための事前準備とコネクション作成方法について紹介したいと思います。

 

■事前準備

[Google API Console]
次の手順に従って、クライアントID、クライアントシークレットを取得します。

  1. Google API コンソールにログインします。
  2. ［プロジェクトの作成］をクリック、または既存のプロジェクトを選択します。
  3. メインメニューから［API Manager］を開き、［認証情報］→［認証情報を作成］→［OAuth クライアントID］をクリックします。
  4. ［作成］をクリックします。
    クライアントIDおよびクライアントシークレットが表示されます。
    GoogleBigQuery_010.png
  5. ［ライブラリ］→［BigQuery API］→［有効にする］をクリックします。
    GoogleBigQuery_020.png

[ASTERIA WARPサーバー]

Google BigQueryアダプターを利用するためには事前にインストールしておく必要があります。
アダプターは［FSMC］→［システム］→［アップデート］画面にてダウンロードするか、ユーザーサイトからダウンロードしたアダプターをサーバーにアップロードすることで適用することができます。

GoogleBigQuery_030.png

アダプターのインストールについて詳しくは下記弊社のオンラインヘルプをご参照ください。

※アダプターのインストール後設定を有効にするためにはフローサービス全体の再起動が必要となります。

 

[フローデザイナー]

ASTERIA WARPサーバー側でGoogle BigQueryアダプターが正常にインストールされたら、フローデザイナー側でコンポーネントを取得する必要があります。
手順は下記になります。

  1. フローデザイナーからフローサービスへ接続
  2. メニューの「ツール > コンポーネント／マッパー関数の取得」でjarファイルを取得
  3. フローデザイナーを再起動

    GoogleBigQuery_040.png
    ※今回ダウンロードするファイルはfccdatagooglebigquery-1806.0500.jarとなります。

 

■コネクションの作成

事前準備が終わりましたら、コネクションを作成します。
FSMCでコネクションを作成する手順は下記になります。
FSMC画面の［設定］→［コネクション］→［GoogleBigQuery］メニューから「新規」ボタンをクリックします。
コネクション作成画面が表示されますので、下記の通り項目を設定します。

GoogleBigQuery_050.png

  • 接続名：コネクション名を設定します。
  • プロジェクトId：Google API Consoleの事前準備で作成したプロジェクトのIdを設定します。
  • データセットId：接続してテーブルを参照するデータセットのDatasetIdを設定します。
  • イニシエートOAuth：GETANDREFRESHを選択します。
    現在トークンが存在しない場合にはブラウザを通じてユーザーをプロンプトすることで取得されます。
    トークンが存在する場合には必要に応じてリフレッシュされます。
  • OAuthクライアントID：Google API Consoleの事前準備で作成したクライアントIDを設定します。
  • OAuthクライアントシークレット：Google API Consoleの事前準備で作成したクライアントシークレットの値を設定します。

※デザイナーからもコネクションの設定が可能です。

 

■コネクションの接続テスト

Google BigQueryアダプターのコネクションが作成されたので、コネクションの接続テストを実行してみます。
今回はOAuthトークン情報を自動で取得更新するために、「イニシエートOAuth」に「GETANDREFRESH」を設定しました。この時、最初にOAuthトークンを取得するにはWARPサーバー側でブラウザが起動され、ログイン画面が表示されます。
ログインに成功するとアプリで必要なアクセス許可をリクエストする画面が表示されますので、許可をクリックします。

許可をクリックすると認証に成功し、OAuthトークンが取得されます。

GoogleBigQuery_061.png

GoogleBigQuery_062.png


また、以下のようにコネクション接続テスト成功画面も確認できます。

GoogleBigQuery_063.png

 

■最後に

Google BigQueryアダプターの利用するために必要な事前準備、およびコネクションの作成方法についてご紹介いたしました。
コネクションの作成後接続テストが正常に行われるとGoogleBigQueryGetコンポーネント、GoogleBigQueryPutコンポーネント、GoogleBigQuerySQLCallコンポーネントが使えます。

各コンポーネントの使い方については既存のRDB系のコンポーネントと同様です。
つまり、RDBGetコンポーネントの付属ツールである「SQLビルダー」、RDBPutコンポーネントの付属ツールである「テーブルの選択」ツールについても同様に使えます。
また、GoogleBigQuerySQLCallコンポーネントを利用してストアドプロシジャを実行することができます。

  • GoogleBigQueryGetコンポーネントのSQLビルダー
    GoogleBigQuery_070.png

  • GoogleBigQueryPutコンポーネントのテーブルの選択
    GoogleBigQuery_080.png

 

この記事は役に立ちましたか？
0人中0人がこの記事が役に立ったと言っています

他のキーワードで検索する