SQLAlchemy PostgreSQL UPSERT値の配列

Question

PostgreSQLに値の配列に対してUPSERTを実行しようとする> 9.5。

SQLALchemy docsのようにステートメントを作成しようとしましたが、1行ではなく配列に対して行う方法についての説明はありません。 insert文は適切に構築されるので、on_conflict_do_update関数を使用してそれを行うことは可能です。

stock_table = Table("stock_history", metadata, 
      Column('date', sqlalchemy.types.NVARCHAR(length=255), primary_key=True), 
      Column('product_id', sqlalchemy.types.INTEGER(), primary_key=True), 
      Column('product_sku', sqlalchemy.types.NVARCHAR(length=255)), 
      Column('on_hand_qty', sqlalchemy.dialects.postgresql.DOUBLE_PRECISION()), 
      Column('available_qty', sqlalchemy.dialects.postgresql.DOUBLE_PRECISION()), 
      Column('output_qty', sqlalchemy.dialects.postgresql.DOUBLE_PRECISION()) 
     ) 
stock_today = pandas.read_sql_query(queryStock, odoo_engine) 
insert_stmt = sqlalchemy.dialects.postgresql.insert(stock_table).values(stock_today) 
upser_stmt = insert_stmt.on_conflict_do_update(
      index_elements=['date', 'product_id'], 
      set_=stock_today.to_dict(orient='dict') 
     ) 

私は次のエラーを取得しています：

このコードを持つ

はAttributeError： 'StrSQLCompiler' オブジェクトには属性 'visit_on_conflict_do_update' 私は何

During handling of the above exception, another exception occurred: 

    Traceback (most recent call last): 
     File "pompeiiETL.py", line 15, in <module> 
     pompeiiJobs.runStockJob(dwh_engine, odoo_prod_engine) 
     File "/Users/alex/Development/DataLab/pompeii-datalab/pompeiiETL/jobs.py", line 54, in runStockJob 
     print(upser_stmt) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line 446, in __str__ 
     return str(self.compile()) 
     File "<string>", line 1, in <lambda> 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line 436, in compile 
     return self._compiler(dialect, bind=bind, **kw) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line 442, in _compiler 
     return dialect.statement_compiler(dialect, self, **kw) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/compiler.py", line 435, in __init__ 
     Compiled.__init__(self, dialect, statement, **kwargs) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/compiler.py", line 216, in __init__ 
     self.string = self.process(self.statement, **compile_kwargs) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/compiler.py", line 242, in process 
     return obj._compiler_dispatch(self, **kwargs) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/visitors.py", line 81, in _compiler_dispatch 
     return meth(self, **kw) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/compiler.py", line 2041, in visit_insert 
     insert_stmt._post_values_clause, **kw) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/compiler.py", line 242, in process 
     return obj._compiler_dispatch(self, **kwargs) 
     File "/Users/alex/Development/DataLab/ETLenv/lib/python3.6/site-packages/sqlalchemy/sql/visitors.py", line 79, in _compiler_dispatch 
     raise exc.UnsupportedCompilationError(visitor, cls) 
    sqlalchemy.exc.UnsupportedCompilationError: Compiler <sqlalchemy.sql.compiler.StrSQLCompiler object at 0x105b55be0> can't render element of type <class 'sqlalchemy.dialects.postgresql.dml.OnConflictDoUpdate'> 

を持っていません間違っていますか？ upsertをするより良い方法はありますか？

ありがとうございます！

Answer 1

あなたは私たちが

db_uri = make_url('your-postgres-db-uri-here') 
engine = create_engine(db_uri) 
upser_stmt.bind = engine 
print(upser_stmt) 

を書き、それがバインドが

insert_stmt = sqlalchemy.dialects.postgresql.insert(stock_table, 
                bind=engine).values(stock_today) 
upser_stmt = insert_stmt.on_conflict_do_update(
    index_elements=['date', 'product_id'], 
    set_=stock_today.to_dict(orient='dict') 
) 

を指定して

我々はまた、INSERT文を作成することができます動作するかどうか、何の適切なバインドを持っていないInsert -objectの文字列表現を取得しようとしています