Vytváření řídicích panelů Power BI v reálném čase bez editoru kódu Stream Analytics

V tomto kurzu se dozvíte, jak pomocí editoru kódu Stream Analytics vypočítat agregace datových proudů v reálném čase a uložit je do Azure Synapse Analytics.

V tomto kurzu se naučíte:

• Nasazení generátoru událostí, který odesílá data do centra událostí
• Vytvoření úlohy Stream Analytics pomocí žádného editoru kódu
• Kontrola vstupních dat a schématu
• Vyberte pole, podle které chcete seskupit, a definujte agregace, jako je počet.
• Konfigurace služby Azure Synapse Analytics, do které se budou zapisovat výsledky
• Spuštění úlohy Stream Analytics
• Vizualizace dat v Power BI

Požadavky

Než začnete, ujistěte se, že jste dokončili následující kroky:

1. Pokud ještě nemáte předplatné Azure, vytvořte si bezplatný účet.

2. Nasaďte generátor událostí TollApp do Azure. Použijte tento odkaz k nasazení šablony Azure TollApp. Nastavte parametr interval na hodnotu 1. A pro tento krok použijte novou skupinu prostředků.

3. Vytvořte pracovní prostor Azure Synapse Analytics s vyhrazeným fondem SQL.

   Poznámka:

   Pokud chcete řídicí panel Power BI v reálném čase sestavit přímo bez zachycení dat do databáze, můžete přeskočit krok č. 3 a 4 a pak přejít k tomuto průvodci a vytvořit řídicí panel v reálném čase s datovou sadou Power BI vytvořenou úlohou Stream Analytics.

4. Vytvořte tabulku s názvem carsummary pomocí vyhrazeného fondu SQL. Můžete to provést spuštěním následujícího skriptu SQL:

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

Použití žádného editoru kódu k vytvoření úlohy Stream Analytics

1. Vyhledejte skupinu prostředků, ve které byl nasazen generátor událostí TollApp.

2. Vyberte obor názvů služby Azure Event Hubs.

3. Na stránce Obor názvů služby Event Hubs vyberte v části Entity v nabídce vlevo možnost Event Hubs.

4. Vyberte entrystream instanci.

   

5. Přejděte do části Zpracování dat v části Funkce a pak vyberte začít na obrazovce Start s prázdnou šablonou plátna .

   

6. Pojmenujte úlohu carsummary a vyberte Vytvořit.

   

7. Na stránce konfigurace centra událostí potvrďte následující nastavení a pak vyberte Připojit.

   1. V případě skupiny Příjemce vyberte Možnost Použít existující a pak vyberte Výchozí.

   2. U typu serializace ověřte, že je vybraný json .

   3. V režimu ověřování ověřte, že se připojovací řetězec používá k připojení k centru událostí: Připojovací řetězec.

      

8. Během několika sekund uvidíte ukázková vstupní data a schéma. Pokud chcete, můžete vypustit pole, přejmenovat pole nebo změnit datový typ.

   

9. Na panelu příkazů vyberte Operace a pak vyberte Seskupovat podle.

   

10. Vyberte dlaždici Seskupit podle na plátně a připojte ji k dlaždici centra událostí.

    

11. Nakonfigurujte dlaždici Seskupovat podle zadáním:

    1. Agregace jako počet.

    2. Pole jako Make (Vytvořit ), což je vnořené pole uvnitř modelu CarModel.

    3. Vyberte Přidat.

       

    4. V části Nastavení:

       1. Pokud chcete agregace seskupit podle, vyberte Vytvořit.

       2. V případě časového intervalu ověřte, že je hodnota nastavená na Přeskakující.

       3. Pro dobu trvání zadejte 3 minuty.

       4. Vyberte Hotovo v dolní části stránky.

          

12. Vyberte Možnost Seskupovat podle a všimněte si seskupených dat na kartě Náhled dat v dolní části stránky.

    

13. Na panelu příkazů vyberte Operations (Operace ) a potom Manage fields (Spravovat pole).

14. Propojení dlaždic Seskupit podle a Správa polí

15. Na stránce Spravovat pole postupujte takto:

    1. Přidejte pole Vytvořit, jak je znázorněno na následujícím obrázku, a pak vyberte Přidat.

       

    2. Vyberte tlačítko Přidat .

       

16. Na stránce Konfigurace spravovat pole vyberte Přidat všechna pole.

    

