Tworzenie pulpitów nawigacyjnych usługi Power BI w czasie rzeczywistym za pomocą usługi Stream Analytics bez edytora kodu

  • Artykuł

W tym samouczku pokazano, jak używać edytora kodu usługi Stream Analytics do obliczania agregacji strumieni danych w czasie rzeczywistym i przechowywania ich w usłudze Azure Synapse Analytics.

Z tego samouczka dowiesz się, jak wykonywać następujące czynności:

  • Wdrażanie generatora zdarzeń wysyłającego dane do centrum zdarzeń
  • Tworzenie zadania usługi Stream Analytics przy użyciu edytora kodu
  • Przeglądanie danych wejściowych i schematu
  • Wybieranie pól do grupowania według i definiowanie agregacji, takich jak liczba
  • Konfigurowanie usługi Azure Synapse Analytics, do której będą zapisywane wyniki
  • Uruchamianie zadania usługi Stream Analytics
  • Wizualizacja danych w usłudze Power BI

Wymagania wstępne

Przed rozpoczęciem upewnij się, że zostały wykonane następujące kroki:

  1. Jeśli nie masz subskrypcji platformy Azure, utwórz bezpłatne konto.

  2. Wdróż generator zdarzeń TollApp na platformie Azure, użyj tego linku, aby wdrożyć szablon platformy Azure TollApp. Ustaw parametr "interval" na 1. W tym kroku użyj nowej grupy zasobów.

  3. Utwórz obszar roboczy usługi Azure Synapse Analytics z dedykowaną pulą SQL.

    Uwaga

    Jeśli chcesz utworzyć pulpit nawigacyjny usługi Power BI w czasie rzeczywistym bezpośrednio bez przechwytywania danych w bazie danych, możesz pominąć krok 3 i 4, a następnie przejść do tego przewodnika, aby utworzyć pulpit nawigacyjny w czasie rzeczywistym przy użyciu zestawu danych usługi Power BI utworzonego przez zadanie usługi Stream Analytics.

  4. Utwórz tabelę o nazwie carsummary przy użyciu dedykowanej puli SQL. Możesz to zrobić, uruchamiając następujący skrypt SQL:

    CREATE TABLE carsummary   
(  
    Make nvarchar(20),  
    CarCount int,
	times datetime
)
WITH ( CLUSTERED COLUMNSTORE INDEX ) ;

