修改luj

eda/esmm/Model_pipline/to_database.py

@@ -80,7 +80,7 @@ def main():
         cur.execute(delete_str)
         con.commit()
         print("delete done")
-        engine = create_engine(str(r"mysql+mysqldb://%s:" + '%s' + "@%s:%s/%s") % (user, password, host, port, db))
+        engine = create_engine(str(r"mysql+pymysql://%s:" + '%s' + "@%s:%s/%s") % (user, password, host, port, db))
         df_all.to_sql('esmm_device_diary_queue',con=engine,if_exists='append',index=False,chunksize=8000)
     except Exception as e:
         print(e)