cursor.copy_expert()
を使用してみてください
:
constr = "dbname='db_name' user='user' host='localhost' password='pass'"
conn = psycopg2.connect(constr)
cur = conn.cursor()
sqlstr = "COPY test_2 FROM STDIN DELIMITER ',' CSV"
with open('/tmp/tmpJopiUG/downloaded_xls.csv') as f:
cur.copy_expert(sqlstr, f)
conn.commit()
ファイルをPythonで開く必要があります そしてそれをpsycopgに渡し、psycopgはそれをpostgresのstdinに転送します。 CSV
を使用しているため COPY
への引数 、COPYステートメントを自分で渡すエキスパートバージョンを使用する必要があります。