Salesforce Marketing のデータでDashのWebアプリを作る方法|CData Connect AI + Python
CData Connect AI の Python SDK(DB-API 2.0準拠)を使うと、pandas と Dash でリアルタイムのSalesforce Marketing のデータを可視化する Web アプリを、個別ドライバー不要で構築できます。接続・モジュールインストール・アプリ構築の3ステップで、約10分で完成します。
Python は豊富なモジュールのエコシステムを備えているため、素早く作業に取りかかり、システムをより効果的に連携できます。CData Connect AI Python SDK、pandas モジュール、そして Dash フレームワークを使えば、Salesforce Marketing のデータを扱う Salesforce Marketing 連携の Web アプリケーションを構築できます。この記事では、Connect AI に接続し、pandas と Dash を使ってSalesforce Marketing のデータを可視化するシンプルな Web アプリを構築する方法をご紹介します。
Connect AI Python SDK(cdata-connect-ai)は DB-API 2.0(PEP 249)に準拠したクライアントなので、pandas は SDK の接続オブジェクトから直接クエリ結果を読み取れます。ソースごとにドライバーをインストールする必要はありません。パーソナルアクセストークンで接続して、アプリを構築しましょう。
Python + pandas + Dash でできること
Salesforce Marketing データの可視化ダッシュボード作成
SQL クエリで取得した Salesforce Marketing のレコードを pandas の DataFrame に読み込み、Dash のグラフコンポーネントに渡すだけで、業種別の傾向などを視覚的に確認できるダッシュボードを構築できます。
リアルタイムデータの自動更新レポート
Connect AI 経由の接続はパーソナルアクセストークンで認証されるため、スケジュール実行するスクリプトに組み込めば、Salesforce Marketing の最新データを反映したレポートを定期的に生成できます。
複数データソースとの統合分析
DB-API 2.0 準拠のクライアントなので、同じコードパターンで Salesforce Marketing 以外のデータソースにも接続でき、pandas 上で結合・集計してから Dash で一元的に可視化できます。
Connect AI で Salesforce Marketing に接続する方法は?
CData Connect AI では、直感的なクリック操作ベースのインターフェースでデータソースに接続できます。
- Connect AI にログインし、Sources をクリックして、 Add Connection をクリックします
- 「Add Connection」パネルから「Salesforce Marketing」を選択します
-
Salesforce Marketing に接続するために必要な認証プロパティを入力します。
Salesforce Marketing Cloud API への認証
User およびPassword をログインクレデンシャルに設定するか、sandbox アカウントに接続する場合はsandbox ユーザーのクレデンシャルに設定します。
Salesforce Marketing Cloud API への接続
デフォルトでは、CData 製品は本番環境に接続します。Salesforce Marketing Cloud sandbox アカウントを使用するには、UseSandbox をtrue に設定します。
デフォルトのインスタンスは、Web Services API s7 です。他のインスタンスを使用する場合は、Instance を設定できます。
- 「Save & Test」をクリックします
- 「Permissions」タブに移動し、ユーザーベースの権限を更新します。

パーソナルアクセストークン(PAT)を生成する
Python SDK は、アカウントのメールアドレスとパーソナルアクセストークン(PAT)を使って Connect AI に認証します。アクセスの粒度を保つために、アプリケーションごとに個別の PAT を作成することをおすすめします。
- Connect AI アプリの右上にある歯車アイコン()をクリックして、設定ページを開きます。
- 設定ページの Access Tokens セクションに移動し、 Create PAT をクリックします。
- PAT に名前を付けて Create をクリックします。

- パーソナルアクセストークンは作成時にのみ表示されます。必ずコピーして安全な場所に保管してください。
必要なモジュールをインストールする
pip ユーティリティを使って、SDK(pandas エクストラ付き)、Dash、Plotly をインストールします。
pip install "cdata-connect-ai[full]" pip install dash pip install plotly
Python で Salesforce Marketing のデータの Web アプリを構築する
必要なモジュールをインストールしたら、Web アプリを構築する準備は完了です。以下にコードスニペットを紹介しますが、完全なソースコードは記事の末尾に掲載しています。
まずモジュールをインポートし、アカウントのメールアドレスと PAT で Connect AI に接続して、Salesforce Marketing のデータを DataFrame に読み込みます。識別子は <Connection>.<Schema>.<Table> という3つの部分で構成されており、接続名はデフォルトでソース名(例:SFMarketingCloud1)になります。
import dash
from dash import dcc, html
import pandas as pd
import plotly.graph_objs as go
import cdata_connect_ai
conn = cdata_connect_ai.connect(
username="[email protected]",
password="<your_pat>",
)
df = pd.read_sql(
"SELECT Id, Status "
"FROM [SFMarketingCloud1].[SFMarketingCloud].[Subscriber] "
"WHERE EmailAddress = '[email protected]'",
conn,
)
conn.close()
アプリとレイアウトを設定する
クエリ結果を DataFrame に格納したら、Salesforce Marketing のデータから棒グラフを作成し、アプリのレイアウトを設定します。
app = dash.Dash(__name__)
app.title = 'CData Connect AI + Dash'
trace = go.Bar(x=df['Id'], y=df['Status'], name='Id')
app.layout = html.Div(
children=[
html.H1("CData Connect AI + Dash", style={'textAlign': 'center'}),
dcc.Graph(
id='example-graph',
figure={
'data': [trace],
'layout': go.Layout(title='Salesforce Marketing Subscriber Data', barmode='stack'),
},
),
],
className="container",
)
アプリを実行できるようにする
接続、アプリ、レイアウトの設定が完了したら、アプリを実行する準備は整いました。
if __name__ == '__main__':
app.run(debug=True)
それでは、Python で Web アプリを実行し、ブラウザでSalesforce Marketing のデータを確認してみましょう。
python sfmarketingcloud-dash.py
関連情報と無料トライアル
これで、CData Connect AI Python SDK を使って、リアルタイムのSalesforce Marketing のデータでインタラクティブな Dash の Web アプリを構築できるようになりました。Salesforce Marketing(および数百種類のその他のデータソース)への接続について詳しくは、Connect AI のページをご覧ください。
CData Connect AI の詳細、または無料トライアルにお申し込みください:
完全なソースコード
import dash
from dash import dcc, html
import pandas as pd
import plotly.graph_objs as go
import cdata_connect_ai
conn = cdata_connect_ai.connect(
username="[email protected]",
password="<your_pat>",
)
df = pd.read_sql(
"SELECT Id, Status "
"FROM [SFMarketingCloud1].[SFMarketingCloud].[Subscriber] "
"WHERE EmailAddress = '[email protected]'",
conn,
)
conn.close()
app = dash.Dash(__name__)
app.title = 'CData Connect AI + Dash'
trace = go.Bar(x=df['Id'], y=df['Status'], name='Id')
app.layout = html.Div(
children=[
html.H1("CData Connect AI + Dash", style={'textAlign': 'center'}),
dcc.Graph(
id='example-graph',
figure={
'data': [trace],
'layout': go.Layout(title='Salesforce Marketing Subscriber Data', barmode='stack'),
},
),
],
className="container",
)
if __name__ == '__main__':
app.run(debug=True)