业务数据获取 优化

dataAnalysisBehavior/behavior/baseAnalyst.py

@@ -513,9 +513,9 @@ class BaseAnalyst(ABC):
 
             conn=session.connection()
             result=conn.execution_options(stream_results=True).execute(text(query_text))
-             # 每次取 100000 行，可根据实际情况调整
+             # 每次取 50000 行，可根据实际情况调整
             while True:
-                rows = result.fetchmany(100000)
+                rows = result.fetchmany(50000)
                 if not rows:
                     break
                 chunks.append(pd.DataFrame(rows, columns=select))