Azure Veri Gezgini kümesi ve veritabanı oluşturma

Makale
07/03/2024

Azure Veri Gezgini uygulamalar, web siteleri, IoT cihazları ve daha fazlasından akışı yapılan büyük miktarda veri üzerinde gerçek zamanlı analiz yapmaya yönelik hızlı ve tam olarak yönetilen bir veri analizi hizmetidir. Azure Veri Gezgini'ni kullanmak için öncelikle bir küme ve bu kümenin içinde bir veya daha fazla veritabanı oluşturmanız gerekir. Ardından, bir veritabanına veri alabilir (yükleyebilir) ve bu veritabanına yönelik sorgular çalıştırabilirsiniz.

Bu makalede C#, Python, Go, Azure CLI, PowerShell veya Azure Resource Manager (ARM) şablonu kullanarak küme ve veritabanı oluşturmayı öğreneceksiniz. Azure portalını kullanarak küme ve veritabanı oluşturmayı öğrenmek için bkz. Hızlı Başlangıç: Azure Veri Gezgini kümesi ve veritabanı oluşturma.

Önceki SDK sürümlerini temel alan kod örnekleri için arşivlenmiş makaleye bakın.

Önkoşullar

Küme ve veritabanı oluşturma yöntemine göre önkoşullar:

Azure aboneliği. Ücretsiz bir Azure hesabı oluşturun.
Visual Studio 2022 Community Edition. Visual Studio kurulumu sırasında Azure geliştirmeyi açın.
Microsoft.Azure.Management.Kusto NuGet paketini yükleyin.
Kaynaklara erişebilen bir Microsoft Entra uygulaması ve hizmet sorumlusu. Dizin (kiracı) Kimliği, Uygulama Kimliği ve İstemci Gizli Anahtarı'nı kaydedin.

Azure aboneliği. Ücretsiz bir Azure hesabı oluşturun.
Yerel ortamınıza herhangi bir şey yüklemek zorunda kalmadan bu makaledeki kodu çalıştırmak için Azure Cloud Shell'i kullanabilirsiniz.
Azure CLI'yı yerel olarak yükleyip kullanmayı seçerseniz Parametreleri yapılandırma makalesindeki adımları izleyin. Bu makale, Azure CLI sürüm 2.0.4 veya üzerini gerektirir. Sürümünüzü kontrol etmek için az --version komutunu çalıştırın. Yükleme veya yükseltme yapmanız gerekirse bkz. Azure CLI'yı yükleme.

CLI parametrelerini yapılandırma

Azure Cloud Shell'de komut çalıştırıyorsanız aşağıdaki adımlar gerekli değildir. CLI'yi yerel olarak çalıştırıyorsanız ortamı ayarlamak için şu adımları izleyin:

En son Kusto CLI sürümünü kullanmak için uzantıyı yükleyin:
```
az extension add -n kusto
```
Azure'da oturum açmak için aşağıdaki komutu çalıştırın:
```
az login
```
Kümenizin oluşturulmasını istediğiniz aboneliği ayarlayın. değerini, kullanmak istediğiniz Azure aboneliğinin adıyla değiştirin MyAzureSub :
```
az account set --subscription MyAzureSub
```
Kümenizin oluşturulmasını istediğiniz kaynak grubunu ayarlayın. değerini, kullanmak istediğiniz kaynak grubunun adıyla değiştirin testrg :
```
az group create --name testrg --location westus
```

Azure Veri Gezgini kümesi oluşturma

Bu bölüm, Azure Veri Gezgini kümesi oluşturma işleminde size yol gösterir. Kümeyi oluşturmak için tercih ettiğiniz yöntemin ilgili sekmesini seçin.

Aşağıdaki kodu kullanarak kümenizi oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
clusterName	mykustocluster	Kümenizin istenen adı.
skuName	Standard_E8ads_v5	Kümeniz için kullanılacak SKU.
katman	Standart	SKU katmanı.
capacity	sayı	Kümenin örnek sayısı.
resourceGroupName	testrg	Kümenin oluşturulacağı kaynak grubu adı.

Not

Küme oluşturma uzun süre çalışan bir işlem olduğundan, CreateOrUpdate yerine CreateOrUpdateAsync kullanılması kesinlikle önerilir.

