사전 조건
-
읽으려는 Salesforce Commerce Cloud 객체. 사용 가능한 엔터티를 확인하려면 아래 지원되는 엔터티 테이블을 참조하세요.
지원되는 엔터티
| 개체 | 필터링 가능 | 제한 지원 | 정렬 기준 지원 | Select * 지원 | 분할 지원 |
|---|---|---|---|---|---|
| Assignments | 예 | 예 | 예 | 예 | 예 |
| Campaigns | 예 | 예 | 예 | 예 | 예 |
| Catalogs | 예 | 예 | 예 | 예 | 예 |
| Categories | 예 | 예 | 예 | 예 | 예 |
| Coupons | 예 | 예 | 예 | 예 | 예 |
| Gift Certificates | 예 | 예 | 예 | 예 | 예 |
| Products | 예 | 예 | 예 | 예 | 예 |
| Promotions | 예 | 예 | 예 | 예 | 예 |
| Source Code Groups | 예 | 예 | 예 | 예 | 예 |
예
salesforce_commerce_cloud_read = glueContext.create_dynamic_frame.from_options(
connection_type="SalesforceCommerceCloud",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "campaign",
"API_VERSION": "v1"
}Salesforce Commerce Cloud 엔터티 및 필드 세부 정보
엔터티 목록:
-
Assignments: https://developer.salesforce.com/docs/commerce/commerce-api/references/assignments
-
Campaigns: https://developer.salesforce.com/docs/commerce/commerce-api/references/campaigns
-
Catalogs: https://developer.salesforce.com/docs/commerce/commerce-api/references/catalogs
-
Categories: https://developer.salesforce.com/docs/commerce/commerce-api/references/catalogs?meta=searchCategories
-
Gift Certificates: https://developer.salesforce.com/docs/commerce/commerce-api/references/gift-certificates
-
Products: https://developer.salesforce.com/docs/commerce/commerce-api/references/products
-
Promotions: https://developer.salesforce.com/docs/commerce/commerce-api/references/promotions
-
Source Code Groups: https://developer.salesforce.com/docs/commerce/commerce-api/references/source-code-groups
분할 쿼리
Spark에서 동시성을 활용하려는 경우 추가 Spark 옵션(PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND, NUM_PARTITIONS)을 제공할 수 있습니다. 이러한 파라미터를 사용하면 Spark 태스크에서 동시에 실행할 수 있는 NUM_PARTITIONS개의 하위 쿼리로 원본 쿼리가 분할됩니다.
-
PARTITION_FIELD: 쿼리 분할에 사용할 필드의 이름입니다. -
LOWER_BOUND: 선택한 파티션 필드의 하한 값(경계 포함).날짜의 경우 Spark SQL 쿼리에 사용된 Spark 날짜 형식을 허용합니다. 유효한 값의 예제:
"2024-02-06". -
UPPER_BOUND: 선택한 파티션 필드의 상한 값(경계 제외). -
NUM_PARTITIONS: 파티션 수.
엔터티 수준 분할 필드 지원 세부 정보는 아래 표에 나와 있습니다.
| 개체 | 분할 필드 | 데이터 유형 |
|---|---|---|
| Campaigns | lastModified | DateTime |
| Campaigns | startDate | DateTime |
| Campaigns | endDate | DateTime |
| Catalogs | creationDate | DateTime |
| Categories | creatiionDate | DateTime |
| Gift Certificates | merchantId | String |
| Gift Certificates | creatiionDate | DateTime |
| Products | creatiionDate | DateTime |
| Products | lastModified | DateTime |
| Source Code Groups | creationDate | DateTime |
| Source Code Groups | startTime | DateTime |
| Source Code Groups | endTime | DateTime |
예
salesforceCommerceCloud_read = glueContext.create_dynamic_frame.from_options(
connection_type="SalesforceCommerceCloud",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "coupons",
"API_VERSION": "v1",
"PARTITION_FIELD": "creationDate"
"LOWER_BOUND": "2020-05-01T20:55:02.000Z"
"UPPER_BOUND": "2024-07-11T20:55:02.000Z"
"NUM_PARTITIONS": "10"
}