|
|
@@ -107,8 +107,12 @@ if __name__ == "__main__":
|
|
|
except:
|
|
|
logger.error(traceback.format_exc)
|
|
|
logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
|
|
|
- if not df_result.empty:
|
|
|
- df_result.columns = ['factory', 'time', 'charge_count', 'drive_count', 'stand_count']
|
|
|
- df_result.to_sql("period_status_statistic",con=db_res_engine, if_exists="append",index=False)
|
|
|
- logger.info("数据库写入成功!")
|
|
|
+ try:
|
|
|
+ if not df_result.empty:
|
|
|
+ df_result.columns = ['factory', 'time', 'charge_count', 'drive_count', 'stand_count']
|
|
|
+ df_result.to_sql("period_status_statistic",con=db_res_engine, if_exists="append",index=False)
|
|
|
+ logger.info("数据库写入成功!")
|
|
|
+ finally:
|
|
|
+ db_res_engine.dispose()
|
|
|
+ db_engine.dispose()
|
|
|
|