Kümenizin başarıyla oluşturulup oluşturulmadığını denetlemek için aşağıdaki komutu çalıştırın:
```
clusterData = (await clusters.GetAsync(clusterName)).Value.Data;
```
Sonucun olarak içerdiğini provisioningState doğrulayarak kümenin başarıyla oluşturulduğundan emin olun Succeeded.

Aşağıdaki komutu kullanarak kümenizi oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
cluster_name	mykustocluster	Kümenizin istenen adı.
sku_name	Standard_E8ads_v5	Kümeniz için kullanılacak SKU.
katman	Standart	SKU katmanı.
capacity	sayı	Kümenin örnek sayısı.
resource_group_name	testrg	Kümenin oluşturulacağı kaynak grubu adı.

Not

Küme oluşturma işlemi uzun süre çalışan bir işlemdir. Yöntem begin_create_or_update LROPoller'ın bir örneğini döndürür. Daha fazla bilgi edinmek için bkz . LROPoller sınıfı .

Kümenizin başarıyla oluşturulup oluşturulmadığını denetlemek için aşağıdaki komutu çalıştırın:

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

Sonucun olarak içerdiğini provisioningState doğrulayarak kümenin başarıyla oluşturulduğundan emin olun Succeeded.

Aşağıdaki kodda bir kümenin nasıl oluşturulacağı gösterilmektedir. Kod deposunu kopyalamak için bkz. Azure Go SDK kullanarak Azure Veri Gezgini kümesini yönetme.

Önkoşullardan hizmet sorumlusu bilgileri de dahil olmak üzere gerekli ortam değişkenlerini ayarlayın. Kümeyi oluşturmak istediğiniz abonelik kimliğinizi, kaynak grubunuzu ve bölgenizi girin.

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

İpucu

Kimlik doğrulaması kullanın . Azure CLI'yi yüklediyseniz ve kimlik doğrulaması için yapılandırdıysanız NewAuthorizerFromCLIWithResource . Bu durumda hizmet sorumlusu oluşturmanız gerekmez.

Kümeyi oluşturmak için aşağıdaki kodu çalıştırın:

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)

Başarıyla oluşturulduğundan emin olmak için kümeleri listeleyin:

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)

Aşağıdaki komutu kullanarak kümenizi oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
Adı	azureclitest	Kümenizin istenen adı.
sku	Standard_E8ads_v5	Kümeniz için kullanılacak SKU. Parametreler: name - SKU adı. tier - SKU katmanı.
resource-group	testrg	Kümenin oluşturulacağı kaynak grubu adı.
konum	westus	Kümenin oluşturulacağı konum.

Kümenin kapasitesi gibi kullanabileceğiniz başka isteğe bağlı parametreler de vardır.

Kümenizin başarıyla oluşturulup oluşturulmadığını denetlemek için aşağıdaki komutu çalıştırın:
```
az kusto cluster show --cluster-name azureclitest --resource-group testrg
```
Sonucun olarak içerdiğini provisioningState doğrulayarak kümenin başarıyla oluşturulduğundan emin olun Succeeded.

Aşağıdaki komutu kullanarak kümenizi oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
Veri Akışı Adı	mykustocluster	Kümenizin istenen adı.
Sku	Standard_E8ads_v5	Kümeniz için kullanılacak SKU.
ResourceGroupName	testrg	Kümenin oluşturulacağı kaynak grubu adı.

Kümenin kapasitesi gibi kullanabileceğiniz başka isteğe bağlı parametreler de vardır.

Kümenizin başarıyla oluşturulup oluşturulmadığını denetlemek için aşağıdaki komutu çalıştırın:
```
Get-AzKustoCluster -Name mykustocluster -ResourceGroupName testrg
```
Sonucun olarak içerdiğini provisioningState doğrulayarak kümenin başarıyla oluşturulduğundan emin olun Succeeded.

Aşağıdaki ARM şablonunu PowerShell kullanarak dağıtmayı öğrenmek için bkz . ARM şablonunu kullanma. Alternatif olarak, Azure portalında Azure'a dağıt'ı seçerek şablonu dağıtabilirsiniz.

