Salesforce Marketing Cloud Account Engagement 엔터티에서 읽기 - AWS Glue
쿼리 파티셔닝

Salesforce Marketing Cloud Account Engagement 엔터티에서 읽기

사전 조건

읽으려는 Salesforce Marketing Cloud Account Engagement 객체. 객체 이름이 필요합니다.

소스에 대해 지원되는 엔터티:

개체 필터링 가능 제한 지원 정렬 기준 지원 Select * 지원 분할 지원
Campaign 예 예 예 예 예
동적 콘텐츠 예 예 예 예 예
이메일 예 예 예 예 예
이메일 템플릿 예 예 예 예 예
참여 스튜디오 프로그램 예 예 예 예 예
폴더 콘텐츠 예 예 예 예 예
랜딩 페이지 예 예 예 예 예
수명 주기 기록 예 예 예 예 예
수명 주기 단계 예 예 예 예 예
나열 예 예 예 예 예
이메일 나열 예 예 예 예 예
멤버쉽 나열 예 예 예 예 예
기회 예 예 예 예 예
잠재 고객 예 예 예 예 예
잠재 고객 계정 예 예 예 예 예
User 예 예 예 예 예

예제:

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

커넥터에 대한 다음 고려 사항에 유의합니다.

  • 엔터티에서 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"
    }
   )