def lambda_handler()

in lambdas/api_get_rides/index.py [0:0]

• 46 lines of code
• 3 McCabe index (conditional complexity)

def lambda_handler(event, context):
  status_code = 400
  try:
    # print("[DEBUG] Received event: " + json.dumps(event, indent=2))
    user_id = event['requestContext']['identity']['cognitoIdentityId']
    sql = '''
          SELECT
            id
            ,userId
            ,stationId
            ,stationName
            ,duration
            ,price
            ,createdDate
          FROM
            rideTransactions
          WHERE
            userId = "{}"
          ORDER BY
            createdDate DESC;
          '''.format(user_id)

    print('[INFO] Connecting...')
    conn_info = connection_info(DB_CREDS)
    conn = pymysql.connect(host=conn_info['host'], user=conn_info['username'], password=conn_info['password'], database=conn_info['dbname'], connect_timeout=30, cursorclass=pymysql.cursors.DictCursor)
    with conn.cursor() as cur:
      print('[INFO] Executing SQL: {}'.format(sql))
      cur.execute(sql)
      rows = cur.fetchall()
    conn.close()
    output = [{'id': c['id'], 'userId': c['userId'], 'stationId': c['stationId'], 'stationName': c['stationName'], 'duration': c['duration'], 'price': float(c['price']), 'createdDate': c['createdDate'].isoformat()} for c in rows]
    # print('[DEBUG] Output: {}'.format(output))
    status_code = 200

  except Exception as e:
    print('ERROR: ', e)
    output = '{}'.format(e)

  # Construct API response
  response = {
    'statusCode': 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': json.dumps(output)
  }

  print('[INFO] Query response: {}'.format(json.dumps(response)))

  return response