Google Data Fusion で Access に連携した ETL プロセスを作成

Google Data Fusion を使用すると、セルフサービス型のデータ連携を行い、異なるデータソースを統合できます。CData JDBC Driver for Access をアップロードすることで、Google Data Fusion のパイプライン内から Access のデータ にリアルタイムでアクセスできるようになります。CData JDBC Driver を使用すると、Access のデータ を Google Data Fusion でネイティブにサポートされている任意のデータソースにパイプできますが、この記事では、Access から Google BigQuery へデータをパイプする方法を説明します。

CData JDBC Driver for Access を Google Data Fusion にアップロード

CData JDBC Driver for Access を Google Data Fusion インスタンスにアップロードして、Access のデータ にリアルタイムでアクセスしましょう。Google Data Fusion では JDBC ドライバーの命名規則に制限があるため、JAR ファイルを driver-version.jar という形式に合わせてコピーまたはリネームしてください。例：cdataaccess-2020.jar

1. Google Data Fusion インスタンスを開きます
2. をクリックしてエンティティを追加し、ドライバーをアップロードします
3. "Upload driver" タブで、リネームした JAR ファイルをドラッグまたは参照します。
4. "Driver configuration" タブで以下を設定します：
   • Name: ドライバーの名前（cdata.jdbc.access）を作成し、メモしておきます
   • Class name: JDBC クラス名を設定します：（cdata.jdbc.access.AccessDriver）
   
5. "Finish" をクリックします

Google Data Fusion で Access のデータ に接続

JDBC Driver をアップロードしたら、Google Data Fusion のパイプラインで Access のデータ にリアルタイムでアクセスできます。

1. Pipeline Studio に移動して、新しいパイプラインを作成します
2. "Source" オプションから "Database" をクリックして、JDBC Driver 用のソースを追加します
3. Database ソースの "Properties" をクリックしてプロパティを編集します

   NOTE：Google Data Fusion で JDBC Driver を使用するには、ライセンス（製品版またはトライアル）とランタイムキー（RTK）が必要です。ライセンス（またはトライアル）の取得については、CData までお問い合わせください。

   • Label を設定します
   • Reference Name を将来の参照用の値に設定します（例：cdata-access）
   • Plugin Type を "jdbc" に設定します
   • Connection String を Access の JDBC URL に設定します。例：
     
     jdbc:access:RTK=5246...;DataSource=C:/MyDB.accdb;

     Access接続の設定方法

     ローカルファイルへの接続設定

     ローカル環境からAccess への接続は非常にシンプルです。ConnectionType をLocal に設定することで、CRUD 操作（SELECT、INSERT、UPDATE、DELETE）をすべて実行できます。接続にはDataSource プロパティに以下のようなAcces sデータベースファイルのフルパスを指定します。

     C:\Users\Public\Documents\MyDatabase.accdb

     詳細な接続手順については、ヘルプドキュメントの「はじめに」セクションをご参照ください。

     クラウドストレージ上のAccess ファイルへの接続設定

     各種クラウドストレージに保存されているAccess ファイルへのアクセスにも対応しています。ただし、クラウド上のファイルに対するデータ操作は、INSERT、UPDATE、DELETE に制限されますのでご注意ください。

     S3、Google Driver、OneDrive など、各種クラウドストレージ内のAccess ファイルへの接続方法はこちらの記事をご確認ください。

     クラウド上のファイルを更新したい場合は、以下の手順で実施いただけます。

     1. 対応するCData ドライバーを利用し、クラウドサービスからAccess ファイルをダウンロード
     2. Access ドライバーを使用して、ローカル環境でファイルを編集
     3. クラウドサービス用ドライバーのストアドプロシージャを使用して、更新ファイルをアップロード

     具体例として、SharePoint 上のファイルを更新する場合の手順をご紹介します。

     1. CData SharePoint ドライバーのDownloadDocument プロシージャを使用してファイルを取得
     2. CData Access ドライバーでファイルの更新を実施
     3. SharePoint ドライバーのUploadDocument プロシージャで更新内容を反映

     DataSource 接続プロパティの設定について補足いたします。接続先のクラウドストレージを識別するための一意の接頭辞を指定し、続けて目的のファイルパスまたはフォルダパスを記述します。フォルダを指定した場合は1ファイルが1テーブルとして、単一ファイルの場合は単一テーブルとして扱われます。

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

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

           java -jar cdata.jdbc.access.jar
           

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

     
   • Import Query を Access から取得したいデータを抽出する SQL クエリに設定します。例：
     SELECT * FROM Orders
   
4. "Sink" タブから、同期先シンクを追加します（この例では Google BigQuery を使用します）
5. BigQuery シンクの "Properties" をクリックしてプロパティを編集します
   • Label を設定します
   • Reference Name を access-bigquery のような値に設定します
   • Project ID を特定の Google BigQuery プロジェクト ID に設定します（またはデフォルトの "auto-detect" のままにします）
   • Dataset を特定の Google BigQuery データセットに設定します
   • Table を Access のデータ を挿入するテーブル名に設定します
   

Source と Sink を設定すると、Access のデータ を Google BigQuery にパイプする準備が整います。パイプラインを保存してデプロイしてください。パイプラインを実行すると、Google Data Fusion が Access からリアルタイムデータをリクエストし、Google BigQuery にインポートします。

これはシンプルなパイプラインの例ですが、変換、分析、条件などを使用してより複雑な Access パイプラインを作成できます。CData JDBC Driver for Access の 30日間の無償トライアルをダウンロードして、今すぐ Google Data Fusion で Access のデータ をリアルタイムで活用しましょう。