在 Azure Synapse Analytics 中搭配專用 SQL 集區使用 Azure 串流分析

發行項
12/18/2024

Azure 串流分析是完全受控的服務，可提供透過雲端串流數據進行低延遲、高可用性、可調整的複雜事件處理。您可以閱讀 Azure 串流分析簡介來瞭解基本概念。接著，您可以遵循開始使用 Azure 串流分析教學課程，瞭解如何使用串流分析建立端對端解決方案。

在本文中，您將瞭解如何使用專用 SQL 集區作為輸出接收，以使用 Azure 串流分析作業進行高輸送量數據擷取。

必要條件

Azure 串流分析作業 - 若要建立 Azure 串流分析作業，請遵循開始使用 Azure 串流分析教學課程中的步驟：

建立事件中樞輸入

設定及啟動事件產生器應用程式。此應用程式會透過事件中樞從用戶端傳送數據。資料的 JSON 結構如下所示：

{
    RecordType: "",
    SystemIdentity: "",
    FileNum: ,
    SwitchNum: "",
    CallingNum: "",
    CallingIMSI: "",
    CalledNum: "",
    CalledIMSI: "",
    DateS: "",
    TimeS: "",
    TimeType: ,
    CallPeriod: ,
    CallingCellID: "",
    CalledCellID: "",
    ServiceType: "",
    Transfer: ,
    IncomingTrunk: "",
    OutgoingTrunk: "",
    MSRN: "",
    CalledNum2: "",
    FCIFlag: "",
    callrecTime: "",
    EventProcessedUtcTime: "",
    PartitionId: ,
    EventEnqueuedUtcTime: ""
}

布建串流分析作業
指定作業輸入和查詢

專用 SQL 集區 - 若要建立新的專用 SQL 集區，請遵循快速入門：建立專用 SQL 集區中的步驟。

指定要指向專用 SQL 集區的串流輸出

步驟 1

從 Azure 入口網站移至您的串流分析作業，然後按兩下 [作業拓撲] 選單下的 [輸出]。

步驟 2

單擊 [ 新增 ] 按鈕，然後從下拉功能表中選擇 [Azure Synapse Analytics ]。

選擇 Azure Synapse Analytics

步驟 3

輸入下列值：

輸出別名：輸入此作業輸出的易記名稱。
訂用帳戶：
- 如果您的專用 SQL 集區與串流分析作業位於相同的訂用帳戶中，請按兩下 [從您的訂用帳戶選取 Azure Synapse Analytics]。
- 如果您的專用 SQL 集區位於不同的訂用帳戶中，請按兩下 [手動提供 Azure Synapse Analytics 設定]。
資料庫：從下拉式清單中選取目的地資料庫。
用戶名稱：指定具有資料庫寫入許可權之帳戶的用戶名稱。
密碼：提供指定使用者帳戶的密碼。
數據表：指定資料庫中目標數據表的名稱。
按兩下 [ 儲存] 按鈕

已完成 Azure Synapse Analytics 表單

步驟 4

您必須先在專用 SQL 集區中建立數據表，才能執行測試。使用 SQL Server Management Studio （SSMS）或您選擇的查詢工具執行下表建立腳本。

CREATE TABLE SensorLog
(
    RecordType VARCHAR(2)
    , SystemIdentity VARCHAR(2)
    , FileNum INT
    , SwitchNum VARCHAR(50)
    , CallingNum VARCHAR(25)
    , CallingIMSI VARCHAR(25)
    , CalledNum VARCHAR(25)
    , CalledIMSI VARCHAR(25)
    , DateS VARCHAR(25)
    , TimeS VARCHAR(25)
    , TimeType INT
    , CallPeriod INT
    , CallingCellID VARCHAR(25)
    , CalledCellID VARCHAR(25)
    , ServiceType VARCHAR(25)
    , [Transfer] INT
    , IncomingTrunk VARCHAR(25)
    , OutgoingTrunk VARCHAR(25)
    , MSRN VARCHAR(25)
    , CalledNum2 VARCHAR(25)
    , FCIFlag VARCHAR(25)
    , callrecTime VARCHAR(50)
    , EventProcessedUtcTime VARCHAR(50)
    , PartitionId int
    , EventEnqueuedUtcTime VARCHAR(50)
    )
WITH (DISTRIBUTION = ROUND_ROBIN)

步驟 5

在串流分析作業的 Azure 入口網站上，按兩下您的作業名稱。按兩下 [輸出詳細資料] 窗格中的 [測試] 按鈕。

顯示 [輸出詳細數據] 上 [測試] 按鈕的螢幕快照。

當資料庫連線成功時，您會在入口網站中看到通知。

步驟 6

單擊 [作業拓撲] 下的 [查詢] 功能表，並將查詢變更為將數據插入您所建立的數據流輸出中。按兩下 [ 測試選取的查詢 ] 按鈕來測試您的查詢。當您的查詢測試成功時，按兩下 [ 儲存查詢 ] 按鈕。

儲存查詢

步驟 7

啟動 Azure 串流分析作業。單擊 [概觀] 功能表上的 [開始] 按鈕。

啟動串流分析作業

按兩下 [開始作業] 窗格上的 [ 開始 ] 按鈕。

按一下 [開始]

下一步

如需整合的概觀，請參閱整合其他服務。如需更多開發秘訣，請參閱專用 SQL 集區的設計決策和編碼技術。

共用方式為