in lambdas/api_search_stations/index.py [0:0]
def lambda_handler(event, context):
# Construct the search query
query = {
'size': 1000,
'query': {
'query_string': {
'query': event['queryStringParameters']['q'],
'fields': ['name']
}
}
}
print('[INFO] Query body: {}'.format(json.dumps(query)))
# Get search result from ES
r = requests.get(es_url, auth = awsauth, headers = headers, data = json.dumps(query))
# Construct API response
response = {
'statusCode': r.status_code,
'headers': {
'Access-Control-Allow-Origin': '*',
'Access-Control-Allow-Credentials': True,
'Access-Control-Allow-Headers': 'Content-Type,X-Amz-Date,Authorization,X-Api-Key,X-Amz-Security-Token,X-Amz-User-Agent',
'Access-Control-Allow-Methods': 'GET,POST,PUT,DELETE,OPTIONS,HEAD,PATCH',
'Content-Type': 'application/json'
},
'body': r.text
}
print('[INFO] Query response: {}'.format(json.dumps(response)))
return response