Vytvoření clusteru a databáze Azure Data Exploreru
Azure Data Explorer je rychlá, plně spravovaná služba analýzy dat pro analýzy velkých objemů dat v reálném čase, která se streamují z aplikací, webů, zařízení IoT a dalších. Pokud chcete použít Azure Data Explorer, musíte nejdříve vytvořit cluster a v něm vytvořit jednu nebo více databází. Pak můžete ingestovat (načíst) data do databáze a spouštět dotazy na ni.
V tomto článku se dozvíte, jak vytvořit cluster a databázi pomocí šablony C#, Python, Go, Azure CLI, PowerShell nebo Azure Resource Manageru (ARM). Informace o vytvoření clusteru a databáze pomocí webu Azure Portal najdete v tématu Rychlý start: Vytvoření clusteru a databáze Azure Data Exploreru.
Ukázky kódu založené na předchozích verzích sady SDK najdete v archivovaného článku.
Požadavky
Požadavky podle metody vytvoření clusteru a databáze:
- Předplatné Azure. Vytvořte bezplatný účet Azure.
- Visual Studio 2022 Community Edition. Zapněte vývoj pro Azure během instalace sady Visual Studio.
- Nainstalujte balíček NuGet Microsoft.Azure.Management.Kusto.
- Aplikace Microsoft Entra a instanční objekt, který má přístup k prostředkům. Uložte ID adresáře (tenanta), ID aplikace a tajný klíč klienta.
Vytvoření clusteru Azure Data Exploreru
Tato část vás provede procesem vytvoření clusteru Azure Data Exploreru. Vyberte příslušnou kartu pro preferovanou metodu pro vytvoření clusteru.
Vytvořte cluster pomocí následujícího kódu:
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);
Nastavení Navrhovaná hodnota Popis pole clusterName mykustocluster Požadovaný název clusteru. skuName Standard_E8ads_v5 Skladová položka, která se použije pro váš cluster. úroveň Standard Úroveň skladové položky. capacity číslo Počet instancí clusteru. resourceGroupName testrg Název skupiny prostředků, ve které se cluster vytvoří. Poznámka:
Vytvoření clusteru je dlouhotrvající operace, takže místo CreateOrUpdateUpdate se důrazně doporučuje použít CreateOrUpdateAsync.
Spuštěním následujícího příkazu zkontrolujte, jestli se cluster úspěšně vytvořil:
clusterData = (await clusters.GetAsync(clusterName)).Value.Data;
Ověřte úspěšné vytvoření clusteru tak, že ověříte, že výsledek obsahuje
provisioningState
hodnotuSucceeded
.
Vytvoření databáze Azure Data Exploreru
V této části vytvoříte databázi v clusteru vytvořeném v předchozí části.
Vytvořte databázi pomocí následujícího kódu:
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);
Poznámka:
Pokud používáte jazyk C# verze 2.0.0 nebo novější, použijte místo ReadWriteDatabase databázi.
Nastavení Navrhovaná hodnota Popis pole clusterName mykustocluster Název clusteru, ve kterém se databáze vytvoří. databaseName mykustodatabase Název databáze. resourceGroupName testrg Název skupiny prostředků, ve které se cluster vytvoří. softDeletePeriod 3650:00:00:00 Doba, po kterou budou data k dispozici pro dotazování. hotCachePeriod 3650:00:00:00 Doba, po kterou se budou data uchovávat v mezipaměti. Spuštěním následujícího příkazu zobrazte databázi, kterou jste vytvořili:
databaseData = (await databases.GetAsync(databaseName)).Value.Data as KustoReadWriteDatabase;