S3 Select Python错误

Question

import boto3

s3 = boto3.client('s3')
r = s3.select_object_content(
    Bucket="bucket",
    Key="file.json",
    ExpressionType='SQL',
    Expression="select * from s3object S3Object AS s",
    InputSerialization = {
                            'JSON': {
                            'Type': 'LINES'
                            }
                        },
    OutputSerialization = { 'JSON': { 'RecordDelimiter': ',' } },
)


for event in r['Payload']:
    if 'Records' in event:
        records = event['Records']['Payload'].decode('utf-8')
        print(records)
    elif 'Stats' in event:
        statsDetails = event['Stats']['Details']
        print("Stats details bytesScanned: ")
        print(statsDetails['BytesScanned'])
        print("Stats details bytesProcessed: ")
        print(statsDetails['BytesProcessed'])

回溯（最近的调用是最后一次）：文件“C://users/a_urrego/pycharmprojects/dw_flighthub/s3select.py”,第48行，在OutputSerialization={'json':{'recorddelimiter':',‘}}中，文件“C:\users\a_urrego\appdata\local\programs\python\python36-32\lib\site-packages\botocore\client.py”,第314行，在_api_call返回b\site-packages\botocore\client.py“，第612行，在_make_api_call中引发error_class(parsed_response,operation_name)botocore.exceptions.clienterror:调用SelectObjectContent操作时发生错误（ParseExpectedToken）：在第1行，第33列，发现意外标记。

进程结束，退出代码为%1

Answer 1

看来您传递的SQL表达式无效：

"select * from s3object S3Object AS s"

一般的SQL语法将是

"SELECT <columns | *> FROM <table> <alias>"

但看起来您在那里重复了一个表名或其他东西。SQL语句的大小写是可选的，但我倾向于喜欢它。