|
@@ -2,19 +2,20 @@
|
|
__author__ = 'lmstack'
|
|
__author__ = 'lmstack'
|
|
#coding=utf-8
|
|
#coding=utf-8
|
|
import os
|
|
import os
|
|
-import datetime
|
|
|
|
import pandas as pd
|
|
import pandas as pd
|
|
from LIB.BACKEND import DBManager, Log
|
|
from LIB.BACKEND import DBManager, Log
|
|
from sqlalchemy import create_engine
|
|
from sqlalchemy import create_engine
|
|
from sqlalchemy.orm import sessionmaker
|
|
from sqlalchemy.orm import sessionmaker
|
|
import time, datetime
|
|
import time, datetime
|
|
-import dateutil.relativedelta
|
|
|
|
import traceback
|
|
import traceback
|
|
from LIB.MIDDLE.CellStateEstimation.Common import log
|
|
from LIB.MIDDLE.CellStateEstimation.Common import log
|
|
from LIB.MIDDLE.SaftyCenter.Low_Soc_Alarm import low_soc_alarm_sta
|
|
from LIB.MIDDLE.SaftyCenter.Low_Soc_Alarm import low_soc_alarm_sta
|
|
from urllib import parse
|
|
from urllib import parse
|
|
import pymysql
|
|
import pymysql
|
|
from LIB.BACKEND import DBManager
|
|
from LIB.BACKEND import DBManager
|
|
|
|
+import logging
|
|
|
|
+import logging.handlers
|
|
|
|
+import re
|
|
|
|
|
|
if __name__ == "__main__":
|
|
if __name__ == "__main__":
|
|
|
|
|
|
@@ -45,15 +46,31 @@ if __name__ == "__main__":
|
|
df_sn = pd.concat([df_sn, df_sn2], axis=0)
|
|
df_sn = pd.concat([df_sn, df_sn2], axis=0)
|
|
df_sn = df_sn.reset_index(drop=True)
|
|
df_sn = df_sn.reset_index(drop=True)
|
|
|
|
|
|
- # 日志配置
|
|
|
|
- now_str = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()).replace(":","_")
|
|
|
|
- log_path = 'log_sta/' + now_str
|
|
|
|
|
|
+ # 日志
|
|
|
|
+ log_path = 'log_sta/'
|
|
if not os.path.exists(log_path):
|
|
if not os.path.exists(log_path):
|
|
os.makedirs(log_path)
|
|
os.makedirs(log_path)
|
|
- log = Log.Mylog(log_name='saftyCenter_lowsocsta', log_level = 'info')
|
|
|
|
- log.set_file_hl(file_name='{}/info.log'.format(log_path), log_level='info', size=1024* 1024 * 100)
|
|
|
|
- log.set_file_hl(file_name='{}/error.log'.format(log_path), log_level='error', size=1024* 1024 * 100)
|
|
|
|
- logger = log.get_logger()
|
|
|
|
|
|
+ logger = logging.getLogger("main")
|
|
|
|
+ logger.setLevel(logging.DEBUG)
|
|
|
|
+
|
|
|
|
+ # 根据日期滚动(每天产生1个文件)
|
|
|
|
+ fh = logging.handlers.TimedRotatingFileHandler(filename='{}/main_info.log'.format(log_path), when="D", interval=1, backupCount=30,
|
|
|
|
+ encoding="utf-8")
|
|
|
|
+ formatter = logging.Formatter("%(asctime)s - %(name)s-%(levelname)s %(message)s")
|
|
|
|
+ fh.suffix = "%Y-%m-%d_%H-%M-%S"
|
|
|
|
+ fh.extMatch = re.compile(r"^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}")
|
|
|
|
+ fh.setFormatter(formatter)
|
|
|
|
+ fh.setLevel(logging.INFO)
|
|
|
|
+ logger.addHandler(fh)
|
|
|
|
+
|
|
|
|
+ fh = logging.handlers.TimedRotatingFileHandler(filename='{}/main_error.log'.format(log_path), when="D", interval=1, backupCount=30,
|
|
|
|
+ encoding="utf-8")
|
|
|
|
+ formatter = logging.Formatter("%(asctime)s - %(name)s-%(levelname)s %(message)s")
|
|
|
|
+ fh.suffix = "%Y-%m-%d_%H-%M-%S"
|
|
|
|
+ fh.extMatch = re.compile(r"^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}")
|
|
|
|
+ fh.setFormatter(formatter)
|
|
|
|
+ fh.setLevel(logging.ERROR)
|
|
|
|
+ logger.addHandler(fh)
|
|
|
|
|
|
logger.info("pid is {}".format(os.getpid()))
|
|
logger.info("pid is {}".format(os.getpid()))
|
|
try:
|
|
try:
|