Azure Data Explorer-fürt és -adatbázis létrehozása

Az Azure Data Explorer egy gyors, teljes körűen felügyelt adatelemzési szolgáltatás, amely valós idejű elemzést tesz lehetővé alkalmazásokból, webhelyekről, IoT-eszközökről és egyebekről nagy mennyiségű adatstreamelésről. Az Azure Data Explorer használatához először hozzon létre egy fürtöt, és hozzon létre egy vagy több adatbázist a fürtben. Ezután betöltheti (betöltheti) az adatokat egy adatbázisba, és lekérdezéseket futtathat rajta.

Ebben a cikkben megtudhatja, hogyan hozhat létre fürtöt és adatbázist C#, Python, Go, Azure CLI, PowerShell, Bicep vagy Azure Resource Manager (ARM) sablon használatával. Ha tudni szeretné, hogyan hozhat létre fürtöt és adatbázist az Azure Portal használatával, tekintse meg rövid útmutatót: Azure Data Explorer-fürt és adatbázis létrehozása.

A korábbi SDK-verziókon alapuló kódmintákért lásd az archivált cikket.

Előfeltételek

Előfeltételek klaszter- és adatbázis-létrehozási módszer szerint:

ARM-sablon

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.

Bicep

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.

PowerShell

• A környezet beállítása Kusto-parancsmagok használata az Azure PowerShell-című témakörben található utasítások alapján.

C#

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Visual Studio 2022 Community Edition. Kapcsolja be a Azure-fejlesztést a Visual Studio telepítése során.
• Telepítse a Microsoft.Azure.Management.Kusto NuGet-csomag.
• Microsoft Entra-alkalmazás és szolgáltatásnév, amely hozzáfér az erőforrásokhoz. Mentse a címtár (bérlő) azonosítóját, alkalmazásazonosítótés titkos ügyfélkód.

Python

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Python 3,4+.
• Telepítse a azure-common és azure-mgmt-kusto csomagokat.
• Microsoft Entra-alkalmazás és szolgáltatásnév, amely hozzáfér az erőforrásokhoz. Mentse a címtár (bérlő) azonosítóját, alkalmazásazonosítótés titkos ügyfélkód.

Go

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Telepítse Git.
• Telepítse a Gomegfelelő verzióját. A támogatott verziókért lásd Go-hoz készült Azure Kusto-modult.
• Microsoft Entra-alkalmazás és szolgáltatásnév, amely hozzáfér az erőforrásokhoz. Mentse a címtár (bérlő) azonosítóját, alkalmazásazonosítótés titkos ügyfélkód.

Azure CLI

Important

Az Azure CLI Kusto-bővítménye elavult és nem karbantartott. Javasoljuk, hogy PowerShellt vagy ARM- vagy Bicep-sablonokat használjon fürtök és adatbázisok létrehozásához. Ha a Azure CLI használata mellett dönt, telepítse a Kusto bővítményt, hogy biztosan a legújabb CLI-parancsokkal rendelkezzen a Azure Data Explorer.

• Egy Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Az Azure Cloud Shell használatával futtathatja a jelen cikkben szereplő kódot anélkül, hogy bármit telepítenie kellene a helyi környezetben.
• Ha az Azure CLI helyi telepítését és használatát választja, kövesse a Paraméterek konfigurálásacímű témakör lépéseit. Ez a cikk az Azure CLI 2.0.4-es vagy újabb verzióját igényli. A verzió ellenőrzéséhez futtassa a az --version. Ha telepítenie vagy frissítenie kell, olvassa el Az Azure CLItelepítése című témakört.

A parancssori felület paramétereinek konfigurálása

A következő lépések nem szükségesek, ha parancsokat futtat az Azure Cloud Shellben. Ha helyileg futtatja a parancssori felületet, kövesse az alábbi lépéseket a környezet beállításához:

1. Telepítse a bővítményt a Kusto CLI legújabb verziójának használatához:

   az extension add -n kusto
   

2. Futtassa a következő parancsot az Azure-ba való bejelentkezéshez:

   az login
   

3. Állítsa be azt az előfizetést, amelyben létre szeretné hozni a fürtöt. Cserélje le MyAzureSub a használni kívánt Azure-előfizetés nevére:

   az account set --subscription MyAzureSub
   

4. Állítsa be azt az erőforráscsoportot, amelyben létre szeretné hozni a fürtöt. Cserélje le a testrg a használni kívánt erőforráscsoport nevére:

   az group create --name testrg --location westus
   

Azure Data Explorer klaszter létrehozása

Ez a szakasz végigvezeti az Azure Data Explorer-fürt létrehozásának folyamatán. Válassza ki a preferált módszer megfelelő lapját a fürt létrehozásához.

ARM-sablon

ARM-sablon

