main_anomaly.py 1.1 KB

123456789101112131415161718192021222324252627282930313233
  1. from LIB.MIDDLE.CellStateEstimation.Common import log
  2. from LIB.BACKEND import DBManager
  3. dbManager = DBManager.DBManager()
  4. import pandas as pd
  5. import anomalySparsePCA
  6. dataSOH = pd.read_excel('sn-20210903.xlsx',sheet_name='格林美-CATL7255')
  7. fileNames = dataSOH['sn']
  8. fileNames = list(fileNames)
  9. l = len(fileNames)
  10. #log信息配置
  11. mylog=log.Mylog('log.txt','error')
  12. mylog.logcfg()
  13. data_res=pd.DataFrame()
  14. for k in range(3):
  15. try:
  16. sn = fileNames[k]
  17. df_data = dbManager.get_data(sn=sn, start_time='2021-01-01 00:00:00', end_time='2021-11-01 00:00:00', data_groups=['bms'])
  18. data_bms = df_data['bms']
  19. #...............训练模型............................................................................
  20. if len(data_bms['时间戳'])>0:
  21. data_stat=anomalySparsePCA.anomaly(data_bms)
  22. data_stat.to_csv('result_'+sn+'.csv',encoding='gbk')
  23. data_stat['sn']=sn
  24. data_res=data_res.append(data_stat)
  25. except Exception as e:
  26. print(repr(e))
  27. mylog.logopt(sn,e)
  28. pass