建立 Azure 資料總管叢集與資料庫

Azure 訂用帳戶。建立免費的 Azure 帳戶。

Important

Azure CLI 的 Kusto 擴充功能已過時且未被維護。我們建議使用 PowerShell 或 ARM/Bicep 範本來建立叢集和資料庫。如果你選擇使用 Azure CLI，務必安裝 Kusto 擴充功能，以確保你擁有最新的 CLI 指令Azure Data Explorer。

Azure 訂用帳戶。建立免費的 Azure 帳戶。
您可以使用 Azure Cloud Shell 來執行本文中的程式代碼，而不需要在本機環境中安裝任何專案。
如果您選擇在本機安裝和使用 Azure CLI，請遵循設定參數中的步驟。本文需要 Azure CLI 2.0.4 版或更新版本。執行 az --version 以檢查您的版本。如果您需要安裝或升級，請參閱安裝 Azure CLI 模組。

設定 CLI 參數

如果您在 Azure Cloud Shell 中執行命令，則不需要下列步驟。如果您要在本機執行 CLI，請遵循下列步驟來設定環境：

安裝擴充功能以使用最新的 Kusto CLI 版本：
```
az extension add -n kusto
```
執行下列命令以登入 Azure：
```
az login
```
設定您要在其中建立叢集的訂用帳戶。以您要使用的 Azure 訂用帳戶名稱取代 MyAzureSub：
```
az account set --subscription MyAzureSub
```
設定您要在其中建立叢集的資源群組。將 testrg 取代為您要使用的資源群組名稱：
```
az group create --name testrg --location westus
```

ARM 範本

以下是一個 ARM 範本範例，該範本能以最少設定方式建立 Azure Data Explorer 叢集及該叢集內的資料庫。欲了解完整細節及支援特性，請參閱 ARM 模板叢集參考及 ARM 模板資料庫參考。

{
    "$schema": "https://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "clusters_kustocluster_name": {
            "type": "string",
            "defaultValue": "[concat('kusto', uniqueString(resourceGroup().id))]",
            "metadata": {
                "description": "Name of the cluster to create"
            }
        },
        "databases_kustodb_name": {
            "type": "string",
            "defaultValue": "kustodb",
            "metadata": {
                "description": "Name of the database to create"
            }
        },
        "location": {
            "type": "string",
            "defaultValue": "[resourceGroup().location]",
            "metadata": {
                "description": "Location for all resources."
            }
        }
    },
    "variables": {},
    "resources": [
        {
            "name": "[parameters('clusters_kustocluster_name')]",
            "type": "Microsoft.Kusto/clusters",
            "apiVersion": "2025-02-14",
            "location": "[parameters('location')]",
            "sku": {
                "name": "Standard_E8ads_v5",
                "tier": "Standard",
                "capacity": 2
            }
        },
        {
            "name": "[concat(parameters('clusters_kustocluster_name'), '/', parameters('databases_kustodb_name'))]",
            "type": "Microsoft.Kusto/clusters/databases",
            "apiVersion": "2025-02-14",
            "location": "[parameters('location')]",
            "dependsOn": [
                "[resourceId('Microsoft.Kusto/clusters', parameters('clusters_kustocluster_name'))]"
            ],
            "kind": "ReadWrite",
            "properties": {
                "softDeletePeriod": "P365D",
                "hotCachePeriod": "P31D"
            }
        }
    ]
}

以下是一個 Bicep 範本範例，該範本以最少設定方式建立 Azure Data Explorer 叢集及該叢集內的資料庫。完整細節及支援性質請參見 Bicep cluster reference 及 Bicep資料庫參考。

    @description('Name of the cluster to create')
    param clusterName string = 'kusto${uniqueString(resourceGroup().id)}'
    
    @description('Name of the database to create')
    param databaseName string = 'kustodb'
    
    @description('Location for all resources.')
    param location string = resourceGroup().location
    
    resource cluster 'Microsoft.Kusto/clusters@2025-02-14' = {
      name: clusterName
      location: location
      sku: {
        name: 'Standard_E8ads_v5'
        tier: 'Standard'
        capacity: 2
      }
    }
    
    
    resource database 'Microsoft.Kusto/clusters/databases@2025-02-14' = {
      parent: cluster
      name: databaseName
      location: location
      kind: 'ReadWrite'
      properties: {
        softDeletePeriod: 'P365D'
        hotCachePeriod: 'P31D'
      }
    }

