Salesforce マーケティングクラウド コネクタの概念
ベータ版
この機能はベータ版です。
Salesforce Marketing Cloud コネクタがどのように機能するかについて学びます。
コネクタの仕組み
Salesforce マーケティングクラウド コネクタは、サーバー間 OAuth 認証を使用してマーケティングクラウド API に接続します。Unity Catalog 接続を作成し、インジェストパイプラインを構成すると、コネクタは Salesforce マーケティング クラウドからデータを取得し、Unity Catalog の Delta テーブルに書き込みます。
コネクタは、多くのテーブルに対する増分取り込みと、その他のテーブルに対するバッチ更新の両方をサポートします。インクリメンタルサポート付きテーブルの場合、コネクタは変更を追跡し、後続のパイプライン実行時に新規または変更されたレコードのみを取得します。バッチ専用テーブルの場合、コネクタはパイプラインが更新されるたびに完全更新を実行します。
ソーススキーマ
Salesforce Marketing Cloudコネクタは、異なる種類のデータを区別するためにsource_schemaパラメーターを使用します。同じパイプライン内で、異なるソーススキーマを持つ複数のテーブルをリストできます。
次の表では、利用可能なソース スキーマの値を説明します。
ソーススキーマ | 説明 |
|---|---|
| キャンペーン、クリック、ジャーニー、その他の組み込みマーケティングクラウドオブジェクトなどのコアテーブルを取り込みます。 |
| 購読者データ、セグメント、およびリレーショナルデータを保存する標準データ拡張機能を取り込みます |
| あるビジネス ユニットから別のビジネス ユニットに共有された標準データ エクステンションを取り込む |
| Salesforce CRMからマーケティングクラウドに自動的に同期されたデータエクステンション（連絡先、リードなど）を取り込みます。 |
| Salesforceインテグレーションによって作成されたデータエクステンション（Salesforceデータイベント、Salesforceオブジェクト）を取り込みます。 |
| ビジネスユニット間で共有されるSalesforceデータエクステンションを取り込みます。 |
注 ：Databricks では、LakeFlow Connect Salesforce コネクタを使用して、Salesforce および共有 Salesforce データ拡張機能を取り込むことを推奨しています。Salesforce マーケティングクラウド コネクタは、これらのデータ拡張機能をインクリメンタルに取り込むことはできませんが、Salesforce コネクタは可能です。
データエクステンション
データエクステンションは、Salesforce マーケティングクラウド内の、サブスクライバー、セグメント、およびリレーショナルデータを保存するテーブルです。コネクタは、複数種類のデータエクステンションの取り込みをサポートします：
- 標準データ拡張機能 ：マーケティングデータを保存するためのカスタムテーブル
- 共有データ拡張機能 ：ビジネスユニット間で共有されるデータ拡張機能
- 同期されたデータエクステンション ：Salesforce CRMから自動的に同期されたテーブル
- Salesforce データ エクステンション ：Salesforce 連携によって作成されたテーブル
データ拡張機能を取り込む際、外部キー (顧客キー) を source_table 名として指定する必要があります。外部キーの代わりに表示名を使用すると、パイプラインは失敗します。
プライマリーキーと履歴追跡
ソースデータエクステンションに主キーが定義されている場合、コネクタは取り込み時にそのキーを使用します。主キーが定義されていない場合、コネクタは自動的に__databricks_idという名前の列を追加します。これはすべての列のハッシュであり、主キーとして使用されます。
__databricks_idを使用する場合、そのテーブルの履歴追跡（SCDタイプ2）はサポートされません。テーブルがSCDタイプ2モードで取り込むように構成されている場合、取り込みは失敗します。
宛先テーブルの名前付け
destination_table 名を指定しない場合、コネクタは source_schema に基づいてテーブルに自動的に名前を付けます：
ソーススキーマ | デフォルトの宛先テーブル名 |
|---|---|
| ソーステーブル名と同じ |
|
|
|
|
|
|
|
|
|
|
注： Databricksは、Delta互換性のために、データエクステンションの表示名を自動的に正規化し、スペースとハイフンをアンダースコアに置き換えます。
たとえば、表示名が src_de_c6035790 の標準データ拡張からのデータを含む出力先テーブルは、別の destination_table 名を指定しない限り、de_src_de_c6035790 という名前になります。
Databricksでは、各データ拡張機能にカスタム destination_table 名を設定することをお勧めします。default名はデータ拡張機能の表示名に基づいているため、誰かが Salesforce Marketing Cloud でデータ拡張機能の名前を変更すると、次のパイプラインの更新によって新しい名前で新しいテーブルに書き込まれます。古い名前のテーブルは宛先スキーマに残るため、同じデータが2つのテーブルに存在することになります。カスタム destination_table 名は、表示名が変更されても変更されません。
destination_table を設定しても、コネクタが行うAPI呼び出しの回数は変わりません。これは、パイプラインが更新されるたびにデータ拡張機能が完全に更新されるためです。
ビジネスユニット
マーケティング クラウド API は、子ビジネス ユニットを含む単一のビジネス ユニットのデータを返します。複数のビジネスユニットがある場合、個別の Unity Catalog 接続を作成し、それぞれに個別の API 統合パッケージを構成する必要があります。