Chauffe-eau : Grafana « Le chauffe-eau », historisation (compteur rattrape depuis le 14/08), jour faible = aussi surplus solaire reel et securite douche de 20 h

This commit is contained in:
Tallagrand Thierry
2026-10-07 07:25:41 +02:00
parent c9e0e4bb5a
commit 36c2fb713a
10 changed files with 654 additions and 12 deletions

View File

@@ -1971,6 +1971,112 @@ journee = dashboard(
], frm="now/d", jusqu="now/d")
# =====================================================================
# LE CHAUFFE-EAU (07/10/2026) — demande du proprietaire
# =====================================================================
# Le 06/10 il a pris 5,4 kWh de 10 h a 15 h, l'energie qui manquait a la
# batterie. Depuis le 07/10 il chauffe en HC de nuit les jours faibles
# (decision du bilan, workflow ECS). Ce tableau dit QUAND il chauffe et SUR
# QUOI : l'energie vient du compteur cumule du ballon (historique HA rattrape
# depuis le 14/08), le contexte de chaque heure des puissances moyennes de
# l'heure — EDF si le reseau fournit plus de 300 W, solaire si la production
# couvre la maison, batterie sinon. C'est une ATTRIBUTION par heure, pas un
# comptage par electron : une heure moitie soleil moitie batterie est classee
# d'un seul cote.
ECS_C = "sensor.tt_chauffe_eau_pleumeur_energie_totale"
def ecs_heures(select, filtre=""):
"""kWh du chauffe-eau par heure locale, avec le contexte de l'heure."""
def moy(cle):
return (f"coalesce((SELECT avg(valeur) FROM mesure WHERE cle = '{cle}' "
f"AND ts >= k.t AND ts < k.t + interval '1 hour'), "
f"(SELECT valeur FROM mesure WHERE cle = '{cle}' AND ts < k.t "
f"ORDER BY ts DESC LIMIT 1), 0)")
return (
"WITH h AS (SELECT generate_series(date_trunc('hour', $__timeFrom()::timestamptz),\n"
" date_trunc('hour', least(now(), $__timeTo()::timestamptz)), interval '1 hour') AS t),\n"
f"v AS (SELECT t, (SELECT valeur FROM mesure WHERE cle = '{ECS_C}' AND ts <= t\n"
" ORDER BY ts DESC LIMIT 1) AS e FROM h),\n"
"k AS (SELECT t, greatest(0, lead(e) OVER (ORDER BY t) - e) AS kwh FROM v),\n"
"c AS (SELECT k.t, k.kwh,\n"
f" {moy('sensor.victron_grid_power_l1')} AS reseau,\n"
f" {moy('sensor.victron_pv_power_system')} AS pv,\n"
f" {moy('sensor.victron_consumption_power_l1')} AS maison\n"
" FROM k WHERE k.kwh IS NOT NULL),\n"
"x AS (SELECT t, kwh, CASE WHEN reseau > 300 THEN 'EDF' WHEN pv >= maison THEN 'solaire'\n"
" ELSE 'batterie' END AS ctx FROM c)\n" + select)
ECS_PAR_SOURCE = sur # (alias de lisibilite)
COULEURS_ECS = [sur("Solaire", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "yellow"}}]),
sur("Batterie", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "red"}}]),
sur("EDF", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "blue"}}])]
chauffe_eau = dashboard("evcs-chauffe-eau", "Le chauffe-eau", (
"Quand le chauffe-eau chauffe, et sur quoi : solaire, batterie ou EDF. "
"Les jours faibles il doit chauffer la nuit sur EDF (decision du bilan "
"apres 07:24), jamais sur la batterie."), [
stat("Maintenant", [sql("A",
"SELECT now() AS time,\n"
" (SELECT valeur FROM mesure WHERE cle = 'sensor.evcs_chauffe_eau_24h_kwh' ORDER BY ts DESC LIMIT 1) AS \"Sur 24 h\",\n"
" (SELECT valeur FROM mesure WHERE cle = 'input_number.victron_water_heater_observed_power_w' ORDER BY ts DESC LIMIT 1) AS \"Puissance\"",
fmt="table")],
PG, 0, 0, 8, 4,
desc="Energie des 24 dernieres heures (securite eau chaude : sous 1,5 kWh "
"il chauffe meme un jour faible) et puissance mesuree par le workflow "
"ECS sur ses 5 dernieres minutes (morte jusqu'au 07/10).",
overrides=[sur("Sur 24 h", [{"id": "unit", "value": "kwatth"}, {"id": "decimals", "value": 2}]),
sur("Puissance", [{"id": "unit", "value": "watt"}])]),
table("Decisions et etats", [sql("A",
"SELECT to_char(ts AT TIME ZONE 'Europe/Paris', 'DD/MM HH24:MI') AS \"Quand\", resume AS \"Quoi\"\n"
"FROM evenement WHERE genre = 'chauffe_eau' AND $__timeFilter(ts) ORDER BY ts DESC", fmt="table")],
PG, 8, 0, 16, 8,
desc="Decision quotidienne du bilan (jour faible : eau chaude en HC de "
"nuit), mise sous tension / coupure, changements de regime (pompe a "
"chaleur, resistance). Journalise depuis le 07/10."),
ts("Energie par heure, selon d'ou elle venait", [sql("A", ecs_heures(
"SELECT t AS time,\n"
" CASE WHEN ctx = 'solaire' THEN kwh END AS \"Solaire\",\n"
" CASE WHEN ctx = 'batterie' THEN kwh END AS \"Batterie\",\n"
" CASE WHEN ctx = 'EDF' THEN kwh END AS \"EDF\"\n"
"FROM x ORDER BY t"))],
PG, 0, 8, 24, 9, unit="kwatth",
desc="Une barre par heure. Contexte de l'heure : EDF si le reseau fournit "
"plus de 300 W en moyenne, solaire si la production couvre la maison, "
"batterie sinon (attribution par heure). Le rouge est ce qu'on veut "
"faire disparaitre : de l'eau chauffee sur la batterie.",
extra={"defaults": {"custom": {"drawStyle": "bars", "fillOpacity": 85, "lineWidth": 0,
"stacking": {"mode": "normal", "group": "A"},
"showPoints": "never", "spanNulls": False}},
"overrides": COULEURS_ECS}),
barchart("Par jour", [sql("A", ecs_heures(
"SELECT to_char(t AT TIME ZONE 'Europe/Paris', 'DD/MM') AS \"Jour\",\n"
" round(sum(kwh) FILTER (WHERE ctx = 'solaire')::numeric, 2) AS \"Solaire\",\n"
" round(sum(kwh) FILTER (WHERE ctx = 'batterie')::numeric, 2) AS \"Batterie\",\n"
" round(sum(kwh) FILTER (WHERE ctx = 'EDF')::numeric, 2) AS \"EDF\"\n"
"FROM x GROUP BY 1, date_trunc('day', t AT TIME ZONE 'Europe/Paris')\n"
"ORDER BY date_trunc('day', t AT TIME ZONE 'Europe/Paris')"), fmt="table")],
PG, 0, 17, 24, 8, unit="kwatth",
desc="kWh du chauffe-eau par jour et par contexte. Repere : le 06/10, 5,4 kWh "
"dont une partie sur la batterie a midi ; un jour faible reussi n'a que "
"du bleu (EDF en heures creuses).",
overrides=COULEURS_ECS),
ts("Puissance mesuree et regime", [sql("A",
"SELECT ts AS time, valeur AS \"Puissance\" FROM mesure\n"
"WHERE cle = 'input_number.victron_water_heater_observed_power_w' AND $__timeFilter(ts) ORDER BY ts")],
PG, 0, 25, 24, 8, unit="watt",
desc="Puissance moyenne sur 5 minutes calculee par le workflow ECS depuis le "
"compteur. Pompe a chaleur : puissance basse, ~5 h pour 55 °C ; "
"resistance (~1,2 kW) : de 55 a 65 °C. Disponible depuis le 07/10 "
"(avant, la mesure ne lisait jamais ses horodatages).",
extra={"defaults": {"custom": {"drawStyle": "line", "lineInterpolation": "stepAfter",
"fillOpacity": 20}}}),
], frm="now-7d")
base = pathlib.Path('deploy/historisation/grafana/dashboards')
for nom, d in [('journee.json', journee),
('nuit.json', nuit), ('solaire.json', solaire),
@@ -1978,6 +2084,7 @@ for nom, d in [('journee.json', journee),
('telephone.json', telephone),
('systeme.json', systeme),
('vehicules.json', vehicules),
('batteries.json', batteries)]:
('batteries.json', batteries),
('chauffe-eau.json', chauffe_eau)]:
(base / nom).write_text(json.dumps(d, indent=2, ensure_ascii=False) + '\n')
print(f"{nom:16s} {len(d['panels'])} panneaux")