Skip to content

Commit

Permalink
Add migration scripts in Flux
Browse files Browse the repository at this point in the history
  • Loading branch information
ccremer committed Dec 27, 2021
1 parent 55c94a2 commit 8b55fd0
Show file tree
Hide file tree
Showing 33 changed files with 652 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.hotwater.hotwatertemp.actual"
tMeasurement = "stiebeleltron_domestic_hotwater_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "actual")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.hotwater.hotwatertemp.set"
tMeasurement = "stiebeleltron_domestic_hotwater_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "target")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.eletricreheating.reheatingtemp.heating"
tMeasurement = "stiebeleltron_electric_reheating_dualmode_reheating_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "sensor", value: "heating")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.eletricreheating.reheatingtemp.hot_water"
tMeasurement = "stiebeleltron_electric_reheating_dualmode_reheating_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "sensor", value: "domestic_hotwater")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_heatpump.energy.compressorday.hot_water"
tMeasurement = "stiebeleltron_energy_heating_total"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 3600000.0)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "timeframe", value: "day")
|> set(key: "compressor", value: "domestic_hotwater")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_heatpump.energy.compressortotal.hot_water"
tMeasurement = "stiebeleltron_energy_heating_total"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 3600000000.0)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "timeframe", value: "total")
|> set(key: "compressor", value: "domestic_hotwater")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_heatpump.energy.compressorday.heating"
tMeasurement = "stiebeleltron_energy_heating_total"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 3600000.0)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "timeframe", value: "day")
|> set(key: "compressor", value: "heating")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_heatpump.energy.compressortotal.heating"
tMeasurement = "stiebeleltron_energy_heating_total"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 3600000000.0)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "timeframe", value: "total")
|> set(key: "compressor", value: "heating")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.flowrate.flow_rate"
tMeasurement = "stiebeleltron_general_flow"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 0.01)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.heatingcircuit.heating_circuit"
tMeasurement = "stiebeleltron_general_heating_circuit_pressure"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.output.heat_pump"
tMeasurement = "stiebeleltron_general_output_activity_ratio"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 0.01)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "pump", value: "heat")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.output.water_pump"
tMeasurement = "stiebeleltron_general_output_activity_ratio"
site = "sirius"

multiplyByX = (x, tables=<-) =>
tables
|> map(fn: (r) => ({
r with
_value: r._value * x
})
)

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> multiplyByX(x: 0.01)
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "pump", value: "water")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.outside.outside_temperature"
tMeasurement = "stiebeleltron_general_temperature_outside"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.general.condenser.condenser"
tMeasurement = "stiebeleltron_general_temperature_condenser"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.heating.buffertemp.actual"
tMeasurement = "stiebeleltron_heating_buffer_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "actual")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.heating.buffertemp.set"
tMeasurement = "stiebeleltron_heating_buffer_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "target")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.heating.fixedtemp.set"
tMeasurement = "stiebeleltron_heating_fixed_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "target")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
sBucket = "netdata/autogen"
tBucket = "stiebeleltron_archive"
sMeasurement = "netdata.heating.stiebeleltron_system.heating.flowtemp.heating"
tMeasurement = "stiebeleltron_heating_flow_temperature"
site = "sirius"

from(bucket: sBucket)
|> range(start: -5y, stop: 0s)
|> filter(fn:(r) =>
r._measurement == sMeasurement
)
|> map(fn: (r) => ({r with _measurement: tMeasurement}))
|> aggregateWindow(every: 10m, fn: mean, createEmpty: false)
|> set(key: "site", value: site)
|> set(key: "state", value: "actual")
|> set(key: "type", value: "heatpump")
|> set(key: "_field", value: "gauge")
|> to(bucket: tBucket)
Loading

0 comments on commit 8b55fd0

Please sign in to comment.