ARM şablonu

Bu şablonu kendi dağıtımlarınız için kullanabilir veya kendi gereksinimlerinize göre özelleştirebilirsiniz. Şablonda kullanılacak JSON söz dizimi ve özellikleri için bkz . Microsoft.Kusto kaynak türleri.

{
    "$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",
            "sku": {
                "name": "Standard_E8ads_v5",
                "tier": "Standard",
                "capacity": 2
            },
            "apiVersion": "2022-12-29",
            "location": "[parameters('location')]",
            "tags": {
                "Created By": "GitHub quickstart template"
            },
            "properties": {
                "trustedExternalTenants": [],
                "optimizedAutoscale": {
                    "version": 1,
                    "isEnabled": true,
                    "minimum": 2,
                    "maximum": 10
                },
                "enableDiskEncryption": false,
                "enableStreamingIngest": false,
                "virtualNetworkConfiguration": {
                    "subnetId": "<subnet resource id>",
                    "enginePublicIpId": "<Engine service's public IP address resource id>",
                    "dataManagementPublicIpId": "<Data management's service public IP address resource id>"
                },
                "keyVaultProperties": {
                    "keyName": "<Key name>",
                    "keyVaultUri": "<Key vault uri>",
                    "userIdentity": "<ResourceId of user assigned managed identity>"
                },
                "enablePurge": false,
                "enableDoubleEncryption": false,
                "engineType": "V3"
            },
            "identity": {
                "type": "SystemAssigned, UserAssigned",
                "userAssignedIdentities": {
                    "<ResourceId of managed identity>": {}
                }
            }
        },
        {
            "name": "[concat(parameters('clusters_kustocluster_name'), '/', parameters('databases_kustodb_name'))]",
            "type": "Microsoft.Kusto/clusters/databases",
            "apiVersion": "2022-12-29",
            "location": "[parameters('location')]",
            "dependsOn": [
                "[resourceId('Microsoft.Kusto/clusters', parameters('clusters_kustocluster_name'))]"
            ],
            "properties": {
                "softDeletePeriodInDays": 365,
                "hotCachePeriodInDays": 31
            }
        }
    ]
}

ARM şablonunu kullanma

Aşağıdaki adımlarda PowerShell kullanarak ARM şablonunun nasıl dağıtılacağı açıklanmaktadır.

Azure Cloud Shell'i açın ve oturum açmak için yönergeleri izleyin.

PowerShell betiğini kopyalamak için Kopyala'yı seçin.

$projectName = Read-Host -Prompt "Enter a project name that is used for generating resource names"
$location = Read-Host -Prompt "Enter the location (i.e. centralus)"
$resourceGroupName = "${projectName}rg"
$clusterName = "${projectName}cluster"
$parameters = @{}
$parameters.Add("clusters_kustocluster_name", $clusterName)
$templateUri = "https://azure.microsoft.com/resources/templates/kusto-cluster-database/"
New-AzResourceGroup -Name $resourceGroupName -Location $location
New-AzResourceGroupDeployment -ResourceGroupName $resourceGroupName -TemplateUri $templateUri -TemplateParameterObject $parameters
Write-Host "Press [ENTER] to continue ..."

Kabuk konsoluna sağ tıklayın ve yapıştır'ı seçin.

Not

Azure Veri Gezgini kümesi ve veritabanı oluşturmak birkaç dakika sürer.

Dağıtımı doğrulamak için aşağıdaki Azure PowerShell betiğini kullanın. Cloud Shell hala açıksa, ilk satırı (Okuma Konağı) kopyalamanız/çalıştırmanız gerekmez.

$projectName = Read-Host -Prompt "Enter the same project name that you used in the last procedure"

Install-Module -Name Az.Kusto
$resourceGroupName = "${projectName}rg"
$clusterName = "${projectName}cluster"

Get-AzKustoCluster -ResourceGroupName $resourceGroupName -Name $clusterName
Write-Host "Press [ENTER] to continue ..."

Azure Veri Gezgini veritabanı oluşturma

Bu bölümde, önceki bölümde oluşturulan küme içinde bir veritabanı oluşturacaksınız.

Aşağıdaki kodu kullanarak veritabanınızı oluşturun:

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

