|
@@ -5,7 +5,7 @@ from os import path
|
|
|
|
|
|
import numpy as np
|
|
|
import pandas as pd
|
|
|
-
|
|
|
+import math
|
|
|
from etl.common.PathsAndTable import PathsAndTable
|
|
|
from etl.wind_power.min_sec import TransParam
|
|
|
from etl.wind_power.min_sec.ClassIdentifier import ClassIdentifier
|
|
@@ -109,9 +109,12 @@ class StatisticsAndSaveFile(object):
|
|
|
df['time_stamp'] = df['time_stamp'].dt.floor('10T')
|
|
|
df = df.groupby(['wind_turbine_number', 'time_stamp']).mean().reset_index()
|
|
|
|
|
|
- power = df.sample(int(df.shape[0] / 100))['active_power'].median()
|
|
|
+ power_df = df[df['active_power'] > 0]
|
|
|
+ power = power_df.sample(int(power_df.shape[0] / 100))['active_power'].median()
|
|
|
+ del power_df
|
|
|
+ trans_print(wind_col_name, '有功功率,中位数', power)
|
|
|
if power > 100000:
|
|
|
- df['active_power'] = df['active_power'] / 100000
|
|
|
+ df['active_power'] = df['active_power'] / 1000
|
|
|
## 做数据检测前,羡强行处理有功功率
|
|
|
# df = df[df['active_power'] < 50000]
|
|
|
|