使用下列命令建立叢集：

 New-AzKustoCluster -ResourceGroupName testrg -Name mykustocluster -Location westus2 -SkuTier Standard -SkuCapacity 2 -SkuName 'Standard_E8ads_v5'

設定	建議的值	欄位描述
名稱	mykustocluster	您想要的叢集名稱。
Sku	Standard_E8ads_v5	將用於您的叢集的 SKU。
資源群組名稱	testrg	將在其中建立叢集的資源群組名稱。

您可以使用其他選擇性參數，例如叢集的容量。

執行下列命令來檢查您的叢集是否已成功建立：

Get-AzKustoCluster -Name mykustocluster -ResourceGroupName testrg

確認叢集已成功建立，方法是確認結果中 provisioningState 的值為 Succeeded。

使用下列程式代碼建立叢集：

var tenantId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Directory (tenant) ID
var clientId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Application ID
var clientSecret = "PlaceholderClientSecret"; //Client Secret
var subscriptionId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx";
var credentials = new ClientSecretCredential(tenantId, clientId, clientSecret);
var resourceManagementClient = new ArmClient(credentials, subscriptionId);
var resourceGroupName = "testrg";
var subscription = await resourceManagementClient.GetDefaultSubscriptionAsync();
var resourceGroup = (await subscription.GetResourceGroupAsync(resourceGroupName)).Value;
var clusters = resourceGroup.GetKustoClusters();    
var clusterName = "mykustocluster";
var skuName = KustoSkuName.StandardE8adsV5;
var skuTier = KustoSkuTier.Standard;
var capacity = 5;
var clusterData = new KustoClusterData(
    location: AzureLocation.CentralUS,
    sku: new KustoSku(skuName, skuTier) { Capacity = capacity }
);
await clusters.CreateOrUpdateAsync(WaitUntil.Completed, clusterName, clusterData);

設定	建議的值	欄位描述
clusterName	mykustocluster	您想要的叢集名稱。
skuName	Standard_E8ads_v5	將用於您的叢集的 SKU。
分層	標準	SKU 層級。
容量	數字	叢集實例的數目。
resourceGroupName	testrg	將建立叢集所在的資源群組名稱。

注意

建立叢集 是長時間執行的作業，因此強烈建議使用 CreateOrUpdateAsync，而不是 CreateOrUpdate。

執行下列命令來檢查您的叢集是否已成功建立：

clusterData = (await clusters.GetAsync(clusterName)).Value.Data;

透過確認結果中顯示 provisioningState 為 Succeeded，來確認叢集已成功建立。

使用下列命令建立叢集：

from azure.mgmt.kusto import KustoManagementClient
from azure.mgmt.kusto.models import Cluster, AzureSku
from azure.common.credentials import ServicePrincipalCredentials

#Directory (tenant) ID
tenant_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
#Application ID
client_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
#Client Secret
client_secret = "xxxxxxxxxxxxxx"
subscription_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
credentials = ServicePrincipalCredentials(
    client_id=client_id,
    secret=client_secret,
    tenant=tenant_id
)

location = 'Central US'
sku_name = 'Standard_E8ads_v5'
capacity = 5
tier = "Standard"
resource_group_name = 'testrg'
cluster_name = 'mykustocluster'
cluster = Cluster(location=location, sku=AzureSku(name=sku_name, capacity=capacity, tier=tier))

kusto_management_client = KustoManagementClient(credentials, subscription_id)

cluster_operations = kusto_management_client.clusters

poller = cluster_operations.begin_create_or_update(resource_group_name, cluster_name, cluster)
poller.wait()

設定	建議的值	欄位描述
cluster_name	mykustocluster	您想要的叢集名稱。
sku_name	Standard_E8ads_v5	將用於您的叢集的 SKU。
分層	標準	SKU 層級。
容量	數字	叢集實例的數目。
resource_group_name	testrg	將在其中建立叢集的資源群組名稱。

注意

建立叢集 是長時間執行的作業。方法 begin_create_or_update 傳回 LROPoller 的實例，請參閱 LROPoller 類別以取得詳細資訊。

執行下列命令來檢查您的叢集是否已成功建立：

cluster_operations.get(resource_group_name = resource_group_name, cluster_name= cluster_name, custom_headers=None, raw=False)

確認結果中 provisioningState 顯示為 Succeeded，以確認叢集已成功建立。

下列程式代碼示範如何建立叢集。

設定必要的環境變數，包括必要條件中的服務主體資訊。輸入您要在其中建立叢集的訂用帳戶標識碼、資源群組和區域。

