將數據從 Azure 串流分析擷取至 Azure 數據總管

開始之前，請確定您有現有的串流分析作業或 建立新的作業，然後使用下列步驟來建立 Azure 數據總管連線。

1. 登入 Azure 入口網站。

2. 從 Azure 入口網站 開啟 [所有資源]，然後選取您的串流分析作業。

3. 在 [作業拓撲] 底下，選取 [輸出]。

4. 選取 [新增>Azure 數據總管]。

   

5. 使用下列資訊填入輸出窗體，然後選取 [ 儲存]。

   注意

   您可以使用下列選項來指定叢集和資料庫：

   • 訂用帳戶：從 訂用帳戶選取 [Azure 數據總管]，選取您的訂用帳戶，然後選擇您的叢集和資料庫。
   • 手動：選取 [手動提供 Azure 數據總管] 設定，指定叢集 URI 和資料庫。

   屬性名稱	描述
   輸出別名	此為易記名稱，用於在查詢中將查詢輸出指向這個資料庫。
   訂用帳戶	選取叢集所在的 Azure 訂用帳戶。
   Cluster	識別叢集的唯一名稱。 功能變數名稱 [region].kusto.windows.net 會附加至您提供的叢集名稱。 名稱只能包含小寫字母和數字。 它必須包含 4 到 22 個字元。
   叢集 URI	叢集的數據擷取 URI。 您可以指定 Azure 資料總管或 Azure Synapse 數據總管數據 擷取端點的 URI。
   Database	您傳送輸出的目標資料庫名稱。 資料庫名稱在叢集內必須是唯一而不重複。
   驗證	Microsoft Entra 受控識別 ，可讓您的叢集輕鬆存取其他Microsoft Entra 受保護的資源。 身分識別由 Azure 平台負責管理，因此您不需要佈建或輪替任何密碼。 受控識別設定可讓您針對叢集使用客戶管理的金鑰。
   Table	您要傳送輸出之資料表的名稱。 Azure 串流分析輸出中的數據行名稱和數據類型必須符合 Azure 數據總管數據表的架構。

   

下列範例示範用於新增 Azure 數據總管輸出連接器的 Azure Resource Manager 範本。 您可以在 Azure 入口網站 中編輯和部署範本，以建立連接器。

{
    "$schema": "http://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "streamingJobName": {
            "type": "string",
            "defaultValue": "streamingjob"
        },
        "eventHubNamespace": {
            "type": "string"
        },
        "eventHubKey": {
            "type": "securestring"
        },
        "eventHubName": {
            "type": "string"
        },
        "eventHubConsumerGroupName": {
            "type": "string"
        },
        "streamingUnits": {
            "type": "int",
            "defaultValue": 3
        },
        "ADXClusterUri": {
            "type": "string"
        },
        "ADXDatabaseName": {
            "type": "string"
        },
        "ADXTableName": {
            "type": "string"
        }
    },
    "resources": [
        {
            "apiVersion": "2017-04-01-preview",
            "name": "[parameters('streamingJobName')]",
            "location": "[resourceGroup().location]",
            "type": "Microsoft.StreamAnalytics/StreamingJobs",
            "identity": {
                "type": "systemAssigned"
            },
            "properties": {
                "sku": {
                    "name": "standard"
                },
                "eventsOutOfOrderPolicy": "drop",
                "eventsOutOfOrderMaxDelayInSeconds": 10,
                "compatibilityLevel": "1.2",
                "outputStartMode": "JobStartTime",
                "inputs": [
                    {
                        "name": "inputEventHub",
                        "properties": {
                            "type": "stream",
                            "serialization": {
                                "type": "JSON",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.ServiceBus/EventHub",
                                "properties": {
                                    "serviceBusNamespace": "[parameters('eventHubNamespace')]",
                                    "sharedAccessPolicyName": "RootManageSharedAccessKey",
                                    "sharedAccessPolicyKey": "[parameters('eventHubKey')]",
                                    "eventHubName": "[parameters('eventHubName')]",
                                    "consumerGroupName": "[parameters('eventHubConsumerGroupName')]"
                                }
                            }
                        }
                    }
                ],
                "transformation": {
                    "name": "ProcessSampleData",
                    "properties": {
                        "streamingUnits": "[int(parameters('streamingUnits'))]",
                        "query": "select * from inputEventHub"
                    }
                },
                "outputs": [
                    {
                        "name": "output",
                        "properties": {
                            "serialization": {
                                "type": "CSV",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.Kusto/clusters/databases",
                                "properties": {
                                    "cluster": "[parameters('ADXClusterUri')]",
                                    "table": "[parameters('ADXTableName')]",
                                    "database": "[parameters('ADXDatabaseName')]",
                                    "authenticationMode": "Msi"
                                }
                            }
                        }
                    }
                ]
            }
        }
    ]
}