ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-07-26 22:51:23 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

proper approach to query paged resources (#53500)

Browse source 
* proper approach to query paged resources

* fixed pep8

* removed unnecessary check
This commit is contained in:
Zim Kalinowski 2019-03-11 15:13:41 +08:00 • committed by ansibot
commit 9413a6c3f1
1 changed files with 17 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

27
lib/ansible/modules/cloud/azure/azure_rm_resource_facts.py
View file

@ -183,18 +183,25 @@ class AzureRMResourceFacts(AzureRMModuleBase):
header_parameters = {} header_parameters = {}
header_parameters['Content-Type'] = 'application/json; charset=utf-8' header_parameters['Content-Type'] = 'application/json; charset=utf-8'
skiptoken = None
response = self.mgmt_client.query(self.url, "GET", query_parameters, header_parameters, None, [200, 404], 0, 0) while True:
if skiptoken:
try: query_parameters['skiptoken'] = skiptoken
response = json.loads(response.text) response = self.mgmt_client.query(self.url, "GET", query_parameters, header_parameters, None, [200, 404], 0, 0)
if response is list:
self.results['response'] = response
else:
self.results['response'] = [response]
except Exception:
self.results['response'] = []
try:
response = json.loads(response.text)
if isinstance(response, dict):
if response.get('value'):
self.results['response'] = self.results['response'] + response['value']
skiptoken = response.get('nextLink')
else:
self.results['response'] = self.results['response'] + [response]
except Exception:
self.results['response'] = []
if not skiptoken:
break
return self.results return self.results