|
@@ -27,9 +27,12 @@ if __name__ == "__main__":
|
|
|
DbSession = sessionmaker(bind=db_engine)
|
|
|
|
|
|
# 日志配置
|
|
|
+ now_str = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())[0:10]
|
|
|
+ if not os.path.exists('log/' + now_str):
|
|
|
+ os.makedirs('log/' + now_str)
|
|
|
log = Log.Mylog(log_name='signal_monitor', log_level = 'info')
|
|
|
- log.set_file_hl(file_name='log/info.log', log_level='info', size=1024* 1024 * 100)
|
|
|
- log.set_file_hl(file_name='log/error.log', log_level='error', size=1024* 1024 * 100)
|
|
|
+ log.set_file_hl(file_name='log/{}/info.log'.format(now_str), log_level='info', size=1024* 1024 * 100)
|
|
|
+ log.set_file_hl(file_name='log/{}/error.log'.format(now_str), log_level='error', size=1024* 1024 * 100)
|
|
|
logger = log.get_logger()
|
|
|
|
|
|
logger.info("pid is + {}".format(os.getpid()))
|
|
@@ -42,7 +45,7 @@ if __name__ == "__main__":
|
|
|
df_sn['ExitTime'] = pd.to_datetime(df_sn['ExitTime'])
|
|
|
signalMonitor = SignalMonitor.SignalMonitor()
|
|
|
cal_period = 24 # 计算间隔,单位h
|
|
|
- for i in range(102, len(df_sn['sn'])): # 遍历SN号
|
|
|
+ for i in range(1450, 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'):
|