Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Prerequisito
Un Salesforce da sObject cui vorresti leggere. Avrai bisogno del nome dell'oggetto, ad esempio Account
o oCase
. Opportunity
Esempio:
salesforce_read = glueContext.create_dynamic_frame.from_options(
connection_type="salesforce",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "Account",
"API_VERSION": "v60.0"
}
Interrogazioni di partizionamento
Puoi fornire le opzioni Spark aggiuntive ePARTITION_FIELD
, NUM_PARTITIONS
se desideri LOWER_BOUND
UPPER_BOUND
, utilizzare la concorrenza in Spark. Con questi parametri, la query originale verrebbe suddivisa in un NUM_PARTITIONS
numero di sottoquery che possono essere eseguite contemporaneamente dalle attività Spark.
PARTITION_FIELD
: il nome del campo da utilizzare per partizionare la query.LOWER_BOUND
: un valore limite inferiore inclusivo del campo di partizione scelto.Per i campi Data o Timestamp, il connettore accetta il formato di timestamp Spark utilizzato nelle query Spark. SQL
Esempi di valori validi:
"TIMESTAMP \"1707256978123\"" "TIMESTAMP '2018-01-01 00:00:00.000 UTC'" "TIMESTAMP \"2018-01-01 00:00:00 Pacific/Tahiti\"" "TIMESTAMP \"2018-01-01 00:00:00\"" "TIMESTAMP \"-123456789\" Pacific/Tahiti" "TIMESTAMP \"1702600882\""
UPPER_BOUND
: un valore limite superiore esclusivo del campo di partizione scelto.NUM_PARTITIONS
: il numero di partizioni.
Esempio:
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"
}