def lambda_handler()

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