Základní dataIoTPlány Performance a Scale

Časové řady IoT a metrik

Přijímejte vzorky ze senzorů a metrik, uchovávejte surová data, jak dlouho potřebujete, kopírujte je do řad s dlouhou retencí a podle potřeby agregujte do bucketů.

pro každou řadu
Retence
pravidla kopírování
Auto
k hledání řad
Štítky
Krok 1 z 6
Vytvoření řady

Uchovávejte surové vzorky 24 hodin a označte je budovou a typem.

Ukázková relaceplaying
# Vytvoření řady
hotkv> TS.CREATE temp:b4:f2 RETENTION 86400000 LABELS building b4 type temperature
OK

Animovaný průvodce se skutečnými příkazy HotKV a ukázkovými odpověďmi. Kliknutím na kterýkoli krok na něj přeskočíte. Příkazy a odpovědi zůstávají anglicky, přesně tak, jak je v HotKV zadáváte a vidíte.

Problém

Tisíce senzorů posílají každých pár sekund hodnotu. Surová data jsou potřeba několik hodin pro alerting, rok historie pro reporty a hledání správné řady znamená vyhledávání podle budovy, patra nebo typu zařízení. Provozovat na to samostatnou databázi časových řad je další systém k provozu.

Jak to řeší HotKV

Časové řady v HotKV mají dobu retence a štítky. Zařízení přidávají vzorky pomocí TS.ADD, pravidlo downsamplingu zkopíruje každý nový vzorek do řady, kterou uchováváte déle, a TS.AGG agreguje libovolný rozsah do bucketů pevné šířky funkcemi avg, min, max a dalšími.

Krok za krokem

Co se děje, příkaz po příkazu

  1. 01

    Vytvoření řady

    Uchovávejte surové vzorky 24 hodin a označte je budovou a typem.

    TS.CREATE temp:b4:f2 RETENTION 86400000 LABELS building b4 type temperature
  2. 02

    Dlouhodobá řada

    Druhá řada, která uchovává vzorky rok.

    TS.CREATE temp:b4:f2:1y RETENTION 31536000000
  3. 03

    Kopírování vzorků do ní

    Každý nový vzorek se zkopíruje také do dlouhodobé řady. Čtěte ji jako hodinové průměry pomocí TS.AGG.

    TS.DOWNSAMPLE temp:b4:f2 temp:b4:f2:1y avg 3600000
  4. 04

    Příjem vzorků

    Senzory hlásí přes bránu. * používá čas serveru.

    TS.ADD temp:b4:f2 * 21.4
  5. 05

    Agregace pro graf

    Pětiminutové průměry za poslední hodinu, připravené k vykreslení.

    TS.AGG temp:b4:f2 1790982000000 1790985600000 300000 avg
  6. 06

    Hledání řad podle štítku

    Každá řada teploty v budově b4.

    TS.LIST LABEL building b4
Kam to zapadá

Scénáře z praxe

Chytré budovy

Teplota, CO2 a obsazenost se ukládají pro každé patro, se surovými daty na den a hodinovými průměry pro reporty.

Telemetrie flotily

Rychlost vozidla, baterie a údaje o motoru se průběžně přijímají a vykreslují pro každé vozidlo.

Metriky aplikací

Latence požadavků a počty chyb pro každý endpoint napájejí živé dashboardy bez samostatné databáze metrik.

Zabudováno

Co dostanete

Retence pro každou řadu

Staré vzorky se odstraňují automaticky.

TS.CREATETS.RETENTION

Pravidla downsamplingu

Nové vzorky se kopírují do řady s dlouhou retencí, kterou agregujete při čtení.

TS.DOWNSAMPLE

Agregace do bucketů

Agregujte libovolný rozsah do bucketů pevné šířky.

TS.AGGTS.RANGE

Štítky

Hledejte řady podle hodnoty štítku.

TS.LISTTS.INFO
Reference:TS.CREATETS.ADDTS.DOWNSAMPLETS.AGG

Časté otázky

Mohu posílat vlastní časové značky?

Ano. Místo * předejte TS.ADD čas Unix v milisekundách.

Které agregace jsou k dispozici?

Úplný seznam, včetně avg, min, max a sum, najdete v referenci TS.AGG.

Které plány je zahrnují?

Časové řady jsou součástí plánů Performance a Scale.

Související případy použití

Analytika

Analytika v reálném čase

Počítejte události, jak se dějí, řaďte to, co je v trendu, a sledujte, které klíče nesou zátěž.

Prozkoumat
Mobilita

Geoprostorové vyhledávání

Najděte nejbližší řidiče, prodejny nebo zařízení v okruhu či obdélníku, s živými polohami aktualizovanými každých pár sekund.

Prozkoumat
Práce na pozadí

Streamování událostí se skupinami konzumentů

Append-only proudy událostí se skupinami konzumentů, potvrzeními a automatickou obnovou zpráv, které spadlý konzument zanechal.

Prozkoumat

Vyzkoušejte to na své zátěži

HotKV mluví protokolem Redisu, takže na něj můžete nasměrovat stávajícího klienta a spustit tytéž příkazy.

Získat předběžný přístupDalší: Analytika v reálném čase