修改了连接远程数据库的方式

zmc

2023-10-12 ed135d79df12a2466b52dae1a82326941211dcc9

 src/write_to_minute_table.py

@@ -51,12 +51,12 @@
    fd_t_minbute(has_remove_duplicates,con)              #将指定页数数据写入数据库分钟数据表中 


engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
# 专门读取设备信息表
con_read = engine.connect()

def write(data):
    engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
    engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
    con = engine.connect()
    write_all(data,con)
    con.close()