Udostępnij za pośrednictwem

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

W tym samouczku pokazano, jak używać edytora bez kodu usługi Stream Analytics do obliczania agregacji na strumieniach 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 Stream Analytics z użyciem edytora bez 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 są zapisywane wyniki
  • Uruchom zadanie usługi Stream Analytics
  • Wizualizacja danych w usłudze Power BI

Wymagania wstępne

Przed rozpoczęciem upewnij się, że wykonasz 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. interval Ustaw parametr 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ąć kroki 3 i 4. Następnie przejdź do tego przewodnika, aby utworzyć pulpit nawigacyjny w czasie rzeczywistym, korzystając z zestawu danych Power BI generowanego przez zadanie Stream Analytics.

  4. Utwórz tabelę o nazwie carsummary przy użyciu dedykowanej puli SQL. Uruchom 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 niewymagającego kodowania

  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 element entrystream.

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

  5. W sekcji Funkcje przejdź do Proces danych, a następnie wybierz rozpocznij na szablonie Rozpocznij z pustym płótnem.

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

  6. Nadaj swojej pracy carsummary nazwę i wybierz opcję Utwórz.

    Zrzut ekranu strony nowego zadania Stream Analytics.

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

    1. W obszarze Grupa konsumentó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. Dla trybu uwierzytelniania upewnij się, że używasz ciągu połączenia do nawiązywania połączenia z centrum zdarzeń: ciąg połączenia.

      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ć nazwy pól lub zmienić typy danych.

    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 pokazujący menu operacji z wybraną opcją

  10. Wybierz kafelek Grupuj według w obszarze roboczym i połącz go z kafelkiem hubu zdarzeń.

    Zrzut ekranu przedstawiający kafelek Grupy połączony z kafelkiem Event Hubs.

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

    1. Agregacja jako liczba.

    2. Pole jako Make, 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 Okno czasowe upewnij się, że wartość jest ustawiona na Tumbling.

      3. W polu 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łącz Grupuj według i Zarządzaj polami elementy.

  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 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ądzania polami z polami o zmienionych nazwach.

  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, jak dane przepływają 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 paska poleceń z wybraną opcją Wyniki, Synapse.

  21. Połącz kafelek Synapse z blokiem 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, które usługa Synapse SQL wykorzystuje do ładowania danych do twojego 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 z puli SQL bezpośredniego dostępu, której użyłeś do utworzenia tabeli carsummary 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 zapisane w tabeli Synapse SQL.

      Zrzut ekranu przedstawiający ustawienia kafelka Synapse.

  23. Wybierz kafelek Synapse i zobacz kartę Podgląd danych w dolnej części strony. Zobaczysz dane przepływające do dedykowanej puli danych 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 Uruchom na pasku poleceń.

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

    Zrzut ekranu przedstawiający stronę

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

    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łącz się z bazą danych przy użyciu trybu DirectQuery 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ę programu Power BI Desktop 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.

    • Oś X jako czas
    • Oś Y jako LiczbaSamochodów
    • Legenda: Utwórz wykres, który można opublikować, aby go zaprezentować. 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

Oprócz usługi Azure Synapse SQL można również użyć bazy danych SQL jako wyjścia z edytora bez kodu do odbierania danych przesyłanych strumieniowo. Następnie użyj łącznika usługi Power BI, aby nawiązać połączenie z bazą danych SQL za pomocą DirectQuery, by 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 bazy danych SQL, zobacz Przekształcanie i pozyskiwanie do bazy danych SQL.

Czyszczenie zasobów

  1. Znajdź wystąpienie usługi Event Hubs i wyświetl 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. Aby potwierdzić usunięcie, wpisz nazwę grupy zasobów.

Następne kroki

W tym samouczku utworzyłeś zadanie Stream Analytics, używając edytora bez kodu do definiowania agregacji i zapisywania wyników w Azure Synapse Analytics. Następnie użyto usługi Power BI do utworzenia pulpitu nawigacyjnego w czasie rzeczywistym w celu wyświetlenia wyników wygenerowanych przez zadanie.

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

  • Last updated on