根据我的经验,我发现最好使用 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'])