Zoho CRM エンティティからの読み取り - AWS Glue
パーティショニングクエリ

Zoho CRM エンティティからの読み取り

前提条件

読み取り元の Zoho CRM オブジェクト。オブジェクト名が必要になります。

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

エンティティ フィルタリング可能 制限をサポートする Order By をサポートする Select * をサポートする パーティション分割をサポートする
製品 はい あり あり あり はい
Quote はい あり あり あり はい
発注書 はい あり あり あり はい
ソリューション はい あり あり あり はい
電話 はい あり あり あり はい
タスク はい あり あり あり はい
イベント はい あり あり あり はい
Invoice はい あり あり あり はい
アカウント はい あり あり あり はい
連絡先 はい あり あり あり はい
Vendor はい あり あり あり はい
キャンペーン はい あり あり あり はい
Deal はい あり あり あり はい
リード はい あり あり あり はい
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/"
    }

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

エンティティ フィルタリング可能 制限をサポートする Order By をサポートする Select * をサポートする パーティション分割をサポートする
製品 はい いいえ いいえ あり いいえ
Quote はい いいえ いいえ あり いいえ
発注書 はい いいえ いいえ あり いいえ
ソリューション はい いいえ いいえ あり いいえ
電話 はい いいえ いいえ あり いいえ
タスク はい いいえ いいえ あり いいえ
イベント はい いいえ いいえ あり いいえ
Invoice はい いいえ いいえ あり いいえ
アカウント はい いいえ いいえ あり いいえ
問い合わせ はい いいえ いいえ あり いいえ
Vendor はい いいえ いいえ あり いいえ
キャンペーン はい いいえ いいえ あり いいえ
Deal はい いいえ いいえ あり いいえ
リード はい いいえ いいえ あり いいえ
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 エンティティ (すべてのエンティティ) 整数 !=, =, <, <=, >, >=, BETWEEN
String Like, =, !=
BigInteger !=, =, <, <=, >, >=, BETWEEN
ブール値 =
倍精度 !=, =, <, <=, >, >=, BETWEEN
BigDecimal !=, =, <, <=, >, >=, BETWEEN
日付 !=, =, <, <=, >, >=, BETWEEN
DateTime !=, =, <, <=, >, >=, BETWEEN
Struct 該当なし
リスト 該当なし

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

パーティショニングは Async モードではサポートされていません。

フィルターベースのパーティショニング (Sync モード):

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"
    }