diff --git a/aosstower/level_b1/nc.py b/aosstower/level_b1/nc.py index 8d7df816ba407958b85e93739337d2ba04ef28d7..15ad42334a32106e05b978b9e8eb3991c117eb3b 100644 --- a/aosstower/level_b1/nc.py +++ b/aosstower/level_b1/nc.py @@ -127,11 +127,23 @@ def minuteAverages(frame): if 'wind_speed' in columns: del newFrame['wind_speed'] + windSeries = frame['wind_speed'] + + windSeries = windSeries.rolling(25, win_type='boxcar').mean() + + print(windSeries) + + newFrame['wind_speed'] = windSeries + if 'wind_direction' in columns: del newFrame['wind_direction'] - print(frame) - + windDirSeries = frame['wind_direction'] + + windDirSeries = windDirSeries.rolling(25, win_type='boxcar').mean() + + newFrame['wind_direction'] = windDirSeries + del frame['minute'] return newFrame.fillna(-99999) @@ -227,9 +239,7 @@ def createGiantNetCDF(start, end, inputFiles, outputName, zlib, chunkSize): frame = getData(inputFiles) - newFrame = minuteAverages(frame) - - print(newFrame) + frame = minuteAverages(frame) if(frame.empty): return False