PyAthenaJDBCというpythonモジュールを使用して、提供されているJDBCドライバを使用してAthenaをクエリしています。ここ はリンクです:https://pypi.python.org/pypi/PyAthenaJDBC/HIVE PyAthenaJDBC(AWS athena)の引数
接続は、クエリが同様に(ショーデータベース、ショーのテーブル、選択を...)作業している、正常に確立され しかし、私はハイブの引数などを使用して、カスタムテーブルを定義しようとしたときにそれはもう働いていない '行形式のSERDE ..' として、ここで は私のコードです:
class PyAthenaLoader():
def connecti(self):
self.conn = pyathenajdbc.connect(
access_key=access_key_id,
secret_key=secret_key_id,
region_name = "us-west-2",
s3_staging_dir="s3://aws-athena-query-results-332333536009-us-west-2")
def create(self):
try:
with self.conn.cursor() as cursor:
cursor.execute(
"""CREATE EXTERNAL TABLE IF NOT EXISTS sales4 (
Day_ID int,
Product_Id string,
Store_Id string,
Sales_Units int,
Sales_Cost float,
Currency string
)
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
WITH SERDEPROPERTIES (
'serialization.format' = '|',
'field.delim' = '|',
'collection.delimm = 'undefined',
'mapkey.delim' = 'undefined'
) LOCATION 's3://athena/';
""")
エラー:行1:8:入力の無い実行可能な代案は (サービス 'EXTERNAL CREATE':AmazonAthenaを。ステータスコード:400;エラーコード: InvalidRequestE xception;リクエストID: 0cca6f3e-fe9e-11E6-be4f-a3b28f284a77)
PS:同じクエリは、コンソール管理にうまく動作することを! 助けてください?