Python でAdobe Experience Manager のデータを変換・出力するETL 処理を作る方法

加藤龍彦
加藤龍彦
デジタルマーケティング
CData Python Connector とpetl モジュールを使って、Adobe Experience Manager のデータを変換後にCSV ファイルに吐き出すETL 処理を実装します。

Pythonエコシステムには多くのモジュールがあり、システム構築を素早く効率的に行うことができます。本記事では、CData Python Connector for AdobeExperienceManager とpetl フレームワークを使って、Adobe Experience Manager のデータにPython から接続してデータを変換、CSV に出力するETL 変換を実装してみます。

CData Python Connector は効率的なデータ処理によりAdobe Experience Manager のデータ にPython から接続し、高いパフォーマンスを発揮します。Adobe Experience Manager にデータをクエリする際、ドライバーはフィルタリング、集計などがサポートされている場合SQL 処理を直接Adobe Experience Manager 側に行わせ、サポートされていないSQL 処理については、組み込みのSQL エンジンによりクライアント側で処理を行います(JOIN やSQL 関数など)。

必要なモジュールのインストール

pip で必要なモジュールおよびフレームワークをインストールします:

pip install petl
pip install pandas

Python でAdobe Experience Manager のデータをETL 処理するアプリを構築

モジュールとフレームワークをインストールしたら、ETL アプリケーションを組んでいきます。コードのスニペットは以下の通りです。フルコードは記事の末尾に付いています。

CData Connector を含むモジュールをインポートします。

import petl as etl
import pandas as pd
import cdata.adobeexperiencemanager as mod

接続文字列で接続を確立します。connect 関数を使って、CData Adobe Experience Manager Connector からAdobe Experience Manager への接続を行います

cnxn = mod.connect("URL=https://author-p12345-e67890.adobeaemcloud.com/crx/server;User=admin;Password=admin;")

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 リポジトリ内の必要なコンテンツパスにアクセスするための十分な権限を持っていることを確認してください。

Adobe Experience Manager をクエリするSQL 文の作成

Adobe Experience Manager にはSQL でデータアクセスが可能です。Content エンティティからのデータを読み出します。

sql = "SELECT Id, Name FROM Content WHERE Name = 'example'"

Adobe Experience Manager データのETL 処理

DataFrame に格納されたクエリ結果を使って、petl でETL(抽出・変換・ロード)パイプラインを組みます。この例では、Adobe Experience Manager のデータ を取得して、Name カラムでデータをソートして、CSV ファイルにデータをロードします。

table1 = etl.fromdb(cnxn,sql)

table2 = etl.sort(table1,'Name')

etl.tocsv(table2,'content_data.csv')

CData Python Connector for AdobeExperienceManager を使えば、データベースを扱う場合と同感覚で、Adobe Experience Manager のデータ を扱うことができ、petl のようなETL パッケージから直接データにアクセスが可能になります。

おわりに

Adobe Experience Manager Python Connector の30日の無償トライアル をぜひダウンロードして、Adobe Experience Manager のデータ への接続をPython アプリやスクリプトから簡単に作成しましょう。



フルソースコード

import petl as etl
import pandas as pd
import cdata.adobeexperiencemanager as mod

cnxn = mod.connect("URL=https://author-p12345-e67890.adobeaemcloud.com/crx/server;User=admin;Password=admin;")

sql = "SELECT Id, Name FROM Content WHERE Name = 'example'"

table1 = etl.fromdb(cnxn,sql)

table2 = etl.sort(table1,'Name')

etl.tocsv(table2,'content_data.csv')

はじめる準備はできましたか?

Adobe Experience Manager Connector の無料トライアルをダウンロードしてお試しください:

 ダウンロード

詳細:

Adobe Experience Manager Icon Adobe Experience Manager Python Connector お問い合わせ

Adobe Experience Manager へのデータ連携用のPython Connector ライブラリ。pandas、SQLAlchemy、Dash、petl などの主要なPython ツールにAdobe Experience Manager をシームレスに統合。