export AZURE_CLIENT_ID="<enter service principal client ID>"
export AZURE_CLIENT_SECRET="<enter service principal client secret>"
export AZURE_TENANT_ID="<enter tenant ID>"

export SUBSCRIPTION="<enter subscription ID>"
export RESOURCE_GROUP="<enter resource group name>"
export LOCATION="<enter azure location e.g. Southeast Asia>"

export CLUSTER_NAME_PREFIX="<enter prefix (cluster name will be [prefix]-ADXTestCluster)>"
export DATABASE_NAME_PREFIX="<enter prefix (database name will be [prefix]-ADXTestDB)>"

提示

如果您已安裝並設定 Azure CLI 以進行驗證，請使用 auth.NewAuthorizerFromCLIWithResource。在此情況下，您不需要建立服務主體。

執行下列程式代碼來建立叢集：

import (
 "context"
 "log"
 "os"
 "strconv"

 "github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
 "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
 "github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto"
 "github.com/olekukonko/tablewriter"
)

const (
 subscriptionEnvVar      = "AZURE_SUBSCRIPTION_ID"
 resourceGroupEnvVar     = "AZURE_RESOURCE_GROUP"
 locationEnvVar          = "AZURE_LOCATION"
 clusterNamePrefixEnvVar = "CLUSTER_NAME_PREFIX"
 dbNamePrefixEnvVar      = "DATABASE_NAME_PREFIX"

 clusterName  = "ADXTestCluster"
 databaseName = "ADXTestDB"
)

func init() {
 subscription = os.Getenv(subscriptionEnvVar)
 if subscription == "" {
  log.Fatalf("missing environment variable %s", subscriptionEnvVar)
 }

 rgName = os.Getenv(resourceGroupEnvVar)
 if rgName == "" {
  log.Fatalf("missing environment variable %s", resourceGroupEnvVar)
 }

 location = os.Getenv(locationEnvVar)
 if location == "" {
  log.Fatalf("missing environment variable %s", locationEnvVar)
 }

 clusterNamePrefix = os.Getenv(clusterNamePrefixEnvVar)
 if clusterNamePrefix == "" {
  log.Fatalf("missing environment variable %s", clusterNamePrefixEnvVar)
 }

 dbNamePrefix = os.Getenv(dbNamePrefixEnvVar)
 if dbNamePrefix == "" {
  log.Fatalf("missing environment variable %s", dbNamePrefixEnvVar)
 }
}

func getClustersClient(subscription string) *armkusto.ClustersClient {
 cred, err := azidentity.NewDefaultAzureCredential(nil)
 if err != nil {
  log.Fatal(err)
 }

 client, err := armkusto.NewClustersClient(subscription, cred, nil)
 if err != nil {
  log.Fatal(err)
 }

 return client
}

// 1 instance, Basic tier with compute type Dev(No SLA)_Standard_D11_v2
func createCluster(sub, name, location, rgName string) {
 ctx := context.Background()

 numInstances := int32(1)
 client := getClustersClient(sub)
 result, err := client.BeginCreateOrUpdate(
  ctx,
  rgName,
  name,
  armkusto.Cluster{
   Location: &location,
   SKU: &armkusto.AzureSKU{
    Name:     to.Ptr(armkusto.AzureSKUNameDevNoSLAStandardD11V2),
    Capacity: &numInstances,
    Tier:     to.Ptr(armkusto.AzureSKUTierBasic),
   },
  },
  nil,
 )
 if err != nil {
  log.Fatal("failed to start cluster creation ", err)
 }

 log.Printf("waiting for cluster creation to complete - %s\n", name)
 r, err := result.PollUntilDone(ctx, nil)
 if err != nil {
  log.Fatal(err)
 }

 log.Printf("created cluster %s\n", *r.Name)
}

createCluster(subscription, clusterNamePrefix+clusterName, location, rgName)

列出叢集以確保成功建立：

func listClusters(sub, rgName string) {
 log.Printf("listing clusters in resource group %s\n", rgName)
 ctx := context.Background()

 result := getClustersClient(sub).NewListByResourceGroupPager(rgName, nil)

 data := [][]string{}

 for result.More() {
  temp, err := result.NextPage(ctx)
  if err != nil {
   log.Fatal(err)
  }
  for _, c := range temp.Value {
   data = append(data, []string{*c.Name, string(*c.Properties.State), *c.Location, strconv.Itoa(int(*c.SKU.Capacity)), *c.Properties.URI})
  }
 }

 table := tablewriter.NewWriter(os.Stdout)
 table.SetHeader([]string{"Name", "State", "Location", "Instances", "URI"})

 for _, v := range data {
  table.Append(v)
 }
 table.Render()
}

listClusters(subscription, rgName)

Important

Azure CLI 的 Kusto 擴充功能已過時且未被維護。我們建議使用 PowerShell 或 ARM/Bicep 範本來建立叢集和資料庫。如果你選擇使用 Azure CLI，務必安裝 Kusto 擴充功能，以確保你擁有最新的 CLI 指令Azure Data Explorer。

使用下列命令建立叢集：

az kusto cluster create --cluster-name azureclitest --sku name="Standard_E8ads_v5" tier="Standard" --resource-group testrg --location westus

設定	建議的值	欄位描述
名稱	azureclitest	所需的叢集名稱。
sku	Standard_E8ads_v5	將用於您的叢集的 SKU。參數：名稱 - SKU 名稱。 tier - SKU 層。
資源群組	testrg	將在其中建立叢集的資源群組名稱。
位置	westus	叢集將建立的位置。

您可以使用其他選擇性參數，例如叢集的容量。

執行下列命令來檢查您的叢集是否已成功建立：

az kusto cluster show --cluster-name azureclitest --resource-group testrg

透過驗證結果包含 provisioningState 且其值為 Succeeded，來確認叢集已成功建立。

叢集和資料庫會與上一節中的ARM範本一起建立。

使用下列命令建立您的資料庫：

New-AzKustoDatabase -ResourceGroupName testrg -ClusterName mykustocluster -Name mykustodatabase -SoftDeletePeriod 3650:00:00:00 -HotCachePeriod 3650:00:00:00

設定	建議的值	欄位描述
叢集名稱	mykustocluster	將在其中建立資料庫的叢集名稱。
名稱	mykustodatabase	您的資料庫名稱。
資源群組名稱	testrg	將建立叢集所在的資源群組名稱。
SoftDeletePeriod	3650:00:00:00	數據可供查詢的時間量。
HotCachePeriod	3650:00:00:00	資料將在快取中保留的時間。

執行下列命令以檢視您所建立的資料庫：

Get-AzKustoDatabase -ClusterName mykustocluster -ResourceGroupName testrg -Name mykustodatabase

使用下列程式代碼建立資料庫：

var cluster = (await clusters.GetAsync(clusterName)).Value;
var databases = cluster.GetKustoDatabases();
var databaseName = "mykustodatabase";
var softDeletePeriod = TimeSpan.FromDays(3650);
var hotCachePeriod = TimeSpan.FromDays(3650);
var databaseData = new KustoReadWriteDatabase
{
    Location = clusterData.Location, SoftDeletePeriod = softDeletePeriod, HotCachePeriod = hotCachePeriod
};
await databases.CreateOrUpdateAsync(WaitUntil.Completed, databaseName, databaseData);

注意

如果您使用 C# 2.0.0 版或更新版本，請使用 Database 而非 ReadWriteDatabase。

設定	建議的值	欄位描述
clusterName	mykustocluster	將在其中建立資料庫的叢集名稱。
databaseName	mykustodatabase	您的資料庫名稱。
resourceGroupName	testrg	將在其中建立叢集的資源群組名稱。
softDeletePeriod	3650:00:00:00	數據可供查詢的時間量。
hotCachePeriod	3650:00:00:00	數據將保留在快取中的時間量。

執行下列命令以檢視您所建立的資料庫：

databaseData = (await databases.GetAsync(databaseName)).Value.Data as KustoReadWriteDatabase;

使用下列命令建立您的資料庫：

from azure.mgmt.kusto import KustoManagementClient
from azure.common.credentials import ServicePrincipalCredentials
from azure.mgmt.kusto.models import ReadWriteDatabase
from datetime import timedelta

#Directory (tenant) ID
tenant_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
#Application ID
client_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
#Client Secret
client_secret = "xxxxxxxxxxxxxx"
subscription_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
credentials = ServicePrincipalCredentials(
    client_id=client_id,
    secret=client_secret,
    tenant=tenant_id
)

location = 'Central US'
resource_group_name = 'testrg'
cluster_name = 'mykustocluster'
soft_delete_period = timedelta(days=3650)
hot_cache_period = timedelta(days=3650)
database_name = "mykustodatabase"

kusto_management_client = KustoManagementClient(credentials, subscription_id)

database_operations = kusto_management_client.databases
database = ReadWriteDatabase(location=location,
      soft_delete_period=soft_delete_period,
      hot_cache_period=hot_cache_period)

poller = database_operations.begin_create_or_update(resource_group_name = resource_group_name, cluster_name = cluster_name, database_name = database_name, parameters = database)
poller.wait()

注意

如果您使用 Python 0.4.0 版或更新版本，請使用 Database 而非 ReadWriteDatabase。

設定	建議的值	欄位描述
cluster_name	mykustocluster	將建立資料庫的叢集名稱。
database_name	mykustodatabase	您的資料庫名稱。
resource_group_name	testrg	將在其中建立叢集的資源群組名稱。
虛刪除期間	3650 天，0：00：00	數據可供查詢的時間量。
熱快取期間	3650 天，0：00：00	資料會在快取中保留的時間。

執行下列命令以檢視您所建立的資料庫：

database_operations.get(resource_group_name = resource_group_name, cluster_name = cluster_name, database_name = database_name)

下列程式代碼示範如何建立資料庫。套件匯入和環境變數起始與上一節相同。

執行下列程式代碼來建立資料庫：

func createDatabase(sub, rgName, clusterName, location, dbName string) {
 ctx := context.Background()

 client := getDBClient(sub)
 future, err := client.BeginCreateOrUpdate(ctx, rgName, clusterName, dbName, &armkusto.ReadWriteDatabase{Kind: to.Ptr(armkusto.KindReadWrite), Location: &location}, nil)

 if err != nil {
  log.Fatal("failed to start database creation ", err)
 }

 log.Printf("waiting for database creation to complete - %s\n", dbName)
 resp, err := future.PollUntilDone(ctx, nil)
 if err != nil {
  log.Fatal(err)
 }

 kdb := resp.GetDatabase()
 log.Printf("created DB %s with ID %s and type %s\n", *kdb.Name, *kdb.ID, *kdb.Type)
}

createDatabase(subscription, rgName, clusterNamePrefix+clusterName, location, dbNamePrefix+databaseName)

列出資料庫，以確保成功建立：

func listDatabases(sub, rgName, clusterName string) {
 log.Printf("listing databases in cluster %s\n", clusterName)

 ctx := context.Background()
 result := getDBClient(sub).NewListByClusterPager(rgName, clusterName, nil)

 data := [][]string{}

 for result.More() {
  temp, err := result.NextPage(ctx)
  if err != nil {
   log.Fatal(err)
  }
  for _, db := range temp.Value {
   if *db.GetDatabase().Kind == armkusto.KindReadWrite {
    data = append(data, []string{*db.GetDatabase().Name, string(*db.GetDatabase().Kind), *db.GetDatabase().Location, *db.GetDatabase().Type})
   }
  }
 }

 table := tablewriter.NewWriter(os.Stdout)
 table.SetHeader([]string{"Name", "State", "Location", "Type"})

 for _, v := range data {
  table.Append(v)
 }
 table.Render()
}

listDatabases(subscription, rgName, clusterNamePrefix+clusterName)

Important

Azure CLI 的 Kusto 擴充功能已過時且未被維護。我們建議使用 PowerShell 或 ARM/Bicep 範本來建立叢集和資料庫。如果你選擇使用 Azure CLI，務必安裝 Kusto 擴充功能，以確保你擁有最新的 CLI 指令Azure Data Explorer。

使用下列命令建立您的資料庫：

az kusto database create --cluster-name azureclitest --database-name clidatabase --resource-group testrg --read-write-database soft-delete-period=P365D hot-cache-period=P31D location=westus

設定	建議的值	欄位描述
叢集名稱	azureclitest	將建立資料庫的叢集名稱。
資料庫名稱	clidatabase	您的資料庫名稱。
資源群組	testrg	將在其中建立叢集的資源群組名稱。
讀寫資料庫	P365DP31Dwestus	資料庫類型。參數：soft-delete-period - 指定資料會保留為可供查詢狀態的時間長度。如需詳細資訊，請參閱保留原則。 hot-cache-period - 表示數據將保留在快取中的時間量。如需詳細資訊，請參閱快取原則。 location -將建立資料庫的位置。

執行下列命令以檢視您所建立的資料庫：

az kusto database show --database-name clidatabase --resource-group testrg --cluster-name azureclitest

必要條件

建立 Azure 數據總管叢集

ARM 範本

建立 Azure 數據總管資料庫

後續步驟

意見反應

其他資源