关闭数据库连接

LIB/FRONTEND/CellStateEstimation/BatSafetyAlarm/deploy.py

@@ -44,7 +44,8 @@ def diag_cal(df_sn, df_diag_ram, df_bms_ram, log_name):
             user2, parse.quote_plus(password2), host2, port2, db2
         ))
     
-
+    conn = pymysql.connect(host=host2, port=port2, user=user2, password=password2, database=db2)
+    cursor = conn.cursor()
     
     start=time.time()
     now_time=datetime.datetime.now()
@@ -108,8 +109,7 @@ def diag_cal(df_sn, df_diag_ram, df_bms_ram, log_name):
                     df_bms_ram_sn.iloc[-1]['end_time']=now_time
                     
                     try:
-                        conn = pymysql.connect(host=host2, port=port2, user=user2, password=password2, database=db2)
-                        cursor = conn.cursor()
+
         
                         cursor.execute('''
                                     update all_fault_info set end_time={} where product_id='{}' and code={} and factory='骑享'
@@ -123,6 +123,9 @@ def diag_cal(df_sn, df_diag_ram, df_bms_ram, log_name):
         except:
             logger.error(traceback.format_exc)
             logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
+    cursor.close()
+    conn.close()
+    db_res_engine.dispose()
     logger.info("pid-{} Done!".format(os.getpid()))
 
 #...................................................主进程...........................................................................................................
@@ -143,6 +146,7 @@ def mainprocess():
     res = cursor.fetchall()
     df_sn = pd.DataFrame(res, columns=['sn', 'imei', 'add_time'])
     df_sn = df_sn.reset_index(drop=True)
+    cursor.close()
     conn.close();
     process = 2
     pool = multiprocessing.Pool(processes = process)

LIB/FRONTEND/SaftyCenter/DataDiag_Static/deploy.py

@@ -152,7 +152,8 @@ def diag_cal():
             logger.error(traceback.format_exc)
             logger.error(str(e))
             logger.error(u"{} ：{},{} 任务运行错误\n".format(sn,start_time,end_time), exc_info=True)
-            
+    DBReadOpe.close()
+    DBRead.close()   
     cursor_platform.close()
     conn_platform.close()
     db_engine.dispose()