我一直在尝试从我的 lambda 函数(Python3.8)查询 Athena,但尽管尝试添加 if else 语句来检查执行状态,但我不断收到相同的错误,并且在 aws 控制台和 cli 上总是出现相同的错误本地
这是 lambda 函数:
import json
import boto3
import time
def function(event, context):
client=boto3.client('athena')
#setup and perform query
queryStart=client.start_query_execution(
QueryString = 'SELECT * FROM my_s3_bucket_developer limit 8;',
QueryExecutionContext = {
'Database':'mydb'
},
ResultConfiguration = {
'OutputLocation': 's3://athena-results-queries-developer/'
}
)
#get query ID
queryId= queryStart['QueryExecutionId']
#we gonna sleep the function now because we don't know how
#long it will take to execute the query
time.sleep(25)
results=client.get_query_results(QueryExecutionId = queryId)
for row in …Run Code Online (Sandbox Code Playgroud)