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

Az Azure Stream Analytics & Eventstream lekérdezési nyelvi referenciája

Az Azure Stream Analytics sql-lekérdezési nyelvet kínál az események streamjeinek átalakításához és számításokhoz.

A T-SQL szintaxis egy részhalmaza

Ez a dokumentum a Stream Analytics lekérdezési nyelvének szintaxisát, használatát és ajánlott eljárásait ismerteti. Az ebben a dokumentumban használt összes példa egy toll booth-forgatókönyvre támaszkodik az alábbiakban leírtak szerint.

A Stream Analytics lekérdezési nyelve a streamelési számításokhoz használt szabványos T-SQL-szintaxis egy részhalmaza.

Az útdíj-stand forgatókönyve

Az útdíjszedési állomás gyakori jelenség – a világ számos gyorsforgalmi útjában, hídján és alagutakban találkozunk velük. Minden útdíjfizetési állomás több útdíjadó standdal rendelkezik, amelyek manuálisak lehetnek – vagyis nem kell fizetniük az útdíjért egy résztvevőnek vagy automatizáltnak –, ahol a stand tetején elhelyezett érzékelő beolvassa a jármű szélvédőjére rögzített RFID-kártyát, miközben ön áthalad az útdíj-standon. Könnyen vizualizálható a járművek áthaladása ezeken az útdíj-állomásokon eseményfolyamként, amelyen érdekes műveletek végezhetők.

Érkezési idő és alkalmazásidő

Minden temporális rendszerben, például az Azure Stream Analyticsben elengedhetetlen az idő előrehaladásának megértése. A rendszeren áthaladó minden eseményhez tartozik egy időbélyeg, amely a System.Timestamp() használatával érhető el. Más szóval a rendszerünk minden eseménye egy időpontot ábrázol. Ez az időbélyeg lehet egy alkalmazásidő, amelyet a felhasználó megadhat a lekérdezésben, vagy a rendszer hozzárendelheti az érkezési idő alapján. Az érkezési idő a bemeneti forrásoktól függően eltérő jelentéssel rendelkezik. Az Azure Event Hub eseményei esetében az érkezési idő az eseményközpont által megadott időbélyeg; Blob Storage esetén ez a blob utolsó módosítási ideje. Az időbélyeg az az időpont, amely releváns az adatok rögzítéséhez vagy elemzéséhez. Ha a felhasználó alkalmazásidőt szeretne használni, ezt a TIMESTAMP BY kulcsszóval teheti meg. A fenti forgatókönyvben a jármű belépése az útdíjszedőbe. Kritikus fontosságú az "időbélyeg" azonosítása a bejövő adatstreamben, ezért gondoskodni kell arról, hogy a rögzített idő is megerősítse az esemény előfordulását. Ha például a számlálókat figyeli, és meg szeretné számolni a számlázott ügyfelek számát, akkor ideális esetben az esemény időbélyegének "sikeres fizetésnek" kell lennie a "számla generált" idő helyett.

IDŐBÉLYEG SZERINT

Az Azure Stream Analyticsben minden esemény jól definiált időbélyegzővel rendelkezik. Ha a felhasználó az alkalmazásidőt szeretné használni, a TIMESTAMP BY kulcsszóval megadhatja a hasznos adat oszlopát, amelyet minden bejövő esemény időbélyegzésére kell használni, hogy bármilyen időbeli számítást hajtson végre, például Ablakozás, Illesztések stb. Ajánlott eljárásként ajánlott a TIMESTAMP BY használatát az érkezési idő függvényében. A TIMESTAMP BY bármely datetime típusú oszlopban használható, és minden ISO 8601-formátum támogatott. A System.Timestamp() csak a Kiválasztásban használható.

Az alábbiakban egy TIMESTAMP BY példát mutatunk be, amely a EntryTime oszlopot használja az események alkalmazásidejeként:

  
SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType, VehicleWeight, Toll, Tag   
FROM TollTagEntry TIMESTAMP BY EntryTime

Mezőnév kis- és nagybetűk bizalmassági foka

Az 1.0 kompatibilitási szinttel létrehozott feladatok mezőnevei kisbetűsre (kis- és nagybetűkre) változnak az Azure Stream Analytics-motor feldolgozásakor. A kis- és nagybetűket támogató bemeneti formátumok, például a JSON esetében ismétlődő mezőkkel rendelkező eseményeket hozhat létre, ha a mezőneveket kis- és nagybetűk érzéketlensége miatt hasonlítják össze. Az ilyen események érvénytelen eseményeknek minősülnek, és a feldolgozás során elvetik.

A kis- és nagybetűk megkülönböztetése megmarad a mezőnevek esetében, ha a Stream Analytics-feladat az 1.1-es vagy újabb kompatibilitási szinttel jön létre. További információkért tekintse meg a kompatibilitási szint konfigurálását ismertető témakört.

Ebben a szakaszban

A Stream Analytics lekérdezési nyelvével kapcsolatos útmutatásért tekintse meg az alábbi témaköröket.

Lásd még:

  • Last updated on