翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
Salesforce エンティティからの読み取り
前提条件
読み取る Salesforce sObject。または 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 で同時実行を利用するNUM_PARTITIONS
場合はPARTITION_FIELD
、追加の Spark LOWER_BOUND
オプション UPPER_BOUND
、、、 を指定できます。これらのパラメータを使用すると、元のクエリは Spark タスクで同時に実行できるサブクエリNUM_PARTITIONS
の数に分割されます。
PARTITION_FIELD
: クエリのパーティション化に使用するフィールドの名前。LOWER_BOUND
: 選択したパーティションフィールドの包括的な下限値。timestamp フィールドでは、Spark SQL クエリで使用される Spark タイムスタンプ形式を使用できます。
有効な値の例:
"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" }