diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_actual.flux new file mode 100644 index 0000000..4cd30b6 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_actual.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_target.flux new file mode 100644 index 0000000..4788721 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/domestic_hotwater_temperature_target.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_heating.flux b/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_heating.flux new file mode 100644 index 0000000..462fc61 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_heating.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_hotwater.flux b/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_hotwater.flux new file mode 100644 index 0000000..b3ade85 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/electric_reheating_dualmode_reheating_temperatur_hotwater.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_day.flux b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_day.flux new file mode 100644 index 0000000..a525ac5 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_day.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_total.flux b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_total.flux new file mode 100644 index 0000000..a1c6182 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_dhw_total.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_day.flux b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_day.flux new file mode 100644 index 0000000..207892d --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_day.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_total.flux b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_total.flux new file mode 100644 index 0000000..c957f7f --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/energy_heating_total_heating_total.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_flow.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_flow.flux new file mode 100644 index 0000000..72dfb6f --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_flow.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_heating_circuit_pressure.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_heating_circuit_pressure.flux new file mode 100644 index 0000000..2584e05 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_heating_circuit_pressure.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_heat.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_heat.flux new file mode 100644 index 0000000..fe84179 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_heat.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_water.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_water.flux new file mode 100644 index 0000000..845cf21 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_output_activity_ratio_water.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_outside_temperature.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_outside_temperature.flux new file mode 100644 index 0000000..3847c70 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_outside_temperature.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/general_temperature_condenser.flux b/charts/stiebeleltron-stack/files/influxdb/migration/general_temperature_condenser.flux new file mode 100644 index 0000000..6a57a94 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/general_temperature_condenser.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_actual.flux new file mode 100644 index 0000000..f2e0187 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_actual.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_target.flux new file mode 100644 index 0000000..b2eef75 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_buffer_temperature_target.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_fixed_temperature.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_fixed_temperature.flux new file mode 100644 index 0000000..5ac9870 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_fixed_temperature.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_heatpump.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_heatpump.flux new file mode 100644 index 0000000..c4f30b4 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_heatpump.flux @@ -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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_preflow.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_preflow.flux new file mode 100644 index 0000000..a92267d --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_preflow.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.preflowtemp.actual" +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: "preflow") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_reheating.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_reheating.flux new file mode 100644 index 0000000..b589a2e --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_flow_temperature_reheating.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.flowtemp.reheating" +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: "reheating") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_actual.flux new file mode 100644 index 0000000..c04d84c --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_actual.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.hc1.actual" +tMeasurement = "stiebeleltron_heating_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: "circuit", value: "hc1") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_target.flux new file mode 100644 index 0000000..fadfaa3 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc1_target.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.hc1.set" +tMeasurement = "stiebeleltron_heating_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: "circuit", value: "hc1") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_actual.flux new file mode 100644 index 0000000..a5755e6 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_actual.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.hc2.actual" +tMeasurement = "stiebeleltron_heating_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: "circuit", value: "hc2") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_target.flux new file mode 100644 index 0000000..802020d --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/heating_temperature_hc2_target.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.heating.hc2.set" +tMeasurement = "stiebeleltron_heating_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: "circuit", value: "hc2") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/process_data_compressor_delay_counter.flux b/charts/stiebeleltron-stack/files/influxdb/migration/process_data_compressor_delay_counter.flux new file mode 100644 index 0000000..3186ca2 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/process_data_compressor_delay_counter.flux @@ -0,0 +1,16 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_heatpump.processdata.remaincomp.timer" +tMeasurement = "stiebeleltron_process_data_compressor_delay_counter" +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) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_actual.flux new file mode 100644 index 0000000..a8f838a --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_actual.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.roomtemp.hc1.actual" +tMeasurement = "stiebeleltron_room_temperature_heating_circuit" +site = "sirius" + +from(bucket: sBucket) + |> range(start: -5yd, 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: "circuit", value: "hc1") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_target.flux new file mode 100644 index 0000000..1762e66 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc1_target.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.roomtemp.hc1.set" +tMeasurement = "stiebeleltron_room_temperature_heating_circuit" +site = "sirius" + +from(bucket: sBucket) + |> range(start: -5yd, 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: "circuit", value: "hc1") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_actual.flux b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_actual.flux new file mode 100644 index 0000000..538cae2 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_actual.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.roomtemp.hc2.actual" +tMeasurement = "stiebeleltron_room_temperature_heating_circuit" +site = "sirius" + +from(bucket: sBucket) + |> range(start: -5yd, 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: "circuit", value: "hc2") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_target.flux b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_target.flux new file mode 100644 index 0000000..c96dbe1 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/room_temperature_heating_circuit_hc2_target.flux @@ -0,0 +1,18 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_system.roomtemp.hc2.set" +tMeasurement = "stiebeleltron_room_temperature_heating_circuit" +site = "sirius" + +from(bucket: sBucket) + |> range(start: -5yd, 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: "circuit", value: "hc2") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_dhw.flux b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_dhw.flux new file mode 100644 index 0000000..115796c --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_dhw.flux @@ -0,0 +1,26 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_heatpump.runtime.compressor.hot_water" +tMeasurement = "stiebeleltron_runtime_compressor" +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: 3600.0) + |> aggregateWindow(every: 10m, fn: mean, createEmpty: false) + |> set(key: "site", value: site) + |> set(key: "compressor", value: "domestic_hotwater") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_heating.flux b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_heating.flux new file mode 100644 index 0000000..46a04af --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_compressor_heating.flux @@ -0,0 +1,26 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_heatpump.runtime.compressor.heating" +tMeasurement = "stiebeleltron_runtime_compressor" +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: 3600.0) + |> aggregateWindow(every: 10m, fn: mean, createEmpty: false) + |> set(key: "site", value: site) + |> set(key: "compressor", value: "heating") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_1.flux b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_1.flux new file mode 100644 index 0000000..4ece541 --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_1.flux @@ -0,0 +1,17 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_heatpump.runtime.reheating.reheating_1" +tMeasurement = "stiebeleltron_runtime_reheating" +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: "circuit", value: "hc1") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket) diff --git a/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_2.flux b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_2.flux new file mode 100644 index 0000000..590bb8d --- /dev/null +++ b/charts/stiebeleltron-stack/files/influxdb/migration/runtime_reheating_2.flux @@ -0,0 +1,17 @@ +sBucket = "netdata/autogen" +tBucket = "stiebeleltron_archive" +sMeasurement = "netdata.heating.stiebeleltron_heatpump.runtime.reheating.reheating_2" +tMeasurement = "stiebeleltron_runtime_reheating" +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: "circuit", value: "hc2") + |> set(key: "_field", value: "gauge") + |> to(bucket: tBucket)