Queue storage basics in Azure - Mini Project: Build & Apply

Queue storage basics

📖 Scenario: You are building a simple messaging system using Azure Queue Storage. This system will store messages in a queue to be processed later by other services.

🎯 Goal: Create an Azure Queue Storage setup with a queue named taskqueue. Add a message to the queue and configure the queue properties.

📋 What You'll Learn

Create a queue client for the queue named taskqueue

Add a message with the exact text 'Process this task' to the queue

Set the queue's metadata with a key environment and value development

💡 Why This Matters

🌍 Real World

Azure Queue Storage is used to decouple components in cloud applications by storing messages that can be processed asynchronously.

💼 Career

Understanding queue storage basics is essential for cloud developers and architects to build scalable and reliable distributed systems.

1

Create the queue client

Create a variable called queue_client using QueueClient from azure.storage.queue with connection string conn_str and queue name 'taskqueue'.

Azure

from azure.storage.queue import QueueClient

conn_str = "DefaultEndpointsProtocol=https;AccountName=examplestorage;AccountKey=examplekey;EndpointSuffix=core.windows.net"

# Create queue_client for 'taskqueue'
# Your code here

Need a hint?

Use QueueClient.from_connection_string with conn_str and 'taskqueue'.

2

Create the queue if it does not exist

Call the create_queue() method on queue_client to create the queue if it does not already exist.

Azure

from azure.storage.queue import QueueClient

conn_str = "DefaultEndpointsProtocol=https;AccountName=examplestorage;AccountKey=examplekey;EndpointSuffix=core.windows.net"

queue_client = QueueClient.from_connection_string(conn_str, "taskqueue")

# Create the queue if it does not exist
# Your code here

Need a hint?

Use queue_client.create_queue() to ensure the queue exists.

3

Add a message to the queue

Use the send_message() method on queue_client to add the message 'Process this task' to the queue.

Azure

from azure.storage.queue import QueueClient

conn_str = "DefaultEndpointsProtocol=https;AccountName=examplestorage;AccountKey=examplekey;EndpointSuffix=core.windows.net"

queue_client = QueueClient.from_connection_string(conn_str, "taskqueue")

queue_client.create_queue()

# Add message 'Process this task' to the queue
# Your code here

Need a hint?

Call queue_client.send_message() with the exact string 'Process this task'.

4

Set metadata on the queue

Set the metadata of queue_client to a dictionary with key 'environment' and value 'development' using the set_queue_metadata() method.

Azure

from azure.storage.queue import QueueClient

conn_str = "DefaultEndpointsProtocol=https;AccountName=examplestorage;AccountKey=examplekey;EndpointSuffix=core.windows.net"

queue_client = QueueClient.from_connection_string(conn_str, "taskqueue")

queue_client.create_queue()

queue_client.send_message('Process this task')

# Set metadata with {'environment': 'development'}
# Your code here

Need a hint?

Use queue_client.set_queue_metadata() with the correct dictionary.