tól

✅ Azure Stream Analytics ✅ Fabric Eventstream

Megadja a WITH záradékhoz társított bemeneti adatfolyamot vagy lépésnevet. A FROM záradék mindig kötelező minden SELECT utasításhoz.

Szemantika

FROM <input_source> [<PARTITION BY clause>] [<TIMESTAMP BY clause>]
  
<PARTITION BY clause> ::== PARTITION BY <key_spec>

<TIMESTAMP BY clause> ::== TIMESTAMP BY scalar_expression [OVER <key_spec>]

<input_source> ::=   
    {   
      *   
      | { input_name |  input_alias }.*   
      | {  
          [ { input_name | input_alias }. ]  
               { column_name }  
     | expression [ [ AS ] column_alias ]  
         }  
      | column_alias = expression   
    }

<key_spec> ::== { column_name | expression } [,... n]

Érvek

*

Megadja, hogy a FROM záradék összes bemeneti adatfolyamának minden oszlopát vissza kell adni. Az oszlopokat a bemeneti forrás adja vissza a FROM záradékban megadott módon, és abban a sorrendben, amelyben a bejövő streamben léteznek.

input_name | input_alias.*

A * hatókörét a megadott bemeneti névre korlátozza.

column_name

A visszaadni kívánt oszlop neve. Minősítse a column_name, hogy megakadályozza a kétértelmű hivatkozásokat, például akkor, ha a FROM záradék két bemeneti forrása ismétlődő nevű oszlopokkal rendelkezik.

kifejezés

Egy operátor vagy operátor által összekapcsolt állandó, függvény, oszlopnevek, állandók és függvények tetszőleges kombinációja, vagy egy allekérdezés.

Column_alias

Alternatív név a lekérdezés eredményhalmazában szereplő oszlopnév helyére. Megadhat például egy aliast, például a Quantity vagy a Quantity to Date (Mennyiség a dátumig) vagy a Qty (Mennyiség) értéket egy mennyiség nevű oszlophoz. Az aliasok a kifejezések eredményeinek nevét is megadják. column_alias nem használható WHERE, GROUP BY vagy HAVING záradékban.

PARTITON BY <key_spec>

Key_spec alapján<> particionálja az adatokat részhalmazokba. Ez lehetővé teszi, hogy a feladat különböző partíciókat használjon és írjon párhuzamosan. További információért lásd az Azure Stream Analytics-lekérdezések párhozamosításának előnyeit ismertető cikket.

TIMESTAMP BY scalar_expression [OVER <key_spec>]

Lehetővé teszi az események időbélyegét scalar_expression érkezési idő helyett. Az OVER záradék segítségével független ütemterveket hozhat létre az egyes különálló kulcsokhoz. További információt a TIMESTAMP BY dokumentációjában talál.

példa

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