|
@@ -19,13 +19,8 @@ class DataFetcher:
|
|
:param windcode: 风场编号 (如 "WF001")
|
|
:param windcode: 风场编号 (如 "WF001")
|
|
:return: 列名列表 (如 ["timestamp", "temp1", "vibration1"])
|
|
:return: 列名列表 (如 ["timestamp", "temp1", "vibration1"])
|
|
"""
|
|
"""
|
|
- # 根据风场编号获取表名,特殊风场用反引号,其他风场不加反引号
|
|
|
|
- special_wind_farms = {
|
|
|
|
- #训练诺木洪风场时 删掉反引号
|
|
|
|
- "WOF093400005": f"`{windcode}-WOB000001_minute`" # 加上反引号
|
|
|
|
- # "WOF093400005": f"{windcode}-WOB000001_minute"
|
|
|
|
- }
|
|
|
|
- table_name = special_wind_farms.get(windcode, f"{windcode}_minute")
|
|
|
|
|
|
+
|
|
|
|
+ table_name = f"{windcode}_minute"
|
|
try:
|
|
try:
|
|
inspector = inspect(get_engine(dataBase.DATA_DB))
|
|
inspector = inspect(get_engine(dataBase.DATA_DB))
|
|
columns = inspector.get_columns(table_name)
|
|
columns = inspector.get_columns(table_name)
|
|
@@ -93,12 +88,8 @@ class DataFetcher:
|
|
return pd.DataFrame()
|
|
return pd.DataFrame()
|
|
|
|
|
|
# 3. 构建参数化查询
|
|
# 3. 构建参数化查询
|
|
- # 根据风场编号获取表名,特殊风场用反引号,其他风场不加反引号
|
|
|
|
- special_wind_farms = {
|
|
|
|
- "WOF093400005": f"`{windcode}-WOB000001_minute`" # 加上反引号
|
|
|
|
- #"WOF093400005": f"{windcode}-WOB000001_minute"
|
|
|
|
- }
|
|
|
|
- table_name = special_wind_farms.get(windcode, f"{windcode}_minute")
|
|
|
|
|
|
+
|
|
|
|
+ table_name = f"{windcode}_minute"
|
|
query = f"""
|
|
query = f"""
|
|
SELECT `year`,`mont`, {','.join(safe_features)}
|
|
SELECT `year`,`mont`, {','.join(safe_features)}
|
|
FROM {table_name}
|
|
FROM {table_name}
|
|
@@ -132,12 +123,8 @@ class DataFetcher:
|
|
|
|
|
|
# 将month格式从yyyy-mm转换为单独的年份和月份
|
|
# 将month格式从yyyy-mm转换为单独的年份和月份
|
|
year, month = month.split('-')
|
|
year, month = month.split('-')
|
|
- # 根据风场编号获取表名,特殊风场用反引号,其他风场不加反引号
|
|
|
|
- special_wind_farms = {
|
|
|
|
- "WOF093400005": f"`{windcode}-WOB000001_minute`" # 加上反引号
|
|
|
|
- #"WOF093400005": f"{windcode}-WOB000001_minute"
|
|
|
|
- }
|
|
|
|
- table_name = special_wind_farms.get(windcode, f"{windcode}_minute")
|
|
|
|
|
|
+
|
|
|
|
+ table_name = f"{windcode}_minute"
|
|
# 单次查询获取所有风机数据
|
|
# 单次查询获取所有风机数据
|
|
query = f"""
|
|
query = f"""
|
|
SELECT `wind_turbine_number`, {','.join(safe_features)}
|
|
SELECT `wind_turbine_number`, {','.join(safe_features)}
|