Azure Resource Manager Redis Dotnet

using Azure.Identity;using Azure.ResourceManager;using Azure.ResourceManager.Redis;
// 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.Redis;using Azure.ResourceManager.Redis.Models;
// Get resource groupvar resourceGroup = await subscription    .GetResourceGroupAsync("my-resource-group");
// Define cache configurationvar cacheData = new RedisCreateOrUpdateContent(    location: AzureLocation.EastUS,    sku: new RedisSku(RedisSkuName.Standard, RedisSkuFamily.BasicOrStandard, 1)){    EnableNonSslPort = false,    MinimumTlsVersion = RedisTlsVersion.Tls1_2,    RedisConfiguration = new RedisCommonConfiguration    {        MaxMemoryPolicy = "volatile-lru"    },    Tags =    {        ["environment"] = "production"    }};
// Create cache (long-running operation)var cacheCollection = resourceGroup.Value.GetAllRedis();var operation = await cacheCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-redis-cache",    cacheData);
RedisResource cache = operation.Value;Console.WriteLine($"Cache created: {cache.Data.HostName}");

// Get existing cachevar cache = await resourceGroup.Value    .GetRedisAsync("my-redis-cache");
Console.WriteLine($"Host: {cache.Value.Data.HostName}");Console.WriteLine($"Port: {cache.Value.Data.Port}");Console.WriteLine($"SSL Port: {cache.Value.Data.SslPort}");Console.WriteLine($"Provisioning State: {cache.Value.Data.ProvisioningState}");

var patchData = new RedisPatch{    Sku = new RedisSku(RedisSkuName.Standard, RedisSkuFamily.BasicOrStandard, 2),    RedisConfiguration = new RedisCommonConfiguration    {        MaxMemoryPolicy = "allkeys-lru"    }};
var updateOperation = await cache.Value.UpdateAsync(    WaitUntil.Completed,    patchData);

await cache.Value.DeleteAsync(WaitUntil.Completed);

var keys = await cache.Value.GetKeysAsync();Console.WriteLine($"Primary Key: {keys.Value.PrimaryKey}");Console.WriteLine($"Secondary Key: {keys.Value.SecondaryKey}");

var regenerateContent = new RedisRegenerateKeyContent(RedisRegenerateKeyType.Primary);var newKeys = await cache.Value.RegenerateKeyAsync(regenerateContent);Console.WriteLine($"New Primary Key: {newKeys.Value.PrimaryKey}");

// Create firewall rulevar firewallData = new RedisFirewallRuleData(    startIP: System.Net.IPAddress.Parse("10.0.0.1"),    endIP: System.Net.IPAddress.Parse("10.0.0.255"));
var firewallCollection = cache.Value.GetRedisFirewallRules();var firewallOperation = await firewallCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "allow-internal-network",    firewallData);
// List all firewall rulesawait foreach (var rule in firewallCollection.GetAllAsync()){    Console.WriteLine($"Rule: {rule.Data.Name} ({rule.Data.StartIP} - {rule.Data.EndIP})");}
// Delete firewall rulevar ruleToDelete = await firewallCollection.GetAsync("allow-internal-network");await ruleToDelete.Value.DeleteAsync(WaitUntil.Completed);

// Patch schedules require Premium SKUvar scheduleData = new RedisPatchScheduleData(    new[]    {        new RedisPatchScheduleSetting(RedisDayOfWeek.Saturday, 2) // 2 AM Saturday        {            MaintenanceWindow = TimeSpan.FromHours(5)        },        new RedisPatchScheduleSetting(RedisDayOfWeek.Sunday, 2) // 2 AM Sunday        {            MaintenanceWindow = TimeSpan.FromHours(5)        }    });
var scheduleCollection = cache.Value.GetRedisPatchSchedules();await scheduleCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    RedisPatchScheduleDefaultName.Default,    scheduleData);

// Import data from blob storagevar importContent = new ImportRdbContent(    files: new[] { "https://mystorageaccount.blob.core.windows.net/container/dump.rdb" },    format: "RDB");
await cache.Value.ImportDataAsync(WaitUntil.Completed, importContent);
// Export data to blob storagevar exportContent = new ExportRdbContent(    prefix: "backup",    container: "https://mystorageaccount.blob.core.windows.net/container?sastoken",    format: "RDB");
await cache.Value.ExportDataAsync(WaitUntil.Completed, exportContent);

var rebootContent = new RedisRebootContent{    RebootType = RedisRebootType.AllNodes,    ShardId = 0 // For clustered caches};
await cache.Value.ForceRebootAsync(rebootContent);

using Azure;
try{    var operation = await cacheCollection.CreateOrUpdateAsync(        WaitUntil.Completed, cacheName, cacheData);}catch (RequestFailedException ex) when (ex.Status == 409){    Console.WriteLine("Cache already exists");}catch (RequestFailedException ex) when (ex.Status == 400){    Console.WriteLine($"Invalid configuration: {ex.Message}");}catch (RequestFailedException ex){    Console.WriteLine($"ARM Error: {ex.Status} - {ex.ErrorCode}: {ex.Message}");}

using StackExchange.Redis;
// Get connection info from management SDKvar cache = await resourceGroup.Value.GetRedisAsync("my-redis-cache");var keys = await cache.Value.GetKeysAsync();
// Connect with StackExchange.Redisvar connectionString = $"{cache.Value.Data.HostName}:{cache.Value.Data.SslPort},password={keys.Value.PrimaryKey},ssl=True,abortConnect=False";var connection = ConnectionMultiplexer.Connect(connectionString);var db = connection.GetDatabase();
// Data operationsawait db.StringSetAsync("key", "value");var value = await db.StringGetAsync("key");