54 lines
1.1 KiB
Python
54 lines
1.1 KiB
Python
import requests
|
|
|
|
import secrets
|
|
|
|
s = requests.Session()
|
|
s.auth = (secrets.username, secrets.app_password)
|
|
|
|
|
|
def get_changeactivities(query: list[str], fields: list[str]) -> dict:
|
|
|
|
incomplete_result = True
|
|
results = []
|
|
page_number = 0
|
|
|
|
parameters = dict(
|
|
query = ';'.join(query),
|
|
fields = ','.join(fields),
|
|
pageSize = 5000
|
|
)
|
|
|
|
while incomplete_result:
|
|
r = s.get(f"{secrets.url}/operatorChangeActivities", params={**parameters, **dict(pageStart=page_number)})
|
|
|
|
page_number += 1
|
|
|
|
results.extend(r.json().get('results'))
|
|
|
|
incomplete_result = r.status_code == 206
|
|
|
|
return results
|
|
|
|
|
|
def get_incidenten(query: list[str], fields: list[str]) -> dict:
|
|
|
|
incomplete_result = True
|
|
results = []
|
|
page_number = 0
|
|
|
|
parameters = dict(
|
|
query = ';'.join(query),
|
|
fields = ','.join(fields),
|
|
pageSize = 5000
|
|
)
|
|
|
|
while incomplete_result:
|
|
r = s.get(f"{secrets.url}/incidents", params={**parameters, **dict(pageStart=page_number)})
|
|
|
|
page_number += 1
|
|
|
|
results.extend(r.json())
|
|
|
|
incomplete_result = r.status_code == 206
|
|
|
|
return results |