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, Bicep 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.
-
Git'i yükleyin.
- Go'nun uygun bir sürümünü yükleyin. Desteklenen sürümler için bkz . Go için Azure Kusto Modülü.
-
Kaynaklara erişebilen bir Microsoft Entra uygulaması ve hizmet sorumlusu.
Dizin (kiracı) Kimliği, Uygulama Kimliği ve İstemci Gizli Anahtarı'nı kaydedin.
Important
Azure CLI için Kusto uzantısı eskidir ve korunmaz. Küme ve veritabanı oluşturma için PowerShell veya ARM/Bicep şablonları kullanmanızı öneririz. Azure CLI kullanmayı seçerseniz, Azure Veri Gezgini için en son CLI komutlarına sahip olduğunuzdan emin olmak için Kusto uzantısı yüklediğinizden emin olun.
- 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.
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.
ARM şablonu
Aşağıda, bir Azure Veri Gezgini kümesi ve bu küme içinde en az yapılandırmaya sahip bir veritabanı oluşturan arm şablonu örneği verilmiştir. Tüm ayrıntılar ve desteklenen özellikler için bkz. ARM şablon kümesi başvurusu ve ARM şablonu veritabanı başvurusu.
{
"$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"
}
}
]
}
Aşağıda, bir Azure Veri Gezgini kümesi oluşturan bir Bicep şablonu ve bu küme içinde en az yapılandırmaya sahip bir veritabanı örneği verilmiştir. Tüm ayrıntılar ve desteklenen özellikler için bkz. Bicep küme başvurusu ve Bicep veritabanı başvurusu.
@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'
}
}
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 provisioningState öğesini Succeeded olarak içerdiğini doğrulayarak kümenin başarıyla oluşturulduğundan emin olun.
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ı |
| Küme adı |
mykustocluster |
Kümenizin istenen adı. |
| skuName |
Standard_E8ads_v5 |
Kümeniz için kullanılacak SKU. |
| katman |
Standart |
SKU katmanı. |
| kapasite |
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 provisioningState öğesini Succeeded olarak içerdiğini doğrulayarak kümenin başarıyla oluşturulduğunu onaylayın.
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 düzeyi. |
| kapasite |
sayı |
Kümenin örnek sayısı. |
| kaynak_grubu_adı |
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 provisioningState öğesini Succeeded olarak içerdiğini doğrulayarak kümenin başarıyla oluşturulduğunu onaylayın.
Aşağıdaki kodda bir kümenin nasıl oluşturulacağı gösterilmektedir.
önkoşullar bölümündeki hizmet sorumlusu bilgileri dahil 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)>"
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)
Important
Azure CLI için Kusto uzantısı eskidir ve korunmaz. Küme ve veritabanı oluşturma için PowerShell veya ARM/Bicep şablonları kullanmanızı öneririz. Azure CLI kullanmayı seçerseniz, Azure Veri Gezgini için en son CLI komutlarına sahip olduğunuzdan emin olmak için Kusto uzantısı yüklediğinizden emin olun.
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ı. |
| kaynak-grubu |
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 provisioningState öğesini Succeeded olarak içerdiğini doğrulayarak kümenin başarıyla oluşturulduğunu onaylayın.
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.
Küme ve veritabanı, önceki bölümde ARM şablonuyla birlikte oluşturulur.
Küme ve veritabanı, önceki bölümdeki Bicep şablonuyla birlikte oluşturulur.
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ı. |
| Kaynak Grubu Adı |
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
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ı. |
| kaynak_grubu_adı |
testrg |
Kümenin oluşturulacağı kaynak grubu adı. |
| mantıksal_silme_süresi |
3650 gün, 0:00:00 |
Verilerin sorgulanabilir durumda tutulacağı süre. |
| sıcak_önbellek_süresi |
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.
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)
Important
Azure CLI için Kusto uzantısı eskidir ve korunmaz. Küme ve veritabanı oluşturma için PowerShell veya ARM/Bicep şablonları kullanmanızı öneririz. Azure CLI kullanmayı seçerseniz, Azure Veri Gezgini için en son CLI komutlarına sahip olduğunuzdan emin olmak için Kusto uzantısı yüklediğinizden emin olun.
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ı. |
| kaynak-grubu |
testrg |
Kümenin oluşturulacağı kaynak grubu adı. |
| okuma-yazma-veritabanı |
P365DP31Dwestus |
Veritabanı türü. Parametreler: geçici silme dönemi - Verilerin sorgulanabilir durumda tutulacağı süreyi belirtir. Daha fazla bilgi için saklama ilkesine bakın.
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
Sonraki adım