Creating and Managing Azure Queue Storage Queues and Messages by Using NET

using Azure.Storage.Queues;
using System;
using System.Configuration;

string connectionString = ConfigurationManager.AppSettings["StorageConnectionString"];
string queueName = "my-queue";
string message = "Hello, Azure Queue!";

// Instantiate a QueueClient which will be used to create and manipulate the queue
var queueClient = new QueueClient(connectionString, queueName);

// Create the queue if it doesn't already exist
queueClient.CreateIfNotExists();

if (queueClient.Exists())
{
    // Send a message to the queue
    queueClient.SendMessage(message);
}
else
{
    Console.WriteLine("Failed to create or access the queue.");
}

using System;
using System.IO;
using System.Threading.Tasks;
using Azure.Identity;
using Azure.Storage.Queues;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

public static class QueuePost
{
    private const string queueName = "az204"; // Replace with your queue name
    private const string storageAccount = "az204fnqueuewriter"; // Replace with your storage account name

    [FunctionName("QueuePost")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
        ILogger log)
    {
        log.LogInformation("Processing a POST request to write message to Azure Queue...");

        try
        {
            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            var data = JsonConvert.DeserializeObject(requestBody);
            if (data == null)
            {
                return new BadRequestObjectResult("Invalid payload");
            }

            var credential = new DefaultAzureCredential();
            var queueUri = new Uri($"https://{storageAccount}.queue.core.windows.net/{queueName}");
            var queueClient = new QueueClient(queueUri, credential);

            // Create the queue if it doesn't exist
            await queueClient.CreateIfNotExistsAsync();

            if (await queueClient.ExistsAsync())
            {
                await queueClient.SendMessageAsync(requestBody);
                log.LogInformation($"Message added to the queue: {requestBody}");
            }
            else
            {
                log.LogError("Queue does not exist and could not be created.");
                return new BadRequestObjectResult("Queue does not exist.");
            }

            return new OkObjectResult($"Message added to queue: {queueName}");
        }
        catch (Exception ex)
        {
            log.LogError($"Error occurred while writing to the queue: {ex.Message}");
            return new StatusCodeResult(StatusCodes.Status500InternalServerError);
        }
    }
}

{
  "generatedBy": "Microsoft.NET.Sdk.Functions.Generator-4.4.0",
  "configurationSource": "attributes",
  "bindings": [
    {
      "type": "httpTrigger",
      "methods": [ "post" ],
      "authLevel": "function",
      "name": "req"
    }
  ],
  "disabled": false,
  "scriptFile": "../bin/QueueWriter.dll",
  "entryPoint": "QueuePost.Run"
}

{
  "name": "admin",
  "url": "www.abc.com/admin.png"
}

2024-09-27T11:05:02Z    [Information]    Executing 'QueuePost' (Reason='This function was programmatically called via the host APIs...', Id=562bdae3-54fd-4fec-b207-7382829df4d0, ...)
2024-09-27T11:05:02Z    [Information]    Processing a POST request to write message to Azure Queue...
2024-09-27T11:05:02Z    [Information]    Message added to the queue: {"name":"admin","url":"www.abc.com/admin.png"}
2024-09-27T11:05:04Z    [Information]    Executed 'QueuePost' (Succeeded, Id=562bdae3-54fd-4fec-b207-7382829df4d0, Duration=1954ms)