Zoho CRM 엔터티에서 읽기 - AWS Glue
분할 쿼리

Zoho CRM 엔터티에서 읽기

사전 조건

읽으려는 Zoho CRM 객체입니다. 객체 이름이 필요합니다.

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

개체 필터링 가능 제한 지원 정렬 기준 지원 Select * 지원 분할 지원
Product 예 예 예 예 예
Quote 예 예 예 예 예
Purchase Order 예 예 예 예 예
Solution 예 예 예 예 예
Call 예 예 예 예 예
Task 예 예 예 예 예
Event 예 예 예 예 예
Invoice 예 예 예 예 예
Account 예 예 예 예 예
Contact 예 예 예 예 예
Vendor 예 예 예 예 예
캠페인 예 예 예 예 예
Deal 예 예 예 예 예
Lead 예 예 예 예 예
Custom Module 예 예 예 예 예
Sales Order 예 예 예 예 예
Price Books 예 예 예 예 예
사례 예 예 예 예 예

예시:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="ZOHO",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "INSTANCE_URL": "https://www.zohoapis.in/"
    }

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

개체 필터링 가능 제한 지원 정렬 기준 지원 Select * 지원 분할 지원
Product 예 아니요 아니요 예 아니요
Quote 예 아니요 아니요 예 아니요
Purchase Order 예 아니요 아니요 예 아니요
Solution 예 아니요 아니요 예 아니요
Call 예 아니요 아니요 예 아니요
Task 예 아니요 아니요 예 아니요
Event 예 아니요 아니요 예 아니요
Invoice 예 아니요 아니요 예 아니요
Account 예 아니요 아니요 예 아니요
Contact 예 아니요 아니요 예 아니요
Vendor 예 아니요 아니요 예 아니요
캠페인 예 아니요 아니요 예 아니요
Deal 예 아니요 아니요 예 아니요
Lead 예 아니요 아니요 예 아니요
Custom Module 예 아니요 아니요 예 아니요
Sales Order 예 아니요 아니요 예 아니요
Price Books 예 아니요 아니요 예 아니요
사례 예 아니요 아니요 예 아니요

예시:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="ZOHO",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "INSTANCE_URL": "https://www.zohoapis.in/",
        "TRANSFER_MODE": "ASYNC"
    }

Zoho CRM 필드 세부 정보:

Zoho CRM에서는 지원되는 엔터티에 대해 메타데이터를 동적으로 가져오도록 엔드포인트를 제공합니다. 따라서 운영자 지원은 데이터 유형 수준에서 캡처됩니다.

개체 데이터 유형 지원되는 연산자
Zoho 엔터티(모든 엔터티) Integer !=, =, <, <=, >, >=, BETWEEN
String Like, =, !=
BigInteger !=, =, <, <=, >, >=, BETWEEN
Boolean =
배정밀도 실수 !=, =, <, <=, >, >=, BETWEEN
BigDecimal !=, =, <, <=, >, >=, BETWEEN
날짜 !=, =, <, <=, >, >=, BETWEEN
DateTime !=, =, <, <=, >, >=, BETWEEN
Struct N/A
나열 N/A

분할 쿼리

파티셔닝은 비동기 모드에서 지원되지 않습니다.

필터 기반 파티셔닝(동기 모드):

Spark에서 동시성을 활용하려는 경우 추가 Spark 옵션(PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND, NUM_PARTITIONS)을 제공할 수 있습니다. 이러한 파라미터를 사용하면 Spark 작업에서 동시에 실행할 수 있는 NUM_PARTITIONS개의 하위 쿼리로 원래 쿼리가 분할됩니다.

  • PARTITION_FIELD: 쿼리 분할에 사용할 필드의 이름입니다.

  • LOWER_BOUND: 선택한 파티션 필드의 하한 값(경계 포함).

    Datetime 필드의 경우 Spark SQL 쿼리에 사용된 Spark 타임스탬프 형식을 허용합니다.

    유효한 값의 예제:

    "2024-09-30T01:01:01.000Z"

  • UPPER_BOUND: 선택한 파티션 필드의 상한 값(경계 제외).

  • NUM_PARTITIONS: 파티션 수.

예시:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="zohocrm",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "PARTITION_FIELD": "Created_Time"
        "LOWER_BOUND": "2022-01-01T01:01:01.000Z"
        "UPPER_BOUND": "2024-01-01T01:01:01.000Z"
        "NUM_PARTITIONS": "10"
    }