in lambdas/simulation/launchDeliveryFleet/index.py [0:0]
def handler(event, context):
proxy_response = {}
session = requests.Session()
session.auth = auth
response = session.request(
url=appsync_url,
method='POST',
json={'query': graphqlQuery}
)
if 'data' in response.json():
items = response.json()['data']['listDeliveryInfos']['items']
for row in items:
response = lambda_client.invoke(
FunctionName=str(pushVehicleLambda),
InvocationType='Event',
Payload=json.dumps(row)
)
logger.info(row['id'] + " StatusCode : " + str(response['ResponseMetadata']['HTTPStatusCode']))
proxy_response['statusCode']=200
proxy_response["body"] = { 'msg': 'Processed ' + str(len(items)) + ' vehicles' }
return setProxyResponse(proxy_response)