def copy_markettrend_resume_db(self):
try:
conn = psycopg2.connect(
dbname="your_db",
user="your_user",
password="your_password",
host="localhost",
port="5432"
)
with conn.cursor() as cursor:
with open(self.bbo_csv, "r", encoding="utf-8") as csv_file:
next(csv_file) # 跳过header
cursor.copy_from(csv_file, "t_market_trend_hist", sep=",")
conn.commit()
except Exception as e:
self.logger.error(e)
if conn:
conn.rollback()
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。