Google Cloud Data Fusion でAdobe Experience Manager のデータを扱う方法：CData JDBC Driver

宮本航太
プロダクトスペシャリスト

CData JDBC ドライバを使って、Google Cloud Data fusion で Adobe Experience Manager のデータをBigQuery にETL。

Google Cloud Data Fusion は、ノーコードでデータ連携の設定が可能な言わば GCP の ETL ツール（サービス）です。たくさんのコネクタや変換・分析機能がデフォルトで用意されているため、さまざまなデータソースを色々な組み合わせで扱うことが可能なようです。また JDBC を扱うこともできるため、この記事では、CData JDBC Driver for Adobe Experience Manager のデータを使って、Adobe Experience Manager のデータデータをCloud Data Fusion でGoogle BigQuery にノーコードでパイプラインします。

Cloud Data Fusion の準備

まずはCloud Data Fusion のインスタンスを作成します。

Data Fusion のトップ画面にある「CREATE INSTANCE」からインスタンスを作成します。
作成されたインスタンス名を先ほどの画面でクリックすると以下の画面に遷移しますので、画面下部にある Service Account をコピーします。

画面上部にある追加からメンバーを追加します。メンバー名は先ほどコピーした「Service Account」に合わせてください。役割は BiqQuery へもアクセスしますので、「BigQuery 管理者」、「Cloud Data Fusion 管理者」、「Cloud Data Fusion API サービスエージェント」を付与します。

CData JDBC Driver for AdobeExperienceManager のアップロード

ここからは実際に、Data Fusion の設定をしていきます。まずは JDBC Driver をアップロードを行います。

「View Instance」をクリックして、Data Fusion の Control Center を開きます。

Control Center が表示されたら、「＋」ボタンをクリックして JDBC Driver をアップロードしていきます。
- Name：アップロードしたドライバーに設定する名前
- Class name：cdata.jdbc.adobeexperiencemanager.AdobeExperienceManagerDriver
アップロードする際の注意点として、Driver のファイル名を name-version の形式に変更してアップロードする必要があります。なお、jarファイルをダブルクリックした際に表示されているバージョンをもとに「adobeexperiencemanager-connector-java-19.0.7115.0.jar」に変更しました。

アップロードが成功するとこのような画面が表示されるので、「Create a Pipeline」をクリックします。

Adobe Experience Manager からGoogle BigQuery へのパイプラインの作成

Data Fusion のパイプライン作成

インプット元はサイドメニューの「Source」から選択します。今回は先ほどアップロードした Adobe Experience Manager のデータの JDBC Driver を使用するため、「DataBase」を選択します。アウトプット先は同じくサイドメニューより「Sink」→「BigQuery」を選択します。

「DataBase」の設定

「DataBase」のアイコンにカーソルを持ってくるとプロパティというボタンが表示されるのでクリックし、下記内容を設定します。

Label：AdobeExperienceManager
Reference Name：AdobeExperienceManager
Plugin Name：AdobeExperienceManager Driver（Driver をアップロードした際の名前）
Plugin Type：jdbc
Connection String：AdobeExperienceManager へ接続する際の JDBC URL
Import Query：インプットしたいデータを抽出するクエリ

Adobe Experience Manager（AEM）の WebDAV 経由で JCR リポジトリを公開するインスタンスに接続します。オンプレミスの AEM と AEM as a Cloud Service の両方のデプロイメントに対応しています。

接続するには、以下のプロパティを設定してください。

URL: WebDAV 対応の JCR サーバー URL。
- AEM as a Cloud Service: https://author-pXXXXX-eXXXXX.adobeaemcloud.com/crx/server
- ローカル開発: http://localhost:4502/crx/server
User: AEM のユーザー名。
Password: AEM のパスワード。

注意: テーブルは JCR リポジトリの構造に基づいて動的に生成されます。設定したユーザーが AEM リポジトリ内の必要なコンテンツパスにアクセスするための十分な権限を持っていることを確認してください。

Connection String は以下の形式です。

jdbc:adobeexperiencemanager:URL=https://author-p12345-e67890.adobeaemcloud.com/crx/server;User=admin;Password=admin;

上のキャプチャの赤枠は、Salesforce から BigQuery へアウトプットするデータの定義となります。こちらは「Import Query」のすぐ右上にある「Get Schema」をクリックすると下の画面が表示されますので、「Import Query」で入力したクエリを実行し、カラムを定義します。