本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
從銷售實體讀取
必要條件
您想要讀取的銷售支援對象。您將需要物件名稱,例如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_BOUND
UPPER_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" }