Vytvoření clusteru Azure Data Explorer databáze pomocí jazyka C #

  • Článek
  • 2 min ke čtení

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í. Do databáze potom ingestujete (načtete) data, abyste se na ně mohli dotazovat spouštěním dotazů. V tomto článku vytvoříte cluster a databázi pomocí jazyka C#.

Požadavky

Instalace C# NuGet

Authentication

Ke spouštění příkladů v tomto článku potřebujeme aplikaci Azure AD a instanční objekt, který má přístup k prostředkům. Pokud chcete vytvořit bezplatnou aplikaci Azure AD a přidat přiřazení role v oboru předplatného, podívejte se na vytvoření aplikace Azure AD. Ukazuje také, jak získat Directory (tenant) ID , Application ID a Client Secret .

Vytvoření Azure Data Explorer clusteru

  1. 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 = "xxxxxxxxxxxxxx";//Client Secret
var subscriptionId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx";
var authenticationContext = new AuthenticationContext($"https://login.windows.net/{tenantId}");
var credential = new ClientCredential(clientId, clientSecret);
var result = await authenticationContext.AcquireTokenAsync(resource: "https://management.core.windows.net/", clientCredential: credential);

var credentials = new TokenCredentials(result.AccessToken, result.AccessTokenType);

var kustoManagementClient = new KustoManagementClient(credentials)
{
    SubscriptionId = subscriptionId
};

var resourceGroupName = "testrg";
var clusterName = "mykustocluster";
var location = "Central US";
var skuName = "Standard_D13_v2";
var tier = "Standard";
var capacity = 5;
var sku = new AzureSku(skuName, tier, capacity);
var cluster = new Cluster(location, sku);
await kustoManagementClient.Clusters.CreateOrUpdateAsync(resourceGroupName, clusterName, cluster);
    Nastavení Navrhovaná hodnota Popis pole
    clusterName mykustocluster Požadovaný název clusteru.
    skuName Standard_D13_v2 SKU, která se použije pro váš cluster.
    tier Standard Úroveň SKU.
    capacity Číslo Počet instancí clusteru
    resourceGroupName testrg (testrg) Název skupiny prostředků, ve které se cluster vytvoří.

    Poznámka

    Vytvoření clusteru je dlouhotrativní operace, proto se důrazně doporučuje místo CreateOrUpdate použít CreateOrUpdateAsync.

  2. Spuštěním následujícího příkazu zkontrolujte, jestli se cluster úspěšně vytvořil:

    kustoManagementClient.Clusters.Get(resourceGroupName, clusterName);

Pokud výsledek obsahuje ProvisioningState hodnotu , cluster se úspěšně Succeeded vytvořil.

Vytvoření databáze v Azure Data Explorer clusteru

  1. Vytvořte databázi pomocí následujícího kódu:

    var hotCachePeriod = new TimeSpan(3650, 0, 0, 0);
var softDeletePeriod = new TimeSpan(3650, 0, 0, 0);
var databaseName = "mykustodatabase";
var database = new ReadWriteDatabase(location: location, softDeletePeriod: softDeletePeriod, hotCachePeriod: hotCachePeriod);

await kustoManagementClient.Databases.CreateOrUpdateAsync(resourceGroupName, clusterName, databaseName, database);

    Poznámka

    Pokud používáte C# verze 2.0.0 nebo nižší, místo ReadWriteDatabase použijte Database.

    Nastavení Navrhovaná hodnota Popis pole
    clusterName mykustocluster Název clusteru, ve kterém se databáze vytvoří.
    Databasename mykustodatabase Název vaší databáze.
    resourceGroupName testrg (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.

  2. Spuštěním následujícího příkazu zobrazte databázi, kterou jste vytvořili:

    kustoManagementClient.Databases.Get(resourceGroupName, clusterName, databaseName) as ReadWriteDatabase;

Teď máte cluster a databázi.

Vyčištění prostředků

  • Pokud máte v plánu postupovat podle našich dalších článků, pořiďte si prostředky, které jste vytvořili.

  • Pokud chcete vyčistit prostředky, odstraňte cluster. Když odstraníte cluster, odstraní se také všechny jeho databáze. K odstranění clusteru použijte následující příkaz:

    kustoManagementClient.Clusters.Delete(resourceGroupName, clusterName);

Další kroky