從銷售實體讀取

必要條件

您想要讀取的銷售支援對象。您將需要物件名稱，例如Account或Case或Opportunity。

範例：

salesforce_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforce",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Account",
        "API_VERSION": "v60.0"
    }

分割查詢

您可以提供額外的 Spark 選項PARTITION_FIELD、、LOWER_BOUNDUPPER_BOUND，以及NUM_PARTITIONS如果您想要在 Spark 中使用並發功能。使用這些參數，原始查詢將被分成可以由 Spark 任務同時執行的子查詢的數NUM_PARTITIONS量。

• PARTITION_FIELD: 要用來分割查詢的欄位名稱。

• LOWER_BOUND: 所選分割區欄位的包含下限值。

  對於時間戳字段，我們接受 Spark SQL 查詢中使用的星火時間戳格式。

  有效值的例子：

  "TIMESTAMP \"1707256978123\"" 
  "TIMESTAMP ’2024-02-06 22:02:58.123 UTC'"
  "TIMESTAMP \"2018-08-08 00:00:00 Pacific/Tahiti\" 
  "TIMESTAMP \"2018-08-08 00:00:00\"" 
  "TIMESTAMP \"-123456789\" Pacific/Tahiti" 
  "TIMESTAMP \"1702600882\""

• UPPER_BOUND：所選分割區欄位的獨佔上限值。

• NUM_PARTITIONS: 分割區的數量。

範例：

salesforce_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforce",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Account",
        "API_VERSION": "v60.0",
        "PARTITION_FIELD": "SystemModstamp"
        "LOWER_BOUND": "TIMESTAMP '2021-01-01 00:00:00 Pacific/Tahiti'"
        "UPPER_BOUND": "TIMESTAMP '2023-01-10 00:00:00 Pacific/Tahiti'"
        "NUM_PARTITIONS": "10"
    }