Az alábbi példa egy olyan ARM-sablont mutat be, amely minimális konfigurációval hoz létre egy Azure Data Explorer-fürtöt és a fürtön belül egy adatbázist. A teljes részletekért és a támogatott tulajdonságokért tekintse meg az ARM-sablon klaszterreferenciáját és az ARM-sablon adatbázisreferenciáját.

{
    "$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

Az alábbiakban egy Bicep sablonra látható példa, amely minimális konfigurációval létrehoz egy Azure Data Explorer-fürtöt és egy adatbázist a fürtön belül. További részletekért és a támogatott tulajdonságokért lásd: Bicep fürtreferenciája és Bicep adatbázis-referencia.

    @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'
      }
    }

PowerShell

1. Hozza létre a klasztert a következő paranccsal:

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

   beállítás	javasolt érték	mező leírása
   Név	mykustocluster	A kívánt neve a fürtnek.
   Sku	Standard_E8ads_v5	A fürthöz használt termékváltozat.
   ResourceGroupName	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.

   Opcionális paraméterek is használhatók, mint például a fürt kapacitása.

2. Futtassa a következő parancsot annak ellenőrzéséhez, hogy a klaszter sikeresen létrejött-e.

   Get-AzKustoCluster -Name mykustocluster -ResourceGroupName testrg
   

3. A fürt sikeres létrehozásának megerősítéséhez ellenőrizze, hogy az eredmény provisioningState tartalmaz-e Succeeded.

C#

1. Hozza létre a klasztert a következő kóddal:

   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);
   

   beállítás	javasolt érték	mező leírása
   clusterName	mykustocluster	A kívánt neve a fürtnek.
   skuName	Standard_E8ads_v5	A fürthöz használt termékváltozat.
   rétegez	Standard	Az SKU-szint.
   kapacitás	szám	A klaszter példányainak száma.
   erőforráscsoportNév	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.

   Jegyzet

   A(z) fürt létrehozása hosszú időtartamú művelet, ezért erősen ajánlott a CreateOrUpdateAsync használata a CreateOrUpdate helyett.

2. Futtassa a következő parancsot annak ellenőrzéséhez, hogy a klaszter sikeresen létrejött-e.

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

3. A fürt sikeres létrehozásának megerősítéséhez ellenőrizze, hogy az eredmény provisioningState tartalmaz-e Succeeded.

Python

1. Hozza létre a klasztert a következő paranccsal:

   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()
   

   beállítás	javasolt érték	mező leírása
   cluster_name	mykustocluster	A kívánt neve a fürtnek.
   sku_name	Standard_E8ads_v5	A fürthöz használt termékváltozat.
   rétegez	Standard	Az SKU-szint.
   kapacitás	szám	A klaszter példányainak száma.
   resource_group_name	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.

   Jegyzet

   Fürt létrehozása egy hosszú ideig futó művelet. A begin_create_or_update metódus visszaad egy LROPoller példányt, további információért lásd a LROPoller osztályt.

2. Futtassa a következő parancsot annak ellenőrzéséhez, hogy a klaszter sikeresen létrejött-e.

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

3. A fürt sikeres létrehozásának megerősítéséhez ellenőrizze, hogy az eredmény provisioningState tartalmaz-e Succeeded.

Go

Az alábbi kód bemutatja, hogyan hozhat létre fürtöt.

1. Állítsa be a szükséges környezeti változókat, beleértve a szolgáltatásnév adatait a előfeltételek. Adja meg az előfizetés azonosítóját, az erőforráscsoportot és a régiót, ahol létre szeretné hozni a fürtöt.

   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)>"
   

   Borravaló

   Használja a auth.NewAuthorizerFromCLIWithResource funkciót, ha az Azure CLI telepítve van, és hitelesítésre van konfigurálva. Ebben az esetben nem kell szolgáltatásnevet létrehoznia.

2. Futtassa a következő kódot a klaszter létrehozásához:

   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)
   

3. A fürtök listázása a sikeres létrehozás érdekében:

   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)
   

Azure CLI

Important

Az Azure CLI Kusto-bővítménye elavult és nem karbantartott. Javasoljuk, hogy a fürtök és adatbázisok létrehozásához PowerShellt vagy ARM-/Bicep-sablonokat használni. Ha a Azure CLI használata mellett dönt, telepítse a Kusto bővítményt, hogy biztosan a legújabb CLI-parancsokkal rendelkezzen a Azure Data Explorer.

1. Hozza létre a klasztert a következő paranccsal:

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

   beállítás	javasolt érték	mező leírása
   név	azureclitest	A kívánt neve a fürtnek.
   Sku	Standard_E8ads_v5	A fürthöz használt termékváltozat. Paraméterek: név – A termékváltozat neve. szint – A cikkazonosító szintje.
   erőforráscsoport	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.
   hely	westus	A fürt létrehozásának helye.

   Opcionális paraméterek is használhatók, mint például a fürt kapacitása.

