Export do influxdb lub mqtt ?

[mmg1t]

Zastanawiam się jak rysować wykresy z wartości prezentowanych z tej integracji.
Wykresy w samym home assistant sa dość ubogie w funkcjonlanosci wiec myśle tutaj o Grafanie (również posiadam),
z tym że datasource byloby dobrze mieć zewnętrzne w postaci InfluxDB, czy też MQTT, albo Prometheus. ?

Co myślicie o tym ?

Ew. gdzie w kodzie najlepiej byłoby się wpiąć by esportować do w/w systemów ? (moge napisać coś, choć tak eleganckie to pewnie nie będzie ;-) )

PS.
dobrze byloby też mieć możliwość wyeksportowania danych historyczny prezentowanych w eliczniku do tegoż influxa, w internetach są gotowce konwertujące XLSa/CSV do influxa, ale może da się to zrobić jakoś przyjemnie w AMIplus ?

[PiotrMachowski]

Ta integracja zapisuje dane godzinowe bezpośrednio do bazy danych tutaj.

Możesz ewentualnie spróbować pobawić się tym skryptem - importuje on dane do bazy PostgreSQL

W sumie, to najbardziej odpornym rozwiązaniem chyba by było pobieranie danych z bazy HA i wrzucanie ich do Influxa

[mmg1t]

tutaj

o, super, dokladnie o tym myslalem :)

tym skryptem

ciekawe, wyglada calkiem dobrze, dzieki :)

odpornym(..)influxa

tak, wlasnie proboje to zrobic, wygląda na to że homeassistant potrafi pisac do influxa stany encji,
... oraz w druga strone - uzywać ich do sensorów:) wyglada b.interesująco

doc: https://www.home-assistant.io/integrations/influxdb

[PiotrMachowski]

homeassistant potrafi pisac do influxa stany encji,

taaaak, ale dane godzinne nie są zapisywane jako encja, tylko bezpośrednio jako statystyki. Może dla nich też działa, ale musiałbyś spróbować

[mmg1t]

wyglada na to ze dziala :)

gotowiec z https://www.home-assistant.io/integrations/influxdb
influxdb:
api_version: 2
(...)

Flex query w Grafanie, czary mary i sa wszystkie wartosci (po dwie, bo restartowalem wiec wczytalo to samo):

from(bucket: "BUCKET_NAME")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r.entity_id =~ /tauron/ )
|> filter(fn: (r) => r["_measurement"] == "kWh")
|> filter(fn: (r) => r["_field"] == "value")
|> aggregateWindow(every: v.windowPeriod, fn: mean, createEmpty: false)
|> yield(name: "mean")

[mmg1t]

sa 4 pozycje z tauron_importer. ..
=> Tauron AMIplus 59*** balanced consumption
=> Tauron AMIplus 59*** balanced consumption
=> ... "consumption"
=> ... "generation"

za "wczoraj": There is no data for this period.

[mmg1t]

aaaaa ..jeest !!!! 2 dni wstecz :) za 6 luty !

[PiotrMachowski]

I powinno być zaciągnięte rok wstecz ;)

[mmg1t]

tak :) zaciaglo :) ...skoro to zassało ... to teraz to tylko wypychac do influxa ...

async_add_external_statistics(self.hass, metadata, statistic_data)

zastanawiam sie jak to ladnie zrobic ...

kazdorazowo zaciaga wszystko ? czy sprawdza w HA (recorder?) czy wpis juz jest ?

[PiotrMachowski]

Rok wstecz zaciąga raz, po dodaniu integracji. Potem zaciąga miesiąc, odfiltrowuje dane sprzed ostatniej wartości ze statystyk (tu sprawdza w recorderze), a potem wrzuca wszystkie nowe dane do statystyk

[mmg1t]

moze ktoś skorzysta :)
te statystyki siedzą w bazie SQL lite homeasistanta ... wiec moze najprosciej bedzie stamtad ciagnac:

przykladowo:

SELECT start,state,sum
FROM statistics_meta
INNER JOIN statistics
ON statistics_meta.id = statistics.metadata_id
AND statistics_meta.statistic_id like "tauron_importer:%_consumption"
AND statistics_meta.statistic_id NOT like "%balanced_consumption"
AND statistics_meta.source = "tauron_importer"
ORDER by start;

start = data/godzina za kiedy jest wpis
state = "diff" pobrane/oddane
sum = obecny stan _consumption

po poprawie zapytania na "%_generation" - to samo dla generowanej czesci (slupek drugiego koloru na wykresie)

więc jakis mechanizm synchronizacyjny (copy w jedna strone) do rozważenia
-=-=-=
inna opcja jeszcze tak OFT: to migracja HA z sqllite na postgresa...łatwiej zarządzac "puchnięciem" bazy SQLite ... a w przypadku tego pluginu mozna jakies triggery zapiac

[mmg1t]

nawiasem zastanawiam sie skad/poco sa dwa rodzaje (te same wartosci??)
tauron_importer:5**************_balanced_generation
vs
tauron_importer:5**************_generation

oraz

tauron_importer:5**************_consumption
vs
tauron_importer:5**************_balanced_consumption

[PiotrMachowski]

To są dane z bilansowania godzinowego