小编oma*_*rgi的帖子

(InvalidRequestException) 调用 GetQueryResults 时...从 Lambda Python 查询 Athena...无法读取结果

我一直在尝试从我的 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)

amazon-iam boto3 aws-lambda amazon-athena python-3.8

5
推荐指数
1
解决办法
1万
查看次数