Tworzenie zadania usługi Stream Analytics przy użyciu edytora kodu

  1. Znajdź grupę zasobów, w której wdrożono generator zdarzeń TollApp.

  2. Wybierz przestrzeń nazw usługi Azure Event Hubs.

  3. Na stronie Przestrzeń nazw usługi Event Hubs wybierz pozycję Event Hubs w obszarze Jednostki w menu po lewej stronie.

  4. Wybierz entrystream wystąpienie.

    Zrzut ekranu przedstawiający wybór centrum zdarzeń.

  5. Przejdź do pozycji Przetwarzanie danych w sekcji Funkcje, a następnie wybierz pozycję Rozpocznij od pustego szablonu kanwy .

    Zrzut ekranu przedstawiający wybór przycisku Uruchom na kafelku Rozpocznij z pustą kanwą.

  6. Nadaj zadanie carsummary nazwę i wybierz pozycję Utwórz.

    Zrzut ekranu przedstawiający stronę Nowego zadania usługi Stream Analytics.

  7. Na stronie konfiguracji centrum zdarzeń potwierdź następujące ustawienia, a następnie wybierz pozycję Połączenie.

    1. W obszarze Grupa odbiorców wybierz pozycję Użyj istniejącej, a następnie wybierz pozycję Domyślne.

    2. W polu Typ serializacji upewnij się, że wybrano kod JSON .

    3. W przypadku trybu uwierzytelniania upewnij się, że ciąg Połączenie ion jest używany do nawiązywania połączenia z centrum zdarzeń: ciąg Połączenie ion.

      Zrzut ekranu przedstawiający stronę konfiguracji centrum zdarzeń.

  8. W ciągu kilku sekund zobaczysz przykładowe dane wejściowe i schemat. Możesz usunąć pola, zmienić nazwę pól lub zmienić typ danych, jeśli chcesz.

    Zrzut ekranu przedstawiający podgląd danych w centrum zdarzeń i polach.

  9. Wybierz pozycję Operacje na pasku poleceń, a następnie wybierz pozycję Grupuj według.

    Zrzut ekranu przedstawiający menu Operacje z wybraną grupą na pasku poleceń.

  10. Wybierz kafelek Grupuj według na kanwie i połącz go z kafelkiem centrum zdarzeń.

    Zrzut ekranu przedstawiający kafelek Grupa połączona z kafelkem usługi Event Hubs.

  11. Skonfiguruj kafelek Grupuj według , określając:

    1. Agregacja jako liczba.

    2. Pole jako Ustaw , które jest zagnieżdżonym polem wewnątrz modelu CarModel.

    3. Wybierz Dodaj.

      Zrzut ekranu przedstawiający ustawienie Agregacje na stronie Grupuj według konfiguracji.

    4. W sekcji Ustawienia:

      1. W obszarze Agregacje grupowania według wybierz pozycję Ustaw.

      2. W obszarze Przedział czasu upewnij się, że wartość jest ustawiona na Wirowanie.

      3. W obszarze Czas trwania wprowadź wartość 3 minut

      4. Wybierz pozycję Gotowe w dolnej części strony.

        Zrzut ekranu przedstawiający stronę Grupuj według konfiguracji.

  12. Wybierz pozycję Grupuj według i zwróć uwagę na zgrupowane dane na karcie Podgląd danych w dolnej części strony.

    Zrzut ekranu przedstawiający kartę Podgląd danych dla operacji Grupuj według.

  13. Na pasku poleceń wybierz pozycję Operacje, a następnie pozycję Zarządzaj polami.

  14. Połączenie grupowanie według kafelków pól i zarządzanie nimi.

  15. Na stronie Zarządzanie polami wykonaj następujące kroki:

    1. Dodaj pole Utwórz, jak pokazano na poniższej ilustracji, a następnie wybierz pozycję Dodaj.

      Zrzut ekranu przedstawiający dodanie pola Utwórz.

    2. Wybierz przycisk Dodaj .

      Zrzut ekranu przedstawiający przycisk Dodaj na stronie Zarządzanie polami.

  16. Wybierz pozycję Dodaj wszystkie pola na stronie Konfiguracja zarządzania polami .

    Zrzut ekranu przedstawiający stronę Zarządzanie polami.

  17. Wybierz pozycję ... obok pól, a następnie wybierz pozycję Edytuj , aby zmienić ich nazwę.

    • COUNT_make do CarCount

    • Window_End_Time do czasu

      Zrzut ekranu przedstawiający stronę Zarządzanie polami z zmienioną zmianą nazwy pól.

  18. Wybierz pozycję Gotowe na stronie Zarządzanie polami . Strona Zarządzanie polami powinna wyglądać tak, jak pokazano na poniższej ilustracji.

    Zrzut ekranu przedstawiający stronę Zarządzanie polami z trzema polami.

  19. Wybierz kafelek Zarządzaj polami i zobacz dane przepływające do operacji na karcie Podgląd danych w dolnej części strony.

    Zrzut ekranu przedstawiający kartę Podgląd danych dla operacji Pola zarządzane.

  20. Na pasku poleceń wybierz pozycję Dane wyjściowe, a następnie wybierz pozycję Synapse.

    Zrzut ekranu przedstawiający pasek poleceń z wybraną pozycją Dane wyjściowe usługi Synapse.

  21. PołączenieKafelek Synapse na kafelku Zarządzaj polami na kanwie.

  22. Na stronie Ustawień usługi Synapse wykonaj następujące kroki:

    1. Jeśli konto magazynu zadań nie zostało jeszcze ustawione, wybierz konto usługi Azure Data Lake Storage w grupie zasobów. Jest to konto magazynu używane przez usługę Synapse SQL do ładowania danych do magazynu danych.

      Zrzut ekranu przedstawiający usługę Synapse z wyborem konta magazynu.

    2. Wybierz subskrypcję platformy Azure, w której znajduje się usługa Azure Synapse Analytics.

    3. Wybierz bazę danych dedykowanej puli SQL użytej do utworzenia carsummary tabeli w poprzedniej sekcji.

    4. Wprowadź nazwę użytkownika i hasło do uwierzytelnienia.

    5. Wprowadź nazwę tabeli jako carsummary.

    6. Wybierz pozycję Połącz. Zostaną wyświetlone przykładowe wyniki, które zostaną zapisane w tabeli sql usługi Synapse.

      Zrzut ekranu przedstawiający ustawienia kafelka usługi Synapse.

  23. Wybierz kafelek Synapse i zobacz kartę Podgląd danych w dolnej części strony. Zobaczysz dane przepływające do dedykowanej puli SQL.

    Zrzut ekranu przedstawiający podgląd danych dla kafelka synapse.

  24. Wybierz pozycję Zapisz na górnej wstążce, aby zapisać zadanie, a następnie wybierz pozycję Uruchom. Zrzut ekranu przedstawiający przycisk Start wybrany na pasku poleceń.

  25. Na stronie Uruchamianie zadania usługi Stream Analytics wybierz pozycję Uruchom , aby uruchomić zadanie.

    Zrzut ekranu przedstawiający stronę Uruchamianie zadania usługi Stream Analytics.

  26. Zostanie wyświetlona lista wszystkich zadań usługi Stream Analytics utworzonych przy użyciu edytora kodu bez. W ciągu dwóch minut zadanie przechodzi do stanu Uruchomiono. Wybierz przycisk Odśwież na stronie, aby wyświetlić zmianę stanu z Utworzone —> uruchamianie —> uruchamianie.

    Zrzut ekranu przedstawiający listę zadań.

