Korzystanie z usługi Azure Stream Analytics z dedykowaną pulą SQL w usłudze Azure Synapse Analytics

Azure Stream Analytics to w pełni zarządzana usługa zapewniająca małe opóźnienia, wysoce dostępne, skalowalne złożone przetwarzanie zdarzeń za pośrednictwem danych przesyłanych strumieniowo w chmurze. Podstawy możesz poznać, czytając artykuł Wprowadzenie do usługi Azure Stream Analytics. Następnie możesz dowiedzieć się, jak utworzyć kompleksowe rozwiązanie za pomocą usługi Stream Analytics, postępując zgodnie z samouczkiem Rozpoczynanie pracy z usługą Azure Stream Analytics .

W tym artykule dowiesz się, jak używać dedykowanej puli SQL jako ujścia danych wyjściowych do pozyskiwania danych o wysokiej przepływności za pomocą zadań usługi Azure Stream Analytics.

Wymagania wstępne

• Zadanie usługi Azure Stream Analytics — aby utworzyć zadanie usługi Azure Stream Analytics, wykonaj kroki opisane w samouczku Rozpoczynanie pracy z usługą Azure Stream Analytics , aby:

  1. Tworzenie danych wejściowych usługi Event Hubs

  2. Konfigurowanie i uruchamianie aplikacji generatora zdarzeń. Ta aplikacja wysyła dane z klienta za pośrednictwem usługi Event Hubs. Struktura JSON danych wygląda następująco:

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

  3. Aprowizuj zadanie usługi Stream Analytics

  4. Określanie danych wejściowych i zapytań dotyczących zadania

• Dedykowana pula SQL — aby utworzyć nową dedykowaną pulę SQL, wykonaj kroki opisane w przewodniku Szybki start: tworzenie dedykowanej puli SQL.

Określanie danych wyjściowych przesyłania strumieniowego w celu wskazania dedykowanej puli SQL

Krok 1

W Azure Portal przejdź do zadania usługi Stream Analytics i kliknij pozycję Dane wyjściowe w menu Topologia zadania.

Krok 2

Kliknij przycisk Dodaj i wybierz pozycję Azure Synapse Analytics z menu rozwijanego.

Krok 3

Podaj następujące wartości:

• Alias wyjściowy: wprowadź przyjazną nazwę dla danych wyjściowych tego zadania.
• Subskrypcja:
  • Jeśli dedykowana pula SQL znajduje się w tej samej subskrypcji co zadanie usługi Stream Analytics, kliknij pozycję Wybierz Azure Synapse Analytics z subskrypcji.
  • Jeśli dedykowana pula SQL znajduje się w innej subskrypcji, kliknij pozycję Podaj ustawienia usługi Azure Synapse Analytics ręcznie.
• Baza danych: wybierz docelową bazę danych z listy rozwijanej.
• Nazwa użytkownika: określ nazwę użytkownika konta, które ma uprawnienia do zapisu dla bazy danych.
• Hasło: podaj hasło dla określonego konta użytkownika.
• Tabela: określ nazwę tabeli docelowej w bazie danych.
• kliknij przycisk Zapisz

Krok 4

Przed uruchomieniem testu należy utworzyć tabelę w dedykowanej puli SQL. Uruchom następujący skrypt tworzenia tabeli przy użyciu SQL Server Management Studio (SSMS) lub wybranego narzędzia do wykonywania zapytań.

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 zadania usługi Stream Analytics kliknij nazwę zadania. Kliknij przycisk Test w okienku Szczegóły danych wyjściowych .

Po pomyślnym nawiązaniu połączenia z bazą danych w portalu zostanie wyświetlone powiadomienie.

Krok 6

Kliknij menu Zapytanie w obszarze Topologia zadania i zmień zapytanie, aby wstawić dane do utworzonych danych wyjściowych strumienia. Kliknij przycisk Testuj wybrane zapytanie , aby przetestować zapytanie. Kliknij przycisk Zapisz zapytanie , gdy test zapytania zakończy się pomyślnie.

Krok 7

Uruchom zadanie usługi Azure Stream Analytics. Kliknij przycisk Start w menu Przegląd .

Kliknij przycisk Start w okienku zadania uruchamiania.

Następne kroki

Aby zapoznać się z omówieniem integracji, zobacz Integrowanie innych usług. Aby uzyskać więcej porad dotyczących programowania, zobacz Projektowanie decyzji i technik kodowania dla dedykowanej puli SQL.