来自Python的Athena Invalid刚需异常

Question

我试图从S3桶读取CSV文件，并通过Python在雅典娜创建表。但是我正在执行它-

DB查询的开始

{'QueryExecutionId'：'9cc82243-4220-47d0-8b63-0aa4f01fd590'，'ResponseMetadata'：{'RequestId'：'1c74bec6-663a-42ef-b9d1-73c7372eb4e10s'，'HTTPHeader20s'，'HTTPHeader内容类型'：'应用程序/x-amz-json-1.1'，'日期'：'星期四，2018 年 11 月 8 日 15:37:11 GMT'，'x-amzn-requestid'：'1c74bec6-663a-42ef- b9d1-73c7372eb4e1'，'内容长度'：'59'，'连接'：'保持活动'}，'重试尝试'：0}}

开始创建表

Traceback（最近的调用最后）：

文件"C：/用户/Doc/PycharmProjects/aws-athena-repo/athena/app.py"，第61行，在QueryExektionContext={'数据库'：'athenadb'}）

文件"C：\Program Files\Python37\lib\site-包\botocore\client.py"，第320行，_api_call返回自己。_make_api_call（operation_name，kwargs）

文件"C：\Program Files\Python37\lib\site-包\botocore\client.py"，第623行，_make_api_callerror_class（parsed_response，operation_name）

botocore.errorfactory.InvalidRequestException:调用StartQueryExecution操作时发生错误（InvalidRequestException）：第1:8行：输入“创建外部”时没有可行的替代方案

这是我的代码示例--

print("Start of DB Query")
# Create a new database
db_query = 'CREATE DATABASE IF NOT EXISTS athenadb;'
response = client.start_query_execution(
    QueryString=db_query,
    ResultConfiguration={'OutputLocation': 's3://mybucket'})
print(response)

table_query = '''
CREATE EXTERNAL TABLE IF NOT EXISTS `athenadb.testtable`(
    `id` int,
    `ident` string,
    `type` string,
    `name` string,
    `latitude_deg` double,
    `longitude_deg` double,
    `continent` string,
    `iso_country` string,
    `iso_region` string,
    `municipality` string,
    `scheduled_service` string,
    `gps_code` string,
    `iata_code` string,
    `local_code` string,
    `home_link` string,
    `wikipedia_link` string,
    `keywords` string 
)
ROW FORMAT DELIMITED 
  FIELDS TERMINATED BY ',' 
  LINES TERMINATED BY '\n' 
WITH SERDEPROPERTIES ( 
  'escape.delim'='\\')
STORED AS TEXTFILE
LOCATION 's3://mybucket/folder/' ;'''

print("Start of table creation")

response1 = client.start_query_execution(
    QueryString=table_query,
    ResultConfiguration={'OutputLocation': 's3://mybucket'},
    QueryExecutionContext={'Database': 'athenadb'})
print(response1)

我不确定是行格式分隔还是其他问题。我认为我的代码很好。

详细步骤将不胜感激！

感谢在adavace！

Answer 1

我使用所有的字段作为字符串和SERDEPROPERTIES作为OpenCSVSerde