Använda Azure Stream Analytics med dedikerad SQL-pool i Azure Synapse Analytics

Artikel
06/01/2023

Azure Stream Analytics är en fullständigt hanterad tjänst som ger låg latens, hög tillgänglighet och skalbar komplex händelsebearbetning över strömmande data i molnet. Du kan lära dig grunderna genom att läsa Introduktion till Azure Stream Analytics. Du kan sedan lära dig hur du skapar en lösning från slutpunkt till slutpunkt med Stream Analytics genom att följa självstudien Kom igång med Azure Stream Analytics .

I den här artikeln får du lära dig hur du använder din dedikerade SQL-pool som utdatamottagare för datainmatning med högt dataflöde med Azure Stream Analytics-jobb.

Förutsättningar

Azure Stream Analytics-jobb – Om du vill skapa ett Azure Stream Analytics-jobb följer du stegen i självstudien Kom igång med Azure Stream Analytics för att:

Skapa event hubs-indata

Konfigurera och starta händelsegeneratorprogrammet. Den här appen skickar data från en klient via dina Event Hubs. JSON-strukturen för data ser ut så här:

{
    RecordType: "",
    SystemIdentity: "",
    FileNum: ,
    SwitchNum: "",
    CallingNum: "",
    CallingIMSI: "",
    CalledNum: "",
    CalledIMSI: "",
    DateS: "",
    TimeS: "",
    TimeType: ,
    CallPeriod: ,
    CallingCellID: "",
    CalledCellID: "",
    ServiceType: "",
    Transfer: ,
    IncomingTrunk: "",
    OutgoingTrunk: "",
    MSRN: "",
    CalledNum2: "",
    FCIFlag: "",
    callrecTime: "",
    EventProcessedUtcTime: "",
    PartitionId: ,
    EventEnqueuedUtcTime: ""
}

Etablera ett Stream Analytics-jobb
Ange jobbindata och fråga

Dedikerad SQL-pool – Om du vill skapa en ny dedikerad SQL-pool följer du stegen i Snabbstart: Skapa en dedikerad SQL-pool.

Ange strömmande utdata så att de pekar på din dedikerade SQL-pool

Steg 1

Från Azure Portal går du till Stream Analytics-jobbet och klickar på Utdata under menyn Jobbtopologi.

Steg 2

Klicka på knappen Lägg till och välj Azure Synapse Analytics i den nedrullningsbara menyn.

Välj Azure Synapse Analytics

Steg 3

Ange följande värden:

Utdataalias: Ange ett eget namn för det här jobbets utdata.
Prenumeration:
- Om din dedikerade SQL-pool finns i samma prenumeration som Stream Analytics-jobbet klickar du på Välj Azure Synapse Analytics från dina prenumerationer.
- Om din dedikerade SQL-pool finns i en annan prenumeration klickar du på Ange Azure Synapse Analytics-inställningar manuellt.
Databas: Välj måldatabasen i listrutan.
Användarnamn: Ange användarnamnet för ett konto som har skrivbehörighet för databasen.
Lösenord: Ange lösenordet för det angivna användarkontot.
Tabell: Ange namnet på måltabellen i databasen.
klicka på knappen Spara

Ifyllt formulär för Azure Synapse Analytics

Steg 4

Innan du kan köra ett test måste du skapa tabellen i din dedikerade SQL-pool. Kör följande skript för att skapa tabeller med hjälp av SQL Server Management Studio (SSMS) eller val av frågeverktyg.

CREATE TABLE SensorLog
(
    RecordType VARCHAR(2)
    , SystemIdentity VARCHAR(2)
    , FileNum INT
    , SwitchNum VARCHAR(50)
    , CallingNum VARCHAR(25)
    , CallingIMSI VARCHAR(25)
    , CalledNum VARCHAR(25)
    , CalledIMSI VARCHAR(25)
    , DateS VARCHAR(25)
    , TimeS VARCHAR(25)
    , TimeType INT
    , CallPeriod INT
    , CallingCellID VARCHAR(25)
    , CalledCellID VARCHAR(25)
    , ServiceType VARCHAR(25)
    , [Transfer] INT
    , IncomingTrunk VARCHAR(25)
    , OutgoingTrunk VARCHAR(25)
    , MSRN VARCHAR(25)
    , CalledNum2 VARCHAR(25)
    , FCIFlag VARCHAR(25)
    , callrecTime VARCHAR(50)
    , EventProcessedUtcTime VARCHAR(50)
    , PartitionId int
    , EventEnqueuedUtcTime VARCHAR(50)
    )
WITH (DISTRIBUTION = ROUND_ROBIN)

Steg 5

Klicka på jobbnamnet på Azure Portal för Stream Analytics-jobbet. Klicka på knappen Test i fönstret Utdatainformation .

Testknappen för outpout-information När anslutningen till databasen lyckas visas ett meddelande i portalen.

Steg 6

Klicka på menyn Fråga under Jobbtopologi och ändra frågan för att infoga data i stream-utdata som du skapade. Klicka på knappen Testa vald fråga för att testa frågan. Klicka på knappen Spara fråga när frågetestet lyckas.

Spara fråga