Vues et periodes comme VRM, et un panneau Batterie enfin lisible

Trois demandes du proprietaire apres usage reel.

1. SELECTEUR DE VUE. Variable « vue » en haut du tableau, dans l'esprit de VRM :
   Vue generale / Consommation / Reseau / Batterie / Chargeur VE. La valeur de
   chaque option est directement une alternative d'expression reguliere,
   consommee par la transformation filterFieldsByName des deux graphiques —
   d'ou le separateur « | ». Un seul jeu de requetes, cinq lectures.

2. PAS ADAPTATIF. L'histogramme d'energie suit desormais la periode choisie :
   l'heure jusqu'a 4 jours, le jour jusqu'a 70, le mois au-dela. Sans cela
   « 30 derniers jours » rendait 720 barres illisibles. C'est ce que fait VRM
   en passant de l'heure au jour puis au mois.

3. PANNEAU BATTERIE ILLISIBLE — un defaut que j'avais cree. Cinq valeurs dans
   huit colonnes : Grafana reduisait le texte jusqu'a l'illisible. Porte a dix
   colonnes avec une taille imposee, plutot que de laisser l'ajustement
   automatique decider. Reseau et Charges CA resserres en consequence.

Ajout lie a la panne en cours : panneau « Ce que le BMS impose » — limite de
courant de charge, alarme de tension de cellule, desequilibre, etat de sante.
C'est ce qu'il faudra regarder cet apres-midi.

Sa fenetre de lecture est de 48 h, deliberement differente des 6 h du reste :
un etat d'alarme ne devient jamais indisponible, il se publie, donc sa derniere
valeur EST la valeur courante meme vieille de dix heures. A l'inverse du
courant reseau, dont le capteur disparait et laisse un chiffre qui ment.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01KKzkkVTG6KXnGXFFC7X9XJ
This commit is contained in:
Tallagrand Thierry
2026-09-05 02:17:21 +02:00
parent 38ed843536
commit 2a367d0960
6 changed files with 344 additions and 44 deletions

View File

