Megosztás a következőn keresztül:

Referenciaadatok JOIN

✅ Azure Stream Analytics ✅ Fabric Eventstream

Egy szokásos forgatókönyvben egy eseményfeldolgozó motort használunk a streamelési adatok nagyon alacsony késésű kiszámításához. A felhasználóknak sok esetben korrelálniuk kell a tárolt előzményadatokat vagy egy lassú adathalmazt (más néven referenciaadatokat) a valós idejű eseménystreamel, hogy intelligensebb döntéseket hozzanak a rendszerről. Csatlakoztassa például az eseménystreamemet egy statikus adatkészlethez, amely ip-címeket képez le helyekre. Ez az egyetlen, a Stream Analyticsben támogatott JOIN, ahol nincs szükség időkorlátra. A referenciaadatok eszközspecifikus küszöbértékekkel is használhatók.

példa

Ha egy haszongépjármű regisztrálva van az útdíjszolgáltatónál, akkor anélkül haladhatnak át az útdíj-standon, hogy ellenőrzés céljából megállnának. Egy haszongépjármű-regisztrációs keresési táblát használunk az összes lejárt regisztrációval rendelkező haszongépjármű azonosítására.

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'

A referenciaadatok JOIN-jának sajátosságai

  • A Referenciaadat-illesztés használatához meg kell határozni egy bemeneti forrást a referenciaadatokhoz.
  • A join referenciaadatok a belső JOIN (alapértelmezett) és a bal oldali külső JOIN esetében támogatottak, hivatkozási adatokkal a JOIN operátor jobb oldalán.
  • Az adattípusok fontos szempontok az illesztési predikátum (ON záradék) kiértékelésében. Előfordulhat, hogy a különböző adattípusok (1.0 és "1") hasonló értékei nem egyeznek. Kifejezetten ajánlott a kulcsok közös típussá alakítása.
  • A referenciaadatok lehetnek statikusak (csak egyszer tölthetők be) vagy dinamikusak (rendszeresen frissítve). A referenciaadatok azonban még a dinamikus esetben sem teszik meg az idő előrehaladását, ezért a bal oldali streamnek új eseményeket kell lekérnie a kimenetek előállításához. További információkért tekintse meg, hogyan halad előre az idő az Azure Stream Analyticsben .

Teljesítménnyel kapcsolatos szempontok

A teljesítménycsökkenés megakadályozása érdekében egyszerű kulcsegyenlegekkel (ON záradék) kell meghatározni a referencia-illesztési predikátumokat (ON s.myKey = r.myKeyzáradékot). Összetett kifejezések vagy egyenlőtlenségek használata belsőleg keresztbe illesztéseket eredményez, amelyeket szűrők (teljes vizsgálat és keresés) követnek, amelyek külön-külön befolyásolhatják az általános késést.

Ha lehetséges, helyezze át ezeket az összetett kifejezéseket a WHERE lekérdezési lépés záradékába, vagy csatlakoztassa ugyanazokat a referenciaadatokat többször is egyszerűbb feltételekkel.

Lásd még:

  • Last updated on