Použití Azure Stream Analytics s vyhrazeným fondem SQL v Azure Synapse Analytics

Článek
06/01/2023

Azure Stream Analytics je plně spravovaná služba, která poskytuje vysoce dostupné a škálovatelné komplexní zpracování událostí přes streamovaná data v cloudu s nízkou latencí. Základní informace najdete v tématu Úvod do Azure Stream Analytics. Pak se dozvíte, jak vytvořit ucelené řešení pomocí Stream Analytics, a to podle kurzu Začínáme používat Azure Stream Analytics .

V tomto článku se dozvíte, jak použít vyhrazený fond SQL jako výstupní jímku pro příjem dat s vysokou propustností pomocí úloh Azure Stream Analytics.

Požadavky

Úloha Azure Stream Analytics – Pokud chcete vytvořit úlohu Azure Stream Analytics, postupujte podle kroků v kurzu Začínáme používat Azure Stream Analytics a postupujte následovně:

Vytvoření vstupu služby Event Hubs

Konfigurace a spuštění aplikace generátoru událostí Tato aplikace odesílá data z klienta prostřednictvím služby Event Hubs. Struktura JSON dat vypadá takto:

{
    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: ""
}

Zřízení úlohy Stream Analytics
Zadání vstupu a dotazu úlohy

Vyhrazený fond SQL – Pokud chcete vytvořit nový vyhrazený fond SQL, postupujte podle kroků v tématu Rychlý start: Vytvoření vyhrazeného fondu SQL.

Určení výstupu streamování tak, aby odkazovat na vyhrazený fond SQL

Krok 1

V Azure Portal přejděte na úlohu Stream Analytics a v nabídce Topologie úlohy klikněte na Výstupy.

Krok 2

Klikněte na tlačítko Přidat a v rozevírací nabídce zvolte Azure Synapse Analytics.

Volba Azure Synapse Analytics

Krok 3

Zadejte tyto hodnoty:

Alias výstupu: Zadejte popisný název výstupu této úlohy.
Předplatné:
- Pokud je váš vyhrazený fond SQL ve stejném předplatném jako úloha Stream Analytics, klikněte na Vybrat Azure Synapse Analytics z vašich předplatných.
- Pokud je vyhrazený fond SQL v jiném předplatném, klikněte na Zadat nastavení Azure Synapse Analytics ručně.
Databáze: V rozevíracím seznamu vyberte cílovou databázi.
Uživatelské jméno: Zadejte uživatelské jméno účtu, který má pro databázi oprávnění k zápisu.
Heslo: Zadejte heslo pro zadaný uživatelský účet.
Tabulka: Zadejte název cílové tabulky v databázi.
klikněte na tlačítko Uložit .

Vyplněný formulář Azure Synapse Analytics

Krok 4

Před spuštěním testu budete muset vytvořit tabulku ve vyhrazeném fondu SQL. Pomocí SQL Server Management Studio (SSMS) nebo nástroje pro dotazování podle vašeho výběru spusťte následující skript pro vytvoření tabulky.

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)

Krok 5

Na Azure Portal úlohy Stream Analytics klikněte na název vaší úlohy. Klikněte na tlačítko Testovat v podokně Podrobností výstupu .

Test button on Outpout details Po úspěšném připojení k databázi se na portálu zobrazí oznámení.

Krok 6

Klikněte na nabídku Dotaz v části Topologie úlohy a změňte dotaz tak, aby vkládal data do výstupu streamu, který jste vytvořili. Kliknutím na tlačítko Test vybraného dotazu otestujte svůj dotaz. Po úspěšném testu dotazu klikněte na tlačítko Uložit dotaz.

Uložit dotaz