INTO (Azure Stream Analytics)

Artikel
08/02/2024

INTO (Ausgabestream)

INTO gibt explizit einen Ausgabestream an und ist immer einem SELECT-Ausdruck zugeordnet. Wenn kein Wert angegeben wird, lautet der Standardausgabestream „output“.

Syntax

[ INTO <output_stream> ]

Argumente

output_stream

Gibt den Namen eines Ausgabedatenstroms an.

Einschränkungen

Select kann nicht verwendet werden. INTO in einer WITH-Klausel. Die INTO-Klausel kann bespielsweise nur in der äußersten Unterabfrage verwendet werden.

Beispiel

WITH WAVehicle AS (  
    SELECT TollId, EntryTime AS VehicleEntryTime, LicensePlate, State, Make, Model, VehicleType,    VehicleWeight, Toll, Tag  
    FROM TollTagEntry TIMESTAMP BY EntryTime  
    WHERE State = "WA"
)  
  
SELECT * INTO WAVehicleArchive FROM WAVehicle;  
  
SELECT DateAdd(minute,-3,System.Timestamp()) AS WinStartTime, System.Timestamp() AS WinEndTime, COUNT(*) INTO WAVehicleCount FROM WAVehicle GROUP BY TumblingWindow(minute, 3)

INTO (Shardanzahl)

INTO gibt explizit die Anzahl von Shards in einem Eingabeschritt an, wenn ein Partitionierungsschema (PARTITION BY) angegeben wird. Wenn die Partitionsanzahl nicht angegeben ist, wird die Anzahl der Shards übertragen, wenn partition by identisch ist oder zwei andere.

INTO ist ein Hinweis für das System und kann ignoriert werden, wenn das System feststellt, dass die explizite Spezifikation nicht vorteilhaft ist.

INTO-Syntax

[ INTO <shard_count> ]

INTO-Argumente

shard_count

Gibt die Anzahl von Shards im Upstream Schritt an.

INTO-Einschränkungen und -Einschränkungen

Die Shardanzahl muss größer als 1 sein. Beim Verknüpfen mehrerer Streams muss die Partitionsanzahl aller Eingaben identisch sein.

INTO-Beispiel

WITH Step1 AS (
    SELECT * 
    FROM input 
    PARTITION BY DeviceId
    INTO 10
)

SELECT * INTO [output] FROM Step1 PARTITION BY DeviceId

Freigeben über