Tworzenie wizualizacji usługi Power BI

  1. Pobierz najnowszą wersję programu Power BI Desktop.

  2. Użyj łącznika usługi Power BI dla usługi Azure Synapse SQL.

    Zrzut ekranu przedstawiający program Power BI Desktop z wybraną usługą Azure i usługą Synapse Analytics SQL.

  3. Połączenie do bazy danych za pomocą polecenia Zapytanie bezpośrednie i użyj tego zapytania, aby pobrać dane z bazy danych

    SELECT [Make],[CarCount],[times]
FROM [dbo].[carsummary]
WHERE times >= DATEADD(day, -1, GETDATE())

    Zrzut ekranu przedstawiający konfigurację usługi Power BI Destop w celu nawiązania połączenia z usługą Azure Synapse SQL Database.

    Przejdź do karty Baza danych i wprowadź swoje poświadczenia (nazwę użytkownika i hasło), aby nawiązać połączenie z bazą danych i uruchomić zapytanie.

  4. Wybierz pozycję Załaduj , aby załadować dane do usługi Power BI.

  5. Następnie możesz utworzyć wykres liniowy za pomocą polecenia

    • Oś X jako czas
    • Oś Y jako CarCount
    • Legenda jako Utwórz zobaczysz wykres, który można opublikować. Możesz skonfigurować automatyczne odświeżanie strony i ustawić je na 3 minuty, aby uzyskać widok w czasie rzeczywistym. Zrzut ekranu przedstawiający pulpit nawigacyjny usługi Power BI przedstawiający dane podsumowania samochodu.

Więcej opcji

Z wyjątkiem usługi Azure Synapse SQL, możesz również użyć usługi SQL Database jako danych wyjściowych edytora bez kodu w celu odbierania danych przesyłanych strumieniowo. Następnie użyj łącznika usługi Power BI, aby połączyć usługę SQL Database z bazą danych za pomocą zapytania bezpośredniego, a także utworzyć pulpit nawigacyjny w czasie rzeczywistym.

Dobrym rozwiązaniem jest również utworzenie pulpitu nawigacyjnego w czasie rzeczywistym przy użyciu danych przesyłanych strumieniowo. Aby uzyskać więcej informacji na temat danych wyjściowych usługi SQL Database, zobacz Przekształcanie i pozyskiwanie do usługi SQL Database.

Czyszczenie zasobów

  1. Znajdź wystąpienie usługi Event Hubs i zapoznaj się z listą zadań usługi Stream Analytics w sekcji Przetwarzanie danych . Zatrzymaj wszystkie uruchomione zadania.
  2. Przejdź do grupy zasobów użytej podczas wdrażania generatora zdarzeń TollApp.
  3. Wybierz pozycję Usuń grupę zasobów. Wpisz nazwę grupy zasobów, aby potwierdzić usunięcie.

Następne kroki

W tym samouczku utworzono zadanie usługi Stream Analytics przy użyciu edytora kodu, aby zdefiniować agregacje i zapisać wyniki w usłudze Azure Synapse Analytics. Następnie użyto usługi Power BI do utworzenia pulpitu nawigacyjnego w czasie rzeczywistym, aby wyświetlić wyniki wygenerowane przez zadanie.

Brak przetwarzania strumienia kodu za pomocą usługi Azure Stream Analytics