17. Vyberte ... vedle polí a výběrem možnosti Upravit je přejmenujte.

    • COUNT_make do CarCount

    • Window_End_Time časy

      

18. Na stránce Spravovat pole vyberte Hotovo. Stránka Spravovat pole by měla vypadat, jak je znázorněno na následujícím obrázku.

    

19. Vyberte dlaždici Spravovat pole a na kartě Náhled dat v dolní části stránky se podívejte na data, která do operace proudí.

    

20. Na panelu příkazů vyberte Výstupy a pak vyberte Synapse.

    

21. Připojte dlaždici Synapse k dlaždici Spravovat pole na plátně.

22. Na stránce nastavení Synapse postupujte takto:

    1. Pokud účet úložiště úloh ještě není nastavený, vyberte ve skupině prostředků účet Azure Data Lake Storage. Jedná se o účet úložiště, který synapse SQL používá k načtení dat do datového skladu.

       

    2. Vyberte předplatné Azure, ve kterém se nachází služba Azure Synapse Analytics.

    3. Vyberte databázi vyhrazeného fondu SQL, kterou jste použili k vytvoření carsummary tabulky v předchozí části.

    4. Zadejte uživatelské jméno a heslo k ověření.

    5. Zadejte název tabulky jako carsummary.

    6. Vyberte Připojit. Zobrazí se ukázkové výsledky, které se zapíšou do tabulky Synapse SQL.

       

23. Vyberte dlaždici Synapse a podívejte se na kartu Náhled dat v dolní části stránky. Uvidíte, že data proudí do vyhrazeného fondu SQL.

    

24. Výběrem možnosti Uložit na horním pásu karet uložte úlohu a pak vyberte Spustit.

25. Na stránce Spustit úlohu Stream Analytics vyberte Spustit a spusťte úlohu.

    

26. Pak se zobrazí seznam všech úloh Stream Analytics vytvořených pomocí žádného editoru kódu. A do dvou minut přejde vaše úloha do stavu Spuštěno. Výběrem tlačítka Aktualizovat na stránce zobrazíte změnu stavu od Vytvoření –> Spuštění –> Spuštěno.

    

Vytvoření vizualizace Power BI

1. Stáhněte si nejnovější verzi Power BI Desktopu.

2. Použijte konektor Power BI pro Azure Synapse SQL.

   

3. Připojte se k databázi pomocí DirectQuery a pomocí tohoto dotazu načtěte data z databáze.

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

   

   Přepněte na kartu Databáze a zadejte svoje přihlašovací údaje (uživatelské jméno a heslo) pro připojení k databázi a spuštění dotazu.

4. Výběrem možnosti Načíst načtete data do Power BI.

5. Potom můžete vytvořit spojnicový graf pomocí

   • Osa X jako časy
   • Osa Y jako CarCount
   • Legenda jako Make Uvidíte pak uvidíte graf, který se dá publikovat. Můžete nakonfigurovat automatickou aktualizaci stránky a nastavit ji na 3 minuty, abyste získali zobrazení v reálném čase.

Další možnost

Kromě Azure Synapse SQL můžete k příjmu streamovaných dat použít také sql Database jako výstup editoru bez kódu. Pak pomocí konektoru Power BI připojte službu SQL Database k databázi s DirectQuery i k sestavení řídicího panelu v reálném čase.

Je také dobrou volbou pro vytvoření řídicího panelu v reálném čase se streamovanými daty. Další informace o výstupu služby SQL Database naleznete v tématu Transformace a ingestování do služby SQL Database.

Vyčištění prostředků

1. Vyhledejte instanci služby Event Hubs a prohlédněte si seznam úloh Stream Analytics v části Zpracování dat . Zastavte všechny spuštěné úlohy.
2. Přejděte do skupiny prostředků, kterou jste použili při nasazování generátoru událostí TollApp.
3. Vyberte Odstranit skupinu prostředků. Potvrďte odstranění zadáním názvu skupiny prostředků.

Další kroky

V tomto kurzu jste vytvořili úlohu Stream Analytics pomocí žádného editoru kódu k definování agregací a zápisu výsledků do Azure Synapse Analytics. Pak jste pomocí Power BI vytvořili řídicí panel v reálném čase k zobrazení výsledků vytvořených úlohou.

Bez zpracování datových proudů kódu pomocí Azure Stream Analytics