From 272ef85e26c0f8e95ce3c41b67e9ef09e0430858 Mon Sep 17 00:00:00 2001
From: kgao <kenny.gao@ssec.wisc.edu>
Date: Thu, 11 Aug 2016 21:22:01 +0000
Subject: [PATCH] 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
---
aosstower/level_b1/nc.py | 20 +++++++++++++++-----
1 file changed, 15 insertions(+), 5 deletions(-)
diff --git a/aosstower/level_b1/nc.py b/aosstower/level_b1/nc.py
index 8d7df81..15ad423 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
--
GitLab