How to Manage Azure Storage Queues

This article explains how to manage Azure Storage queues. You can manage queues using the Azure portal, Azure CLI, Azure PowerShell, or client libraries.

using Azure.Storage.Queues;

string connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
string queueName = "my-new-queue";

// Create a QueueClient object
QueueClient queueClient = new QueueClient(connectionString, queueName);

// Create the queue
queueClient.Create();

Console.WriteLine($"Queue '{queueName}' created successfully.");
                    

using Azure.Storage.Queues;

string connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
string queueName = "my-queue-to-delete";

// Create a QueueClient object
QueueClient queueClient = new QueueClient(connectionString, queueName);

// Delete the queue
queueClient.Delete();

Console.WriteLine($"Queue '{queueName}' deleted successfully.");
                    

using Azure.Storage.Queues;

string connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";

// Create a QueueServiceClient object
QueueServiceClient queueServiceClient = new QueueServiceClient(connectionString);

Console.WriteLine("Listing queues:");
await foreach (var queueItem in queueServiceClient.GetQueuesAsync())
{
    Console.WriteLine($"- {queueItem.Name}");
}
                    

import com.azure.storage.queue.QueueClient;
import com.azure.storage.queue.QueueServiceClient;
import com.azure.storage.queue.QueueServiceClientBuilder;

public class ManageQueues {
    public static void main(String[] args) {
        String connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
        String queueName = "my-new-queue-java";

        // Create a QueueClient object
        QueueClient queueClient = new QueueClient(connectionString, queueName);

        // Create the queue
        queueClient.create();

        System.out.println("Queue '" + queueName + "' created successfully.");
    }
}
                    

import com.azure.storage.queue.QueueClient;
import com.azure.storage.queue.QueueServiceClient;
import com.azure.storage.queue.QueueServiceClientBuilder;

public class ManageQueues {
    public static void main(String[] args) {
        String connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
        String queueName = "my-queue-to-delete-java";

        // Create a QueueClient object
        QueueClient queueClient = new QueueClient(connectionString, queueName);

        // Delete the queue
        queueClient.delete();

        System.out.println("Queue '" + queueName + "' deleted successfully.");
    }
}
                    

import com.azure.storage.queue.QueueClient;
import com.azure.storage.queue.QueueServiceClient;
import com.azure.storage.queue.QueueServiceClientBuilder;
import com.azure.storage.queue.models.QueueItem;

public class ManageQueues {
    public static void main(String[] args) {
        String connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";

        // Create a QueueServiceClient object
        QueueServiceClient queueServiceClient = new QueueServiceClientBuilder()
            .connectionString(connectionString)
            .buildClient();

        System.out.println("Listing queues:");
        for (QueueItem queueItem : queueServiceClient.listQueues()) {
            System.out.println("- " + queueItem.getName());
        }
    }
}
                    

from azure.storage.queue import QueueClient

connection_string = "YOUR_AZURE_STORAGE_CONNECTION_STRING"
queue_name = "my-new-queue-python"

# Create a QueueClient object
queue_client = QueueClient.from_connection_string(connection_string, queue_name)

# Create the queue
queue_client.create_queue()

print(f"Queue '{queue_name}' created successfully.")
                    

from azure.storage.queue import QueueClient

connection_string = "YOUR_AZURE_STORAGE_CONNECTION_STRING"
queue_name = "my-queue-to-delete-python"

# Create a QueueClient object
queue_client = QueueClient.from_connection_string(connection_string, queue_name)

# Delete the queue
queue_client.delete_queue()

print(f"Queue '{queue_name}' deleted successfully.")
                    

from azure.storage.queue import QueueServiceClient

connection_string = "YOUR_AZURE_STORAGE_CONNECTION_STRING"

# Create a QueueServiceClient object
queue_service_client = QueueServiceClient.from_connection_string(connection_string)

print("Listing queues:")
for queue_item in queue_service_client.list_queues():
    print(f"- {queue_item.name}")
                    

const { QueueClient } = require("@azure/storage-queue");

const connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
const queueName = "my-new-queue-js";

// Create a QueueClient object
const queueClient = new QueueClient(connectionString, queueName);

async function createQueue() {
    await queueClient.createQueue();
    console.log(`Queue '${queueName}' created successfully.`);
}

createQueue().catch(err => console.error(err));
                    

const { QueueClient } = require("@azure/storage-queue");

const connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";
const queueName = "my-queue-to-delete-js";

// Create a QueueClient object
const queueClient = new QueueClient(connectionString, queueName);

async function deleteQueue() {
    await queueClient.deleteQueue();
    console.log(`Queue '${queueName}' deleted successfully.`);
}

deleteQueue().catch(err => console.error(err));
                    

const { QueueServiceClient } = require("@azure/storage-queue");

const connectionString = "YOUR_AZURE_STORAGE_CONNECTION_STRING";

// Create a QueueServiceClient object
const queueServiceClient = QueueServiceClient.fromConnectionString(connectionString);

async function listQueues() {
    console.log("Listing queues:");
    for await (const queueItem of queueServiceClient.listQueues()) {
        console.log(`- ${queueItem.name}`);
    }
}

listQueues().catch(err => console.error(err));
                    

az storage queue create --name my-new-queue-cli --account-name  --account-key 
                    

az storage queue delete --name my-queue-to-delete-cli --account-name  --account-key 
                    

az storage queue list --account-name  --account-key 
                    

$storageAccountName = ""
$storageAccountKey = ""
$queueName = "my-new-queue-ps"

$ctx = New-AzStorageContext -StorageAccountName $storageAccountName -StorageAccountKey $storageAccountKey
New-AzStorageQueue -Name $queueName -Context $ctx
                    

$storageAccountName = ""
$storageAccountKey = ""
$queueName = "my-queue-to-delete-ps"

$ctx = New-AzStorageContext -StorageAccountName $storageAccountName -StorageAccountKey $storageAccountKey
Remove-AzStorageQueue -Name $queueName -Context $ctx
                    

$storageAccountName = ""
$storageAccountKey = ""

$ctx = New-AzStorageContext -StorageAccountName $storageAccountName -StorageAccountKey $storageAccountKey
Get-AzStorageQueue -Context $ctx
                    

Queue Operations

You can perform various operations on Azure Storage queues, including creating, deleting, listing, and getting queue metadata. The following sections provide details and code examples for common management tasks.

Creating a Queue

When you create a queue, you specify a unique name for it within your storage account. Queue names must be between 3 and 63 characters long and adhere to certain naming conventions.

Deleting a Queue

Deleting a queue removes it and all of its messages from your storage account. This operation is irreversible.

Listing Queues

You can retrieve a list of all queues within your storage account. This is useful for inventory management and automation.

Getting Queue Metadata

You can retrieve metadata for a specific queue, such as its approximate message count and last modified time.

This article covers the fundamental management operations for Azure Storage queues. For detailed information on specific client libraries or advanced scenarios, please refer to the corresponding documentation.