Azure Resource Manager Cosmosdb Dotnet

using Azure.Identity;using Azure.ResourceManager;using Azure.ResourceManager.CosmosDB;
// Local dev: DefaultAzureCredential. Production: set AZURE_TOKEN_CREDENTIALS=prod or AZURE_TOKEN_CREDENTIALS=<specific_credential>var credential = new DefaultAzureCredential(    DefaultAzureCredential.DefaultEnvironmentVariableName);// Or use a specific credential directly in production:// See https://learn.microsoft.com/dotnet/api/overview/azure/identity-readme?view=azure-dotnet#credential-classes// var credential = new ManagedIdentityCredential();var armClient = new ArmClient(credential);
// Get subscriptionvar subscriptionId = Environment.GetEnvironmentVariable("AZURE_SUBSCRIPTION_ID");var subscription = armClient.GetSubscriptionResource(    new ResourceIdentifier($"/subscriptions/{subscriptionId}"));

using Azure.ResourceManager.CosmosDB;using Azure.ResourceManager.CosmosDB.Models;
// Get resource groupvar resourceGroup = await subscription    .GetResourceGroupAsync("my-resource-group");
// Define accountvar accountData = new CosmosDBAccountCreateOrUpdateContent(    location: AzureLocation.EastUS,    locations: new[]    {        new CosmosDBAccountLocation        {            LocationName = AzureLocation.EastUS,            FailoverPriority = 0,            IsZoneRedundant = false        }    }){    Kind = CosmosDBAccountKind.GlobalDocumentDB,    ConsistencyPolicy = new ConsistencyPolicy(DefaultConsistencyLevel.Session),    EnableAutomaticFailover = true};
// Create account (long-running operation)var accountCollection = resourceGroup.Value.GetCosmosDBAccounts();var operation = await accountCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-cosmos-account",    accountData);
CosmosDBAccountResource account = operation.Value;

var databaseData = new CosmosDBSqlDatabaseCreateOrUpdateContent(    new CosmosDBSqlDatabaseResourceInfo("my-database"));
var databaseCollection = account.GetCosmosDBSqlDatabases();var dbOperation = await databaseCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-database",    databaseData);
CosmosDBSqlDatabaseResource database = dbOperation.Value;

var containerData = new CosmosDBSqlContainerCreateOrUpdateContent(    new CosmosDBSqlContainerResourceInfo("my-container")    {        PartitionKey = new CosmosDBContainerPartitionKey        {            Paths = { "/partitionKey" },            Kind = CosmosDBPartitionKind.Hash        },        IndexingPolicy = new CosmosDBIndexingPolicy        {            Automatic = true,            IndexingMode = CosmosDBIndexingMode.Consistent        },        DefaultTtl = 86400 // 24 hours    });
var containerCollection = database.GetCosmosDBSqlContainers();var containerOperation = await containerCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-container",    containerData);
CosmosDBSqlContainerResource container = containerOperation.Value;

// Manual throughputvar throughputData = new ThroughputSettingsUpdateData(    new ThroughputSettingsResourceInfo    {        Throughput = 400    });
// Autoscale throughputvar autoscaleData = new ThroughputSettingsUpdateData(    new ThroughputSettingsResourceInfo    {        AutoscaleSettings = new AutoscaleSettingsResourceInfo        {            MaxThroughput = 4000        }    });
// Apply to databaseawait database.CreateOrUpdateCosmosDBSqlDatabaseThroughputAsync(    WaitUntil.Completed,    throughputData);

// Get keysvar keys = await account.GetKeysAsync();Console.WriteLine($"Primary Key: {keys.Value.PrimaryMasterKey}");
// Get connection stringsvar connectionStrings = await account.GetConnectionStringsAsync();foreach (var cs in connectionStrings.Value.ConnectionStrings){    Console.WriteLine($"{cs.Description}: {cs.ConnectionString}");}

using Azure;
try{    var operation = await accountCollection.CreateOrUpdateAsync(        WaitUntil.Completed, accountName, accountData);}catch (RequestFailedException ex) when (ex.Status == 409){    Console.WriteLine("Account already exists");}catch (RequestFailedException ex){    Console.WriteLine($"ARM Error: {ex.Status} - {ex.ErrorCode}: {ex.Message}");}