1

我正在调用 Salesforce 批量 API 来获取数据。我正在使用 simple_salesforce 库。我想获取我的 id 等于特定值的数据,我还需要返回一些响应,因为我有一个 id 列表。我的数据如下所示:

ids_dict = [{'ID-1010': 'abc'}, {'ID-1020': 'def'}]

这是代码:

for key, value in ids_dict.items():
    desired_opp = value
    sql = sf.bulk.OpportunityLineItem.query("SELECT Name, Price FROM OpportunityLineItem where Opportunity_ID__c = '%s'" % desired_opp)
    sql_response = []
    sql_response.append(sql)

返回的是一个带有多个defID 响应的列表。对于尊重的身份,我只需要两个响应。

4

1 回答 1

1

根据我的经验,我发现最好使用 sf.query(query=SOQL) 并使用 sf.query_more(next_URL, True) 来获取其余记录

由于查询只返回 2000 条记录,您需要使用 .query_more() 来获取更多记录

来自simple-salesforce 文档

SOQL 查询通过以下方式完成:

sf.query("SELECT Id, Email FROM Contact WHERE LastName = 'Jones'")

如果由于结果特别大,Salesforce 将nextRecordsUrl添加到您的查询结果中,例如"nextRecordsUrl" : "/services/data/v26.0/query/01gD0000002HU6KIAW-2000",您可以使用ID 或完整的 URL (如果使用完整的 URL,你必须传递 'True' 作为你的第二个参数)

sf.query_more("01gD0000002HU6KIAW-2000")
sf.query_more("/services/data/v26.0/query/01gD0000002HU6KIAW-2000", True)

另外,也许您想更改您的 sql 语句以使用“in”而不是“=”来选择它可以一次等于的多个值。这样,在您请求更多记录之前,您只需向 salesforce 进行一次 API 调用。(消除多次少于 2000 条记录搜索的浪费调用)

这是一个使用这个的例子

 data = [] # list to hold all the records

 SOQL = "SELECT Name, Price FROM OpportunityLineItem where Opportunity_ID__c in ('abc', 'def')"

 results = sf.query(query=SOQL) # api call

 ## loop through the results and add the records
 for rec in results['records']:
     rec.pop('attributes', None) # remove extra data
     data.append(rec) # add the record to the list


 ## check the 'done' attrubite in the response to see if there are more records
 ## While 'done' == False (more records to fetch) get the next page of records
 while(results['done'] == False):
     ## attribute 'nextRecordsUrl' holds the url to the next page of records
     results = sf.query_more(results['nextRecordsUrl', True])

     ## repeat the loop of adding the records
     for rec in results['records']:
         rec.pop('attributes', None)
         data.append(rec)

遍历记录并使用数据

 ## loop through the records and get their attribute values
 for rec in data:
     # the attribute name will always be the same as the salesforce api name for that value
     print(rec['Name'])
     print(rec['Price'])
于 2020-04-30T06:38:48.103 回答