@@ -73,7 +73,8 @@ def ts(title, targets, ds, x, y, w, h, unit="", desc="", extra=None, legend="bot
p[k] = v
return p
def stat(title, targets, ds, x, y, w, h, desc="", overrides=None, texte="auto"):
def stat(title, targets, ds, x, y, w, h, desc="", overrides=None, texte="auto",
taille=None, mappings=None):
"""Grands chiffres. Sur telephone, Grafana empile TOUS les panneaux en
pleine largeur sous ~770 px : mettre plusieurs valeurs dans UN panneau est
donc le seul moyen de les garder cote a cote et de limiter le defilement."""
@@ -84,7 +85,7 @@ def stat(title, targets, ds, x, y, w, h, desc="", overrides=None, texte="auto"):
"color": {"mode": "thresholds"},
"thresholds": {"mode": "absolute",
"steps": [{"color": "text", "value": None}]},
"mappings": []}, "overrides": overrides or []},
"mappings": mappings or []}, "overrides": overrides or []},
"options": {"reduceOptions": {"calcs": ["lastNotNull"],
"fields": "", "values": False},
"orientation": "horizontal", "textMode": texte,
@@ -92,6 +93,7 @@ def stat(title, targets, ds, x, y, w, h, desc="", overrides=None, texte="auto"):
"justifyMode": "center",
"percentChangeColorMode": "standard",
"noValue": "—",
**({"text": taille} if taille else {}),
"wideLayout": True}}
@@ -136,8 +138,9 @@ def barchart(title, targets, ds, x, y, w, h, unit="", desc=""):
"showLegend": True},
"tooltip": {"mode": "multi", "sort": "none"}}}
def dashboard(uid, title, desc, panels, refresh="1m", frm="now-24h"):
def dashboard(uid, title, desc, panels, refresh="1m", frm="now-24h", variables=None):
return {
"templating": {"list": variables or []},
"uid": uid, "title": title, "description": desc,
"tags": ["evcs"], "timezone": "Europe/Paris", "editable": True,
"schemaVersion": 39, "version": 1, "refresh": refresh,
@@ -614,7 +617,7 @@ telephone = dashboard("evcs-telephone", "Sur le telephone", (
# variation de -373 kWh sur une heure. Integrer la puissance ignore
# completement ce probleme.
def flux_dernier(refid, mesure, entite, libelle, champ="value"):
def flux_dernier(refid, mesure, entite, libelle, champ="value", fenetre="6h"):
"""Derniere valeur connue d'une entite, renommee pour l'affichage."""
# Fenetre de 6 HEURES : un compromis, et il merite d'etre explique.
#
@@ -645,7 +648,7 @@ def flux_dernier(refid, mesure, entite, libelle, champ="value"):
# constante. `last()` reste peu couteux sur une fenetre large.
return flux(refid,
f'from(bucket: "evcs")\n'
f' |> range(start: -6h)\n'
f' |> range(start: -{fenetre})\n'
f' |> filter(fn: (r) => r._measurement == "{mesure}"'
f' and r.entity_id == "{entite}" and r._field == "{champ}")\n'
f' |> last()\n'
@@ -678,9 +681,24 @@ ENERGIE_CLES = [
# D'ou l'axe des minutes COMPLET par `generate_series`, la valeur reportee
# depuis le dernier point connu, puis la moyenne. Chaque heure pese alors ses
# soixante minutes, qu'il y ait eu une mesure ou non.
ENERGIE_SQL = """WITH axe AS (
SELECT generate_series(date_trunc('minute', $__timeFrom()::timestamptz),
date_trunc('minute', $__timeTo()::timestamptz),
ENERGIE_SQL = """WITH bornes AS (
SELECT $__timeFrom()::timestamptz AS d, $__timeTo()::timestamptz AS f
),
-- Le pas s'adapte a la plage choisie. Sans cela, « 30 derniers jours » rend
-- 720 barres illisibles — c'est exactement ce que fait VRM en passant de
-- l'heure au jour puis au mois.
pas AS (
SELECT CASE WHEN f - d > interval '70 days' THEN 'month'
WHEN f - d > interval '4 days' THEN 'day'
ELSE 'hour' END AS unite,
CASE WHEN f - d > interval '70 days' THEN 'MM/YYYY'
WHEN f - d > interval '4 days' THEN 'DD/MM'
ELSE 'DD/MM HH24' END AS forme
FROM bornes
),
axe AS (
SELECT generate_series(date_trunc('minute', (SELECT d FROM bornes)),
date_trunc('minute', (SELECT f FROM bornes)),
interval '1 minute') AS t
),
releve AS (
@@ -705,22 +723,15 @@ report AS (
for _, n in ENERGIE_CLES) + """
FROM paliers
)
SELECT to_char(t, 'DD/MM HH24') AS "Heure",
SELECT to_char(date_trunc(pas.unite, t), pas.forme) AS "Heure",
""" + ",\n".join(
# Energie REELLEMENT accumulee : puissance moyenne x duree observee.
# Pas la moyenne seule, qui comptait 22 minutes comme 60 et annoncait
# 5,13 kWh de reseau a 01 h le 04/09 — le service n'avait demarre qu'a
# 01:37. Pas non plus un rejet des heures incompletes, qui laissait
# toujours vide l'heure EN COURS, celle qu'on regarde le plus.
# Contrepartie assumee : une heure passee amputee par un arret du service
# sous-estime — mais un tel arret est journalise et apparait en marqueur
# sur le graphique.
f' round((avg({n}) * count({n}) / 60.0 / 1000.0)::numeric, 2) AS "{n}"'
for _, n in ENERGIE_CLES) + """
FROM report
GROUP BY date_trunc('hour', t), to_char(t, 'DD/MM HH24')
FROM report, pas
GROUP BY date_trunc(pas.unite, t), pas.forme
HAVING """ + " OR ".join(f"count({n}) > 0" for _, n in ENERGIE_CLES) + """
ORDER BY date_trunc('hour', t)"""
ORDER BY date_trunc(pas.unite, t)"""
# Detail par tracker. Les quatre entrees du RS 450/200 et le MPPT1 ne suivent
# pas la meme convention de nommage : deux branches, reunies puis pivotees.
@@ -757,17 +768,39 @@ def col(nom, unite, largeur=None, dec=0):
props.append({"id": "custom.width", "value": largeur})
return sur(nom, props)
# Selecteur de vue, dans l'esprit de VRM : la meme representation, restreinte
# aux grandeurs qui interessent. La valeur de chaque option est directement une
# alternative d'expression reguliere, consommee par la transformation
# « filterFieldsByName » des panneaux — d'ou le separateur « | ».
_VUES = [
("Vue generale", "Solaire|Reseau|Batterie|Maison|Voiture"),
("Consommation", "Maison|Voiture"),
("Reseau", "Reseau|Maison"),
("Batterie", "Batterie|Solaire|Maison"),
("Chargeur VE", "Voiture|Solaire"),
]
VARIABLE_VUE = {
"name": "vue", "label": "Vue", "type": "custom", "hide": 0, "skipUrlSync": False,
"query": ",".join(f"{t} : {v}" for t, v in _VUES),
"options": [{"selected": i == 0, "text": t, "value": v} for i, (t, v) in enumerate(_VUES)],
"current": {"selected": True, "text": _VUES[0][0], "value": _VUES[0][1]},
"multi": False, "includeAll": False,
}
FILTRE_VUE = [{"id": "filterFieldsByName",
"options": {"include": {"pattern": "^(time|Heure|$vue)$"}}}]
systeme = dashboard("evcs-systeme", "Le systeme", (
"Replique locale de la vue generale VRM. La console Victron est hebergee "
"dans le cloud : elle disparait quand une coupure d'orage emporte "
"Internet. Tout ce qui est affiche ici est lu sur le reseau local."),
frm="now-24h", refresh="30s", panels=[
frm="now-24h", refresh="30s", variables=[VARIABLE_VUE], panels=[
stat("Reseau", [
flux_dernier("A", "W", "victron_grid_power_l1", "Puissance"),
flux_dernier("B", "V", "airtria_mpii_v1_input_voltage_l1", "Tension"),
flux_dernier("C", "A", "gx_device_grid_current_l1", "Courant")],
IN, 0, 0, 6, 5,
IN, 0, 0, 5, 5,
"Positif : le reseau alimente la maison. Le contacteur EDF est pilote par "
"le workflow d'hysteresis, pas depuis ici.",
overrides=[col("Puissance", "watt"), col("Tension", "volt"), col("Courant", "amp", dec=1)]),
@@ -775,7 +808,7 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
stat("Charges CA", [
flux_dernier("A", "W", "victron_consumption_power_l1", "Consommation"),
flux_dernier("B", "Hz", "airtria_mpii_v1_output_frequency_l1", "Frequence")],
IN, 6, 0, 5, 5,
IN, 5, 0, 4, 5,
"Ce que la maison consomme, voiture comprise.",
overrides=[col("Consommation", "watt"), col("Frequence", "hertz", dec=1)]),
@@ -785,7 +818,7 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
flux_dernier("C", "V", "victron_battery_voltage", "Tension"),
flux_dernier("D", "A", "victron_battery_current", "Courant"),
flux_dernier("E", "°C", "victron_battery_temperature", "Temperature")],
IN, 11, 0, 8, 5,
IN, 9, 0, 10, 5,
"Puissance positive : la batterie se charge. Sept modules actifs sur huit, "
"un pack bloquant la charge vers 94 %.",
overrides=[
@@ -793,7 +826,11 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
{"id": "thresholds", "value": seuils(
("red", None), ("orange", 25), ("yellow", 40), ("green", 60))}]),
col("Puissance", "watt"), col("Tension", "volt", dec=2),
col("Courant", "amp", dec=1), col("Temperature", "celsius")]),
col("Courant", "amp", dec=1), col("Temperature", "celsius")],
# Cinq valeurs dans huit colonnes : Grafana reduisait le texte jusqu'a
# l'illisible. Dix colonnes et une taille imposee, plutot que de laisser
# l'ajustement automatique decider.
taille={"valueSize": 26, "titleSize": 11}),
stat("Chargeur VE", [
flux_dernier("A", "W", "victron_evcs_ac_power", "Puissance"),
@@ -808,14 +845,14 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
stat("Chargeur PV", [
flux_dernier("A", "W", "victron_pv_power_system", "Production"),
flux_dernier("B", "W", "victron_pv_power_10m_avg", "Moyenne 10 min")],
IN, 0, 5, 6, 8,
IN, 0, 5, 5, 8,
"Rappel qui vaut pour toute lecture de cette valeur : sans injection, la "
"production MESUREE vaut min(ressource, consommation + absorption "
"batterie). Basse ne veut pas dire mauvais temps.",
overrides=[col("Production", "watt"), col("Moyenne 10 min", "watt")]),
dict(table("Detail par tracker", [flux("A", TRACKERS_FLUX)],
IN, 6, 5, 18, 8,
IN, 5, 5, 13, 8,
"Les 52 panneaux en quatre plans : sud-est 40 degres, trois chaines sud "
"35 degres, ouest 45 degres. Le suiveur de trois panneaux ne publie pas "
"de mode de fonctionnement et n'apparait donc pas ici.",
@@ -835,6 +872,41 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
transformations=[{"id": "organize", "options": {
"indexByName": {"tracker": 0, "V": 1, "A": 2, "W": 3}}}]),
stat("Ce que le BMS impose", [
# Fenetre de 48 h pour ce panneau, et c'est deliberement different du
# reste. Un etat d'alarme ne devient jamais « indisponible » : il se
# publie. Sa derniere valeur EST donc la valeur courante, meme vieille de
# dix heures — a l'inverse du courant reseau, dont le capteur disparait et
# laisse derriere lui un chiffre qui ment.
flux_dernier("A", "A", "airtria_8_us2000c_maximum_allowed_charge_current", "Charge max", fenetre="48h"),
flux("B", 'from(bucket: "evcs")\n'
' |> range(start: -48h)\n'
' |> filter(fn: (r) => r._measurement == "sensor.airtria_8_us2000c_tension_de_cellule_elevee"'
' and r._field == "state")\n'
' |> last()\n'
' |> keep(columns: ["_time", "_value"])\n'
' |> rename(columns: {_value: "Tension cellule"})'),
flux("C", 'from(bucket: "evcs")\n'
' |> range(start: -48h)\n'
' |> filter(fn: (r) => r._measurement == "sensor.airtria_8_us2000c_cell_imbalance"'
' and r._field == "state")\n'
' |> last()\n'
' |> keep(columns: ["_time", "_value"])\n'
' |> rename(columns: {_value: "Desequilibre"})'),
flux_dernier("D", "%", "airtria_8_us2000c_state_of_health", "Sante", fenetre="48h")],
IN, 18, 5, 6, 8,
"« Charge max » est la limite que le BMS impose au systeme entier. Le "
"04/09 elle est tombee de 150 a 20 A en trois minutes, des 76 % de charge, "
"au moment ou l'alarme de tension de cellule s'est declenchee — le parc "
"n'etait alors qu'a 50,76 V pour 53,2 V autorises. Ce n'est pas le parc "
"qui sature, c'est une cellule.",
overrides=[col("Charge max", "amp"), col("Sante", "percent")],
taille={"valueSize": 24, "titleSize": 11},
mappings=[{"type": "value", "options": {
"no_alarm": {"text": "OK", "color": "green", "index": 0},
"warning": {"text": "AVERTISSEMENT", "color": "orange", "index": 1},
"alarm": {"text": "ALARME", "color": "red", "index": 2}}}]),
ts("Les flux", [
sql_grandeurs("A", [
('sensor.victron_pv_power_system', 'Solaire'),
@@ -852,13 +924,17 @@ systeme = dashboard("evcs-systeme", "Le systeme", (
sur("Batterie", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "blue"}}]),
sur("Maison", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "text"}},
{"id": "custom.fillOpacity", "value": 0}]),
sur("Voiture", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "green"}}])]}),
sur("Voiture", [{"id": "color", "value": {"mode": "fixed", "fixedColor": "green"}}])],
"transformations": FILTRE_VUE}),
barchart("Energie heure par heure", [sql("A", ENERGIE_SQL, fmt="table")],
dict(barchart("Energie par periode", [sql("A", ENERGIE_SQL, fmt="table")],
PG, 0, 22, 24, 9, "kwatth",
"Obtenue en integrant la puissance, PAS en lisant les compteurs kWh du "
"GX : ceux-ci se remettent a zero sans le signaler (verifie le 04/09, "
"-373 kWh enregistres sur une heure cote Home Assistant)."),
"Le pas suit la periode choisie : l'heure jusqu'a 4 jours, le jour "
"jusqu'a 70, le mois au-dela. Obtenue en integrant la puissance, PAS en "
"lisant les compteurs kWh du GX : ceux-ci se remettent a zero sans le "
"signaler (verifie le 04/09, -373 kWh enregistres sur une heure cote "
"Home Assistant)."),
transformations=FILTRE_VUE),
])
base = pathlib.Path('deploy/historisation/grafana/dashboards')