Sdílet prostřednictvím

JOIN pro referenční data

✅Eventstream prostředků infrastruktury Azure Stream Analytics ✅

V obvyklém scénáři používáme modul pro zpracování událostí k výpočtu streamovaných dat s velmi nízkou latencí. V mnoha případech uživatelé potřebují korelovat trvalá historická data nebo pomalu se měnící datovou sadu (neboli referenční data) s datovým proudem událostí v reálném čase, aby mohli inteligentněji rozhodovat o systému. Připojte například datový proud událostí ke statické datové sadě, která mapuje IP adresy na umístění. Toto je jediná podporovaná funkce JOIN ve Stream Analytics, kde není nutná dočasná hranice. Referenční data se dají použít také k tomu, aby měly prahové hodnoty specifické pro zařízení.

Příklad

Pokud je komerční vozidlo registrováno u placené společnosti, může projít přes placenou kabinu, aniž by bylo zastaveno pro kontrolu. Použijeme vyhledávací tabulku pro registraci obchodních vozidel k identifikaci všech komerčních vozidel s prošlou registrací.

SELECT I1.EntryTime, I1.LicensePlate, I1.TollId, R.RegistrationId  
FROM Input1 I1 TIMESTAMP BY EntryTime  
JOIN Registration R  
ON I1.LicensePlate = R.LicensePlate  
WHERE R.Expired = '1'

Specifika referenčních dat JOIN

  • Použití funkce JOIN referenčních dat vyžaduje, aby byl definován vstupní zdroj pro referenční data.
  • Funkce JOIN referenčních dat je podporována pro vnitřní SPOJENÍ (výchozí) a levý vnější JOIN s referenčními daty na pravé straně operátoru JOIN.
  • Datové typy jsou důležitým aspektem vyhodnocení predikátu spojení (ON klauzule). Podobné hodnoty u různých datových typů (1.0 a "1") se nemusí shodovat. Explicitně se doporučuje převádět klíče na běžný typ.
  • Referenční data můžou být statická (načtená jenom jednou) nebo dynamická (pravidelně se aktualizují). I v dynamickém případě však referenční data neprovádí průběh času, takže datový proud na levé straně potřebuje získat nové události, aby bylo možné vytvářet výstupy. Další informace najdete také v průběhu času v Azure Stream Analytics .

Důležité informace o výkonu

Aby se zabránilo snížení výkonu, měly by být predikáty referenčního spojení (ON klauzule) definovány prostřednictvím jednoduchých klíčových rovnítků (ON s.myKey = r.myKey). Použití složitých výrazů nebo nerovností interně způsobí křížová spojení následovaná filtry (úplné prohledávání vs. vyhledávání), které můžou mít vliv na celkovou latenci.

Pokud je to možné, přesuňte tyto složité výrazy do WHERE klauzule kroku dotazu nebo spojte stejná referenční data několikrát s jednoduššími podmínkami.

Viz také

  • Last updated on