Not

C# sürüm 2.0.0 veya üzerini kullanıyorsanız ReadWriteDatabase yerine Veritabanı'nı kullanın.

Ayar	Önerilen değer	Alan açıklaması
clusterName	mykustocluster	Veritabanının oluşturulacağı kümenizin adı.
veritabanıAdı	mykustodatabase	Veritabanınızın adı.
resourceGroupName	testrg	Kümenin oluşturulacağı kaynak grubu adı.
softDeletePeriod	3650:00:00:00	Verilerin sorgulanabilir durumda tutulacağı süre.
hotCachePeriod	3650:00:00:00	Verilerin önbellekte tutulacağı süre.

Oluşturduğunuz veritabanını görmek için aşağıdaki komutu çalıştırın:

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

Aşağıdaki komutu kullanarak veritabanınızı oluşturun:

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

Not

Python sürüm 0.4.0 veya üzerini kullanıyorsanız ReadWriteDatabase yerine Veritabanı'nı kullanın.

Ayar	Önerilen değer	Alan açıklaması
cluster_name	mykustocluster	Veritabanının oluşturulacağı kümenizin adı.
database_name	mykustodatabase	Veritabanınızın adı.
resource_group_name	testrg	Kümenin oluşturulacağı kaynak grubu adı.
soft_delete_period	3650 gün, 0:00:00	Verilerin sorgulanabilir durumda tutulacağı süre.
hot_cache_period	3650 gün, 0:00:00	Verilerin önbellekte tutulacağı süre.

Oluşturduğunuz veritabanını görmek için aşağıdaki komutu çalıştırın:

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

Aşağıdaki kodda veritabanı oluşturma gösterilmektedir. Paket içeri aktarmaları ve ortam değişkeni başlatma işlemi önceki bölümdekiyle aynıdır. Kod deposunu kopyalamak için bkz. Azure Go SDK kullanarak Azure Veri Gezgini kümesini yönetme.

Veritabanını oluşturmak için aşağıdaki kodu çalıştırın:

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)

Başarıyla oluşturulduğundan emin olmak için veritabanlarını listeleyin:

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)

Aşağıdaki komutu kullanarak veritabanınızı oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
küme adı	azureclitest	Veritabanının oluşturulacağı kümenizin adı.
veritabanı adı	clidatabase	Veritabanınızın adı.
resource-group	testrg	Kümenin oluşturulacağı kaynak grubu adı.
okuma-yazma-veritabanı	P365D P31D westus	Veritabanı türü. Parametreler: geçici silme dönemi - Verilerin sorgulanabilir durumda tutulacağı süreyi belirtir. Daha fazla bilgi için bkz . bekletme ilkesi . hot-cache-period - Verilerin önbellekte tutulacağı süreyi belirtir. Daha fazla bilgi için bkz . önbellek ilkesi . location -Veritabanının oluşturulacağı konum.

Oluşturduğunuz veritabanını görmek için aşağıdaki komutu çalıştırın:

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

Aşağıdaki komutu kullanarak veritabanınızı oluşturun:

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

Ayar	Önerilen değer	Alan açıklaması
ClusterName	mykustocluster	Veritabanının oluşturulacağı kümenizin adı.
Veri Akışı Adı	mykustodatabase	Veritabanınızın adı.
ResourceGroupName	testrg	Kümenin oluşturulacağı kaynak grubu adı.
SoftDeletePeriod	3650:00:00:00	Verilerin sorgulanabilir durumda tutulacağı süre.
HotCachePeriod	3650:00:00:00	Verilerin önbellekte tutulacağı süre.

Oluşturduğunuz veritabanını görmek için aşağıdaki komutu çalıştırın:

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

Sonraki adım

Tablo oluştur

Aracılığıyla paylaş

Azure Veri Gezgini kümesi ve veritabanı oluşturma

Önkoşullar

CLI parametrelerini yapılandırma

Parametreleri yapılandırma

Azure Veri Gezgini kümesi oluşturma

ARM şablonu

ARM şablonunu kullanma

Azure Veri Gezgini veritabanı oluşturma

Sonraki adım

Geri Bildirim

Ek kaynaklar