работает без ошибок. Но не загружает данные. Аналогичный код для выгрузки работает, все ок. Коннекты к БД и ssh тоже ок. Подскажите пжл что не так, может БД не понимает команды библиотеки psycopg2 ?
data.copy() #dataframe который надо залить в table
#загрузка данных в PostgreSQL
with SSHTunnelForwarder(#параметры) as tunnel:
print('pass')
conn = psycopg2.connect(host, user, password, database,port)
cur = conn.cursor()
#очистка данных
cur.execute('''TRUNCATE ONLY public.table;''')
df_columns = list(data)
columns = ",".join(data.columns)
values = "VALUES({})".format(",".join(["%s" for _ in data.columns]))
insert = '''INSERT INTO table ({}) {};'''.format(columns, values)
#загрузка данных
psycopg2.extras.execute_batch(cur, insert, data.values)
print("Данные загружены")
cur.close()
Коммита не хватает может?
cur.commit() в предпоследней в перед print данные загружены
Действительно, спасибо!
Обсуждают сегодня