baseAnalyst.analysisOfTurbines 函数 打印所有 机组

dataAnalysisBehavior/behavior/baseAnalyst.py

@@ -292,6 +292,7 @@ class BaseAnalyst(ABC):
         return self.filterCommon(dataFrame, conf)
 
     def analysisOfTurbines(self,  outputAnalysisDir, conf: Contract, turbineCodes):
+        self.logger.info(f"method: analysisOfTurbines , turbineCodes : {turbineCodes}")
         return self.turbinesAnalysis(outputAnalysisDir, conf, turbineCodes)
 
     def turbinesAnalysis(self, outputAnalysisDir, conf: Contract, turbineCodes):
@@ -584,7 +585,6 @@ class BaseAnalyst(ABC):
 
     def processTurbineData(self, turbines, conf: Contract, select: str):
         try:
-            self.logger.info(f"method: processTurbineData , turbines : {turbines}")
             # add "where" condition
             select_conditions = self.selectAllCondition(conf)