def athenaQuery()

in source/create-athena-views-lambda.py [0:0]

• 17 lines of code
• 1 McCabe index (conditional complexity)

def athenaQuery(athenaDb,outputLocation,queryString,workGroupName):
    logger.info('Variables passed to athenaQuery(): ' + athenaDb+','+outputLocation+','+queryString)
    startQueryResponse = athenaClient.start_query_execution(
        QueryString=queryString,
        QueryExecutionContext={
            'Database': athenaDb
        },
        ResultConfiguration={
            'OutputLocation': outputLocation,
            'EncryptionConfiguration': {
                        'EncryptionOption': 'SSE_S3'
                    }            
        },
        WorkGroup=workGroupName
    )
    logger.info("startQueryResponse= " +json.dumps(startQueryResponse))
    return