メインコンテンツまでスキップ
に最終更新

Salesforce マーケティングクラウドからのデータ取り込み

備考

ベータ版

この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。

このページでは、LakeFlow Connect を使用して、管理された Salesforce マーケティング クラウド取り込みパイプラインを作成する方法について説明します。

要件​

  • 取り込みパイプラインを作成するには、まず、次の要件を満たす必要があります。

    • ワークスペースでUnity Catalogが有効になっている必要があります。

    • サーバレス コンピュートがワークスペースで有効になっている必要があります。サーバレス コンピュートの要件を参照してください。

    • 新しい接続を作成する予定がある場合は、メタストアに対する CREATE CONNECTION 特権が必要です。Unity Catalog での特権の管理を参照してください。

      コネクタが UI ベースのパイプライン オーサリングをサポートしている場合、管理者はこのページのステップを完了することで、接続とパイプラインを同時に作成できます。 ただし、パイプラインを作成するユーザーが API ベースのパイプライン オーサリングを使用している場合、または管理者以外のユーザーである場合、管理者はまずカタログ エクスプローラーで接続を作成する必要があります。 「管理対象取り込みソースへの接続」を参照してください。

    • 既存の接続を使用する場合：接続オブジェクトに対してUSE CONNECTIONまたはALL PRIVILEGESの権限が必要です。

    • ターゲットカタログに対するUSE CATALOG権限が必要です。

    • 既存のスキーマに対するUSE SCHEMAおよびCREATE TABLE権限、またはターゲットカタログに対するCREATE SCHEMA権限を持っている必要があります。

  • Salesforce Marketing Cloud から取り込むには、Databricks への Salesforce Marketing Cloud 取り込みのための OAuth を構成するを完了し、接続を作成する必要があります。Salesforce マーケティングクラウド接続を作成するを参照してください。

取り込みパイプラインを作成​

  1. Databricksワークスペースのサイドバーで、 データ取り込み をクリックします。
  2. **[データの追加]**ページで、**[Databricks コネクタ]**の下にある**[Salesforce マーケティング クラウド]**をクリックします。
  3. 取り込みウィザードの**[接続]**ページで、Salesforce Marketing Cloud のアクセス認証情報を格納する接続を選択します。メタストアに対する CREATE CONNECTION 権限がある場合は、「 プラスアイコン。 接続を作成 」をクリックして、Salesforce マーケティング クラウド接続の作成で認証の詳細を使用して新しい接続を作成できます。
  4. 次へ をクリックします。
  5. **インジェスト セットアップ** ページで、パイプラインの一意の名前を入力します。
  6. イベントログを書き込むカタログとスキーマを選択してください。カタログに対するUSE CATALOG権限とCREATE SCHEMA権限がある場合は、ドロップダウンメニューで プラスアイコン。 スキーマを作成 をクリックして、新しいスキーマを作成できます。
  7. パイプラインの作成および続行 をクリックします。
  8. **ソース**ページで、取り込むテーブルを選択します。
  9. 保存して続行 をクリックします。
  10. 宛先 ページで、データを取り込むカタログとスキーマを選択します。カタログに対するUSE CATALOG権限とCREATE SCHEMA権限がある場合は、ドロップダウンメニューで プラスアイコン。 スキーマを作成 をクリックして、新しいスキーマを作成できます。
  11. 保存して続行 をクリックします。
  12. (オプション) スケジュールと通知 ページで、 プラスアイコン。 スケジュールを作成 をクリックします。宛先テーブルを更新する頻度を設定します。
  13. (オプション) プラスアイコン。 通知の追加 をクリックして、パイプライン操作の成功または失敗に関するEメール通知を設定し、次に パイプラインを保存して実行 をクリックします。

例​

これらの例を使用してパイプラインを構成してください。

デフォルトのスキーマからすべてのテーブルを取り込む​

次のパイプライン定義ファイルは、default スキーマから現在および将来のすべてのテーブルを取り込みます：

YAML
variables:
  dest_catalog:
    default: main
  dest_schema:
    default: ingest_destination_schema

resources:
  pipelines:
    pipeline_sfmc:
      name: sfmc_pipeline
      catalog: ${var.dest_catalog}
      schema: ${var.dest_schema}
      ingestion_definition:
        connection_name: <sfmc-connection>
        objects:
          # Ingest all tables from the default schema
          - schema:
              source_schema: default
              destination_catalog: ${var.dest_catalog}
              destination_schema: ${var.dest_schema}

単一のソーステーブルを取り込む​

以下のパイプライン定義ファイルは、defaultスキーマから単一のテーブルを取り込みます。

YAML
variables:
  dest_catalog:
    default: main
  dest_schema:
    default: ingest_destination_schema

resources:
  pipelines:
    pipeline_sfmc:
      name: sfmc_pipeline
      catalog: ${var.dest_catalog}
      schema: ${var.dest_schema}
      ingestion_definition:
        connection_name: <sfmc-connection>
        objects:
          # Ingest the campaigns table from the default schema
          - table:
              source_schema: default
              source_table: campaigns
              destination_catalog: ${var.dest_catalog}
              destination_schema: ${var.dest_schema}

データエクステンションの取り込み​

データエクステンションからデータを取り込むには、source_tableの値として外部キーを使用してください。ソーススキーマタイプの詳細については、Salesforce Marketing Cloudコネクタのコンセプトを参照してください。

以下のパイプライン定義ファイルは、データ拡張機能を取り込みます。

YAML
variables:
  dest_catalog:
    default: main
  dest_schema:
    default: ingest_destination_schema

resources:
  pipelines:
    pipeline_sfmc:
      name: sfmc_pipeline
      catalog: ${var.dest_catalog}
      schema: ${var.dest_schema}
      ingestion_definition:
        connection_name: <sfmc-connection>
        objects:
          # Ingest a data extension using its External Key (Customer Key)
          - table:
              source_schema: dataextensions
              source_table: <external-key>
              destination_catalog: ${var.dest_catalog}
              destination_schema: ${var.dest_schema}

宣言型オートメーションバンドル ジョブ定義ファイル​

以下は、Declarative Automation Bundles で使用するジョブ定義ファイルの例です。ジョブは毎日、前回の実行からちょうど1日後に実行されます。

YAML
resources:
  jobs:
    sfmc_dab_job:
      name: sfmc_dab_job

      trigger:
        periodic:
          interval: 1
          unit: DAYS

      email_notifications:
        on_failure:
          - <email-address>

      tasks:
        - task_key: refresh_pipeline
          pipeline_task:
            pipeline_id: ${resources.pipelines.pipeline_sfmc.id}

一般的なパターン​

高度なパイプライン構成については、「マネージド取り込みパイプラインの一般的なパターン」を参照してください。

次のステップ​

パイプラインの開始、スケジュール、アラートを設定する共通パイプラインメンテナンス タスクを参照してください。

その他のリソース​

このページの見出し