2. Futtassa a következő parancsot annak ellenőrzéséhez, hogy a klaszter sikeresen létrejött-e.

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

3. A fürt sikeres létrehozásának megerősítéséhez ellenőrizze, hogy az eredmény provisioningState tartalmaz-e Succeeded.

Azure Data Explorer-adatbázis létrehozása

Ebben a szakaszban létrehoz egy adatbázist az előző szakaszban létrehozott fürtön belül.

ARM-sablon

A fürt és az adatbázis a korábbi szakaszban található ARM-sablonnal együtt jön létre.

Bicep

A fürt és az adatbázis együtt jönnek létre az előző szakaszban bemutatott Bicep-sablonnal.

PowerShell

1. Hozza létre az adatbázist a következő paranccsal:

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

   beállítás	javasolt érték	mező leírása
   Fürtnév	mykustocluster	Annak a fürtnek a neve, ahol az adatbázis létrejön.
   Név	mykustodatabase	Az adatbázis neve.
   ResourceGroupName	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.
   SoftDeletePeriod	3650:00:00:00	Az adatok lekérdezéshez való rendelkezésre állásának időtartama.
   HotCachePeriod	3650:00:00:00	Az adatok gyorsítótárban tartásának időtartama.

2. Futtassa a következő parancsot a létrehozott adatbázis megtekintéséhez:

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

C#

1. Hozza létre az adatbázist a következő kóddal:

   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);
   

   Jegyzet

   Ha a C# 2.0.0-s vagy újabb verzióját használja, a ReadWriteDatabase helyett használja az Adatbázist.

   beállítás	javasolt érték	mező leírása
   clusterName	mykustocluster	Annak a fürtnek a neve, ahol az adatbázis létrejön.
   adatbázisNév	mykustodatabase	Az adatbázis neve.
   erőforráscsoportNév	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.
   softDeletePeriod	3650:00:00:00	Az adatok lekérdezéshez való rendelkezésre állásának időtartama.
   hotCachePeriod	3650:00:00:00	Az adatok gyorsítótárban tartásának időtartama.

2. Futtassa a következő parancsot a létrehozott adatbázis megtekintéséhez:

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

Python

1. Hozza létre az adatbázist a következő paranccsal:

   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()
   

   Jegyzet

   Ha a Python 0.4.0-s vagy újabb verzióját használja, a ReadWriteDatabase helyett használja az Adatbázist.

   beállítás	javasolt érték	mező leírása
   cluster_name	mykustocluster	Annak a fürtnek a neve, ahol az adatbázis létrejön.
   database_name	mykustodatabase	Az adatbázis neve.
   resource_group_name	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.
   lágy törlési időszak	3650 nap, 0:00:00	Az adatok lekérdezéshez való rendelkezésre állásának időtartama.
   gyorsítótár aktív időszak	3650 nap, 0:00:00	Az adatok gyorsítótárban tartásának időtartama.

2. Futtassa a következő parancsot a létrehozott adatbázis megtekintéséhez:

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

Go

Az alábbi kód bemutatja, hogyan hozhat létre adatbázist. A csomagimportálás és a környezeti változó kezdeményezése ugyanaz, mint az előző szakaszban.

1. Futtassa a következő kódot az adatbázis létrehozásához:

   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)
   

2. A sikeres létrehozás érdekében listázhatja az adatbázisokat:

   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)
   

Azure CLI

Important

Az Azure CLI Kusto-bővítménye elavult és nem karbantartott. Javasoljuk a PowerShell vagy ARM-/Bicep-sablonok használatát fürtök és adatbázisok létrehozásához. Ha a Azure CLI használata mellett dönt, telepítse a Kusto bővítményt, hogy biztosan a legújabb CLI-parancsokkal rendelkezzen a Azure Data Explorer.

1. Hozza létre az adatbázist a következő paranccsal:

   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
   

   beállítás	javasolt érték	mező leírása
   klaszter neve	azureclitest	Annak a fürtnek a neve, ahol az adatbázis létrejön.
   adatbázis neve	clidatabase	Az adatbázis neve.
   erőforráscsoport	testrg	Az erőforráscsoport neve, ahol a fürt létrehozva lesz.
   olvasási-írási adatbázis	P365DP31Dwestus	Az adatbázis típusa. Paraméterek: helyreállítható törlési időszak – Azt jelzi, hogy az adatok mennyi ideig lesznek elérhetők a lekérdezéshez. További információért lásd adatmegőrzési szabályzat. gyorsítótár-időtartam – Azt jelzi, hogy az adatok meddig lesznek a gyorsítótárban tárolva. Lásd a gyorsítótár-szabályzatot a további információkért. hely -The hely, ahol az adatbázis létrejön.

2. Futtassa a következő parancsot a létrehozott adatbázis megtekintéséhez:

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

Következő lépés

Tábla létrehozása