使用串流分析無程式碼編輯器建置即時 Power BI 儀表板

本教學示範如何使用 Stream Analytics 無程式碼編輯器，計算即時資料串流的彙總數據，並將其儲存在 Azure Synapse Analytics。

在本教學課程中，您會了解如何：

• 部署可將資料傳送至事件中樞的事件產生器
• 使用無程式碼編輯器創建 Stream Analytics 職缺
• 檢閱輸入資料和結構描述
• 選擇欄位進行分組，並定義彙總方式，如計數
• 設定 Azure Synapse Analytics 以撰寫結果
• 執行串流分析作業
• 將 Power BI 中的資料視覺化

必要條件

在開始之前，務必完成以下步驟：

1. 如果您沒有 Azure 訂閱，請建立免費帳戶。
2. 將 TollApp 事件產生器部署到 Azure。 請使用此連結部署 TollApp Azure 範本。 將參數設 interval 為 1。 這一步請使用新的資源群組。
3. 建立一個搭配專用的 SQL 集區的 Azure Synapse Analytics 工作區。
4. 用你的專用 SQL 池建立一個命名carsummary。 執行以下 SQL 腳本：

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

使用無程式碼編輯器來建立串流分析工作

1. 找到你部署 TollApp 事件產生器的資源群組。

2. 選取 Azure 事件中樞命名空間。

3. 在事件中心命名空間頁面，左側選單的實體選項中選擇事件中心。

4. 選擇entrystream實例。

   

5. 在 功能 區塊中，前往 處理資料，然後在 空白畫布 範本上選擇 開始。

   

6. 為您的作業carsummary命名，然後選擇建立。

   

7. 在 [事件中樞] 設定頁面上，確認下列設定，然後選取 [連線]。

   1. 針對 [ 取用者] 群組，選取 [ 使用現有的]，然後選取 [ 預設]。

   2. 針對 [串行化類型]，確認 已選取 JSON 。

   3. 針對 驗證模式，確認使用 連接字串 來連線到您的事件中樞。

      

8. 幾秒鐘內，你就能看到範例輸入資料和結構。 你可以選擇刪除欄位、重新命名欄位或更改資料型別。

   

9. 選取 命令行上的 [作業 ]，然後選取 [ 分組依據]。

   

10. 選取畫布上的 [分組依據] 圖格，並將其連線至事件中樞圖格。

    

11. 藉由指定下列方式來設定 [分組依據] 圖格：

    1. 彙總為計數。

    2. 欄位即 品牌，這是 CarModel 內巢狀的欄位。

    3. 選取 [新增]。

       

    4. 在 [設定] 區段中：

       1. 針對 [ 群組匯總依據]，選取 [ 製造商]。

       2. 針對 時間視窗，確認值設定為 輪轉。

       3. 關於 持續時間，輸入 3分鐘。

       4. 選取頁面底部的 [完成]。

          

12. 選取 [分組依據]，並注意頁面底部 [數據預覽] 索引標籤中的分組數據。

    

13. 在命令列上，選取操作，然後選取管理欄位。

14. 將群組依據和管理欄位磁貼連接起來。

15. 在 [ 管理欄位 ] 頁面上，遵循下列步驟：

    1. 新增 [製作] 欄位，如下圖所示，然後選取 [新增]。

       

    2. 選取 [新增]。

       

16. 在 [管理欄位] 組態頁面上選取 [新增所有欄位]。

    

17. 選取欄位旁的 [...]，然後選取 [編輯] 以重新命名欄位。

    • COUNT_make 轉換為 CarCount

    • Window_End_Time 到 times

      

18. 選取 完成 在 管理欄位 頁面上。 [管理欄位] 頁面應如下圖所示。

    

19. 選取 [ 管理欄位 ] 圖格，然後在頁面底部的 [數據預覽 ] 索引標籤中查看流入作業的數據。

    

20. 在命令行上，選取 [輸出]，然後選取 [ Synapse]。

    

21. 將 [Synapse] 圖格連線到畫布上的 [管理欄位] 圖格。

22. 在 [ Synapse 設定] 頁面上，遵循下列步驟：

    1. 如果尚未設定作業記憶體帳戶，請選取資源群組中的 Azure Data Lake Storage 帳戶。 這是 Synapse SQL 用來將數據載入數據倉儲的記憶體帳戶。

       

    2. 選取 Azure Synapse Analytics 所在的 Azure 訂用帳戶。

    3. 選取您在上一節中用來建立 carsummary 數據表的專用 SQL 集區資料庫。

    4. 輸入要驗證的使用者名稱和密碼。

    5. 輸入資料表名稱作為 carsummary。

    6. 選取 Connect。 你會看到寫入 Synapse SQL 表的範例結果。

       

23. 選取 [Synapse ] 圖格，並查看 頁面底部的 [數據預覽 ] 索引卷標。 您會看到數據流向專用 SQL 集區。

    

24. 選取頂端功能區中的 [儲存] 以儲存您的工作，然後選取 [開始]。

25. 在 [ 啟動串流分析作業 ] 頁面上，選取 [ 開始 ] 以執行您的作業。

    

26. 接著，您會看到使用無程式代碼編輯器建立的所有串流分析作業清單。 在兩分鐘內，您的作業會進入執行狀態。 請在頁面上選擇 「重新整理 」按鈕，查看狀態從已建立 -> 開始 -> 執行中。

    

建立 Power BI 視覺效果

1. 下載最新版本 的 Power BI Desktop。

2. 使用適用於 Azure Synapse SQL 的 Power BI 連接器。

   

3. 使用 DirectQuery 連接你的資料庫，並用這個查詢從資料庫取得資料

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

   

   切換到 資料庫 分頁，輸入你的憑證（使用者名稱和密碼）即可連接資料庫並執行查詢。

4. 選擇 載入 以將資料載入 Power BI。

5. 然後，您可以建立折線圖

   • X 軸作為時間
   • Y 軸代表汽車數量
   • Legend as Make You 可以看到一張你可以發佈的圖表。 您可以設定自動頁面重新整理，並將其設定為 3 分鐘，以取得即時的檢視。

其他選項

除了 Azure Synapse SQL，你也可以用 SQL Database 作為無程式碼編輯器輸出來接收串流資料。 接著用 Power BI 連接器，透過 DirectQuery 連接 SQL 資料庫，建立即時儀表板。

您也可以選擇使用串流資料建置即時儀表板。 如需 SQL Database 輸出的詳細資訊，請參閱轉換和內嵌至 SQL Database。

清除資源

1. 找到你的 Event Hubs 實例，並在 流程資料 區塊下查看 Stream Analytics 職缺清單。 停止任何運行中的作業。
2. 移至部署 TollApp 事件產生器時所使用的資源群組。
3. 選取 [刪除資源群組]。 要確認刪除，請輸入資源群組名稱。

下一步

在這個教學中，你透過使用無程式碼編輯器定義彙整，並將結果寫入 Azure Synapse Analytics 來建立一個 Stream Analytics 的工作。 接著你用 Power BI 建立一個即時儀表板，查看工作產生的結果。

使用 Azure Stream Analytics 進行無程式碼串流處理