2017-03-15 16 views
0

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:同じクエリは、コンソール管理にうまく動作することを! 助けてください?

答えて

1

クエリが不正です。

それは、このラインによるものです:それはdelimm後にクローズ引用符が欠落している

'collection.delimm = 'undefined', 

関連する問題