|
@@ -4,24 +4,22 @@ __author__ = 'lmstack'
|
|
|
import os
|
|
|
import datetime
|
|
|
import pandas as pd
|
|
|
-from LIB.BACKEND import DBManager, Log
|
|
|
+from LIB.BACKEND import DBManager
|
|
|
from sqlalchemy import create_engine
|
|
|
from sqlalchemy.orm import sessionmaker
|
|
|
-import time, datetime
|
|
|
+import datetime
|
|
|
import dateutil.relativedelta
|
|
|
import traceback
|
|
|
-from LIB.MIDDLE.CellStateEstimation.Common import log
|
|
|
from pandas.core.frame import DataFrame
|
|
|
|
|
|
-from LIB.MIDDLE.CellStateEstimation.Common.V1_0_1 import DBDownload
|
|
|
from urllib import parse
|
|
|
import pymysql
|
|
|
-import pdb
|
|
|
-from apscheduler.schedulers.blocking import BlockingScheduler
|
|
|
-import datacompy
|
|
|
from LIB.MIDDLE.SaftyCenter.Common import DBDownload as DBDw
|
|
|
from LIB.MIDDLE.SaftyCenter.Common import QX_BatteryParam
|
|
|
from LIB.MIDDLE.SaftyCenter.Low_Soc_Alarm.low_soc_alarm import Low_soc_alarm
|
|
|
+import logging
|
|
|
+import logging.handlers
|
|
|
+import re
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
|
@@ -67,15 +65,31 @@ if __name__ == "__main__":
|
|
|
db_engine.dispose()
|
|
|
|
|
|
|
|
|
- # 日志配置
|
|
|
- now_str = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()).replace(":","_")
|
|
|
- log_path = 'log/' + now_str
|
|
|
+ # 日志
|
|
|
+ log_path = 'log/'
|
|
|
if not os.path.exists(log_path):
|
|
|
os.makedirs(log_path)
|
|
|
- log = Log.Mylog(log_name='saftyCenter_lowSocAlarm', 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()))
|
|
|
|