Improve handling missing data

solectrus · Feb 1, 2025 · 3187175 · 3187175
1 parent 8d24d2b
commit 3187175
Show file tree

Hide file tree

Showing 4 changed files with 118 additions and 22 deletions.
diff --git a/lib/flux/extractor.rb b/lib/flux/extractor.rb
@@ -14,8 +14,9 @@ def records(day)
         #{from_bucket}
         |> #{range}
         |> #{filter(selected_sensors: config.sensor_names)}
-        |> aggregateWindow(every: 1m, fn: mean)
+        |> aggregateWindow(every: 5s, fn: last)
         |> fill(usePrevious: true)
+        |> aggregateWindow(every: 1m, fn: mean)
       FLUX
       result = query(query_string)
 

diff --git a/spec/cassettes/extractor.yml b/spec/cassettes/extractor.yml
diff --git a/spec/cassettes/loop-restart.yml b/spec/cassettes/loop-restart.yml
diff --git a/spec/cassettes/loop-start.yml b/spec/cassettes/loop-start.yml