Я экспериментирую с массовой загрузкой dataframe
в таблицу базы данных.У меня есть следующий код, который сначала записывает dataframe
в csv
, а затем копирует содержимое csv
в таблицу базы данных.Я получаю ошибку psycopg2.OperationalError: could not open file "C:\Users\test\PycharmProjects\etc\demand_override.csv" for reading: No such file or directory
Однако, когда я копирую и вставляю указанную выше директорию в проводник, открывается файл CSV!Где я делаю это неправильно?
from sqlalchemy import create_engine
import pandas as pd
import time
import os
engine = create_engine("postgresql://myapp:mypass@project.com/my_database")
schema = 'scenario_1'
df = pd.read_csv('./input/demand_override.csv')
t2 = time.time()
cwd = os.getcwd()
df.to_csv(cwd+'/'+'demand_override.csv', index=False)
copy_query = "COPY " + schema + "." + 'demand_override' + " FROM '" + cwd + '\\' + 'demand_override.csv' + "' CSV HEADER"
_connection = engine.connect()
_connection.execute(copy_query)