Skip to content
Snippets Groups Projects
Commit 272ef85e authored by kgao's avatar kgao
Browse files

Added rolling averages for wind_speed and wind_direction

every five seconds, a new rolling 2 minute average is calculated
every minute, only 1 average is stored in the file's memory
parent 7b5cb32e
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment