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 ukládat 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řte úlohu Stream Analytics pomocí editoru bez kódu
• Kontrola vstupních dat a schématu
• Vyberte pole, podle které chcete seskupit, a definujte agregace, jako je počet.
• Konfigurujte Azure Synapse Analytics, kam se zapisují 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. Pomocí tohoto odkazu nasaďte šablonu Azure TollApp. interval Nastavte parametr na hodnotu 1. Pro tento krok použijte novou skupinu prostředků.
3. Vytvořte Azure Synapse Analytics pracovní prostor s Vyhrazeným SQL fondem.
4. Vytvořte tabulku s názvem carsummary pomocí vyhrazeného fondu SQL. Spusťte následující skript SQL:

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

Použijte editor bez kódu k vytvoření úlohy Stream Analytics

1. Vyhledejte skupinu prostředků, do které jste nasadili generátor událostí TollApp.

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

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

4. Vyberte instanci entrystream.

   

5. V části Funkce přejděte do části Zpracování dat a pak vyberte Začít 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 spotřebitelů vyberte Použít existující, a pak vyberte Výchozí.

   2. Ujistěte se, že je vybrán Typ serializaceJSON.

   3. V režimu ověřování potvrďte, že se Connection String používá k připojení k centru událostí: Connection string.

      

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

   

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 Event Hub.

    

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

    1. Agregace jako počet.

    2. Pole jako Make, což je vnořené pole uvnitř CarModel.

    3. Vyberte Přidat.

       

    4. V části Nastavení:

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

       2. Pro Časové okno ověřte, že je hodnota nastavená na Převracející se.

       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. Spojte dlaždice 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 Přidat.

       

16. Na stránce Správa polí vyberte Přidat všechna pole.

    

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

    • COUNT_make na CarCount

    • Window_End_Time na č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 vašem 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 zapisují 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, jak 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 během dvou minut vaše úloha přejde do stavu Běžící. Výběrem tlačítka Aktualizovat na stránce zobrazíte změnu stavu od Vytvořeno –> Spouštění –> Běží.

    

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 časové údaje
   • Osa Y jako PočetAut
   • Legenda jako Umožňuje zobrazit graf, který můžete publikovat. Můžete nakonfigurovat automatickou aktualizaci stránky a nastavit ji na 3 minuty, abyste získali zobrazení v reálném čase.

Více 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. Potom se pomocí konektoru Power BI připojte ke SQL databázi pomocí DirectQuery a sestavte řídicí panel 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ů. Odstranění potvrdíte zadáním názvu skupiny prostředků.

Další kroky

V tomto kurzu jste vytvořili úlohu Stream Analytics pomocí editoru bez kódu pro definování agregací a zápis výsledků do Azure Synapse Analytics. Pak jste pomocí Power BI vytvořili řídicí panel v reálném čase, abyste viděli výsledky vytvořené úlohou.

Zpracování datových proudů bezkódově pomocí Azure Stream Analytics