Salesforce Marketing Cloud Account Engagement エンティティからの読み取り - AWS Glue
パーティショニングクエリ

Salesforce Marketing Cloud Account Engagement エンティティからの読み取り

前提条件

読み取り元の Salesforce Marketing Cloud Account Engagement オブジェクト。オブジェクト名が必要になります。

Sync ソースに対応するエンティティ:

エンティティ フィルタリング可能 制限をサポートする Order By をサポートする Select * をサポートする パーティション分割をサポートする
キャンペーン はい あり あり あり あり
動的コンテンツ はい あり あり あり あり
E メール はい あり あり あり あり
Email Template はい あり あり あり あり
Engagement Studio Program はい あり あり あり あり
Folder Contents はい あり あり あり あり
Landing Page はい あり あり あり あり
Lifecycle History はい あり あり あり あり
Lifecycle Stage はい あり あり あり あり
リスト はい あり あり あり あり
List Email はい あり あり あり あり
List Membership はい あり あり あり あり
機会 はい あり あり あり あり
Prospect はい あり あり あり あり
Prospect Account はい あり あり あり あり
ユーザー はい あり あり あり あり

例:

salesforcepardot_read = glueContext.create_dynamic_frame.from_options(
    connection_type="SalesforcePardot",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v5"
    }
   )

Async ソースに対応するエンティティ:

エンティティ フィルタリング可能 制限をサポートする Order By をサポートする Select * をサポートする パーティション分割をサポートする
キャンペーン あり なし なし あり なし
動的コンテンツ あり なし なし あり なし
Email Template あり なし なし あり なし
Landing Page あり なし なし あり なし
Lifecycle History あり なし なし あり なし
Lifecycle Stage あり なし なし あり なし
リスト あり なし なし あり なし
List Email あり なし なし あり なし
List Membership あり なし なし あり なし
機会 あり なし なし あり なし
Prospect あり なし なし あり なし
Prospect Account あり なし なし あり なし
ユーザー あり なし なし あり なし

例:

salesforcepardot_read = glueContext.create_dynamic_frame.from_options(
    connection_type="SalesforcePardot",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v5",
        "TRANSFER_MODE": "ASYNC"
    }
   )

Salesforce Marketing Cloud Account Engagement エンティティとフィールドの詳細:

次のエンティティのフィールドの詳細を表示するには、Salesforce Marketing Cloud Account Engagement API に移動し、[ガイド] を選択し、[オープンソース API ラッパー] まで下にスクロールし、メニューから [バージョン 5 ドキュメント] を展開してエンティティを選択します。

エンティティリスト:

  • キャンペーン

  • 動的コンテンツ

  • E メール

  • Email Template

  • Engagement Studio Program

  • Folder Content

  • Landing Page

  • Lifecycle History

  • Lifecycle Stage

  • リスト

  • List Email

  • List Membership

  • 機会

  • Prospect

  • Prospect Account

  • ユーザー

上記のフィールドに加えて、Async モードは、以下の表に示すように、各エンティティの特定のフィルタリング可能なフィールドをサポートします。

エンティティ Async でサポートされている追加のフィルタリング可能なフィールド
キャンペーン createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
動的コンテンツ createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
Email Template createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
Engagement Studio Program -
Landing Page createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
Lifecycle History createdAfter, createdBefore
Lifecycle Stage createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
リスト createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
List Email createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
List Membership createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
機会 createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
Prospect createdAfter, createdBefore, deleted, updatedAfter, updatedBefore
Prospect Account createdAfter, createdBefore, deleted
ユーザー createdAfter, createdBefore, deleted, updatedAfter, updatedBefore

追加フィールドの詳細については、「Salesforce Export API」を参照してください

コネクタに関する以下の考慮事項に注意してください:

  • エンティティの deleteフィールドの値は、false (デフォルト)、true、または all です。

パーティショニングクエリ

フィルターベースのパーティション分割:

Spark で同時実行を使用する場合は、追加の Spark オプション PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND、および NUM_PARTITIONS を指定できます。これらのパラメータを使用すると、元のクエリは Spark タスクで同時に実行できるサブクエリの NUM_PARTITIONS の数に分割されます。

  • PARTITION_FIELD: クエリのパーティション化に使用するフィールドの名前。

  • LOWER_BOUND: 選択したパーティションフィールドの包括的な下限値。

    Datetime フィールドでは、SPark SQL クエリで使用される Spark タイムスタンプ形式を受け入れます。

    有効な値の例は次のとおりです:

    "2022-01-01T01:01:01.000Z"

  • UPPER_BOUND: 選択したパーティションフィールドの排他的上限値。

  • NUM_PARTITIONS: パーティション数。

  • PARTITION_BY: 実行されるパーティション分割のタイプ。フィールドベースのパーティショニングの場合、「FIELD」が渡されます。

例:

salesforcepardot_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcepardot",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v5",
        "PARTITION_FIELD": "createdAt"
        "LOWER_BOUND": "2022-01-01T01:01:01.000Z"
        "UPPER_BOUND": "2024-01-01T01:01:01.000Z"
        "NUM_PARTITIONS": "10",
        "PARTITION_BY": "FIELD"
    }
   )