更改日志记录方式

LIB/FRONTEND/SignalMonitor/deploy.py

@@ -30,9 +30,9 @@ if __name__ == "__main__":
     DbSession = sessionmaker(bind=db_engine)
     
     # 日志配置
-    log = Log.Mylog(log_name='signal_monitor', log_level = 'info')
-    log.set_file_hl(file_name='info.log', log_level='info')
-    log.set_file_hl(file_name='error.log', log_level='error')
+    log = Log.Mylog(log_name='signal_monitor', log_level = 'info', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/info.log', log_level='info')
+    log.set_file_hl(file_name='log/error.log', log_level='error')
     logger = log.get_logger()
 
     logger.info("pid is + {}".format(os.getpid()))
@@ -46,6 +46,7 @@ if __name__ == "__main__":
     signalMonitor = SignalMonitor.SignalMonitor()
     cal_period = 24    # 计算间隔，单位h
     for i in range(102, len(df_sn['sn'])):    # 遍历SN号
+        
         sn = [df_sn.loc[i,'sn']]
         if not (sn[0][0:2] == 'PK' or sn[0][0:2] == 'MG' or sn[0][0:2] == 'UD'):
             continue
@@ -70,6 +71,7 @@ if __name__ == "__main__":
                             'sn', 'PackState', 'LineState', 'StartTime', 'EndTime', 'OfflineTime'])    # 初始化BMS信号统计数据
         df_res_gps = pd.DataFrame(columns=[
                                 'sn', 'PackState', 'LineState', 'StartTime', 'EndTime', 'OfflineTime', 'latitude', 'longitude'])    # 初
+        logger.info("{} {} START!".format(sn, str(st)))
         while st < et:
             try:
                 df_res, df_state, df_last_state = signalMonitor.get_bms_offline_stat(
@@ -100,5 +102,5 @@ if __name__ == "__main__":
         df_tosql.columns = ['sn', 'time_stamp', 'pack_state', 'line_state','latitude', 'longitude']
         df_tosql.to_sql("signal_monitor_gps_last_day",con=db_engine, if_exists="append",index=False)
 
-        logger.info("{} {} Success!".format(sn, str(st)))
+        logger.info("{} {} DONE!".format(sn, str(st)))
 

LIB/FRONTEND/odo/deploy.py

@@ -35,9 +35,9 @@ if __name__ == "__main__":
     DbSession = sessionmaker(bind=db_engine)
     
     # 日志配置
-    log = Log.Mylog(log_name='signal_monitor', log_level = 'info')
-    log.set_file_hl(file_name='info.log', log_level='info')
-    log.set_file_hl(file_name='error.log', log_level='error')
+    log = Log.Mylog(log_name='signal_monitor', log_level = 'info', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/info.log', log_level='info')
+    log.set_file_hl(file_name='log/error.log', log_level='error')
     logger = log.get_logger()
 
     logger.info("pid is + {}".format(os.getpid()))
@@ -80,9 +80,11 @@ if __name__ == "__main__":
             SN=SN.strip('\n')
 
             try:
+                logger.info("{}---{} START!".format(SN, str(str_date)))
                 range=GetDistInfo(SN,input_starttime,input_endtime)
                 range_df=pd.DataFrame([range])
                 drive_info_aday=pd.concat([drive_info_aday,range_df],axis=0)
+                logger.info("{}---{} DONE!".format(SN, str(str_date)))
 
             except Exception as e:
                 logger.error(traceback.format_exc)

LIB/FRONTEND/soh/deploy.py

@@ -31,9 +31,9 @@ if __name__ == "__main__":
     DbSession = sessionmaker(bind=db_engine)
     
     # 日志配置
-    log = Log.Mylog(log_name='signal_monitor', log_level = 'info')
-    log.set_file_hl(file_name='info.log', log_level='info')
-    log.set_file_hl(file_name='error.log', log_level='error')
+    log = Log.Mylog(log_name='signal_monitor', log_level = 'info', size=1024* 1024 * 100)
+    log.set_file_hl(file_name='log/info.log', log_level='info')
+    log.set_file_hl(file_name='log/error.log', log_level='error')
     logger = log.get_logger()
 
     logger.info("pid is + {}".format(os.getpid()))
@@ -50,20 +50,24 @@ if __name__ == "__main__":
 
     for sn in SNnums_6040.tolist():
         try:
+            logger.info("6040 SN: {} START!".format(sn))
             res = NCMSoh.cal_soh(sn, end_time, start_time)
             if not res.empty:
                 res.columns = ['time', 'sn', 'bms_soh', 'soh', 'soh_err']
                 res.to_sql("soh_result",con=db_engine, if_exists="append",index=False)
+            logger.info("6040 SN: {} DONE!".format(sn))
         except:
             logger.error(traceback.format_exc)
             logger.error(u"{} ：{},{} 任务运行错误".format(sn,start_time,end_time), exc_info=True)
 
     for sn in SNnums_6060.tolist():
         try:
+            logger.info("6060 SN: {} START!".format(sn))
             res = LFPSoh.cal_soh(sn, end_time, start_time)
             if not res.empty:
                 res.columns = ['time', 'sn', 'bms_soh', 'soh', 'soh_err']
                 res.to_sql("soh_result",con=db_engine, if_exists="append",index=False)
+            logger.info("6060 SN: {} DONE!".format(sn))
         except:
             logger.error(traceback.format_exc)
             logger.error(u"{} ：{},{} 任务运行错误".format(sn,start_time,end_time), exc_info=True)