Python'dan Azure Kuyruk Depolama kullanma

pip install azure-storage-queue

pip install azure-storage-queue==2.1.0

nesnesi QueueClient bir kuyrukla çalışmana olanak sağlar. Aşağıdaki kodu, bir Azure kuyruğuna program aracılığıyla erişmek istediğiniz herhangi bir Python dosyasının en üstüne ekleyin:

from azure.storage.queue import (
        QueueClient,
        BinaryBase64EncodePolicy,
        BinaryBase64DecodePolicy
)

import os, uuid

nesnesi QueueService kuyruklarla çalışmana olanak sağlar. Aşağıdaki kod bir nesnesi QueueService oluşturur. Azure veritabanına program aracılığıyla erişmek istediğiniz herhangi bir Python dosyasının en üstüne aşağıdaki kodu Depolama:

from azure.storage.queue import (
        QueueService,
        QueueMessageFormat
)

import os, uuid

Aşağıdaki kod, depolama QueueClient bağlantı dizesini kullanarak bir nesnesi oluşturur.

# Retrieve the connection string from an environment
# variable named AZURE_STORAGE_CONNECTION_STRING
connect_str = os.getenv("AZURE_STORAGE_CONNECTION_STRING")

# Create a unique name for the queue
q_name = "queue-" + str(uuid.uuid4())

# Instantiate a QueueClient object which will
# be used to create and manipulate the queue
print("Creating queue: " + q_name)
queue_client = QueueClient.from_connection_string(connect_str, q_name)

# Create the queue
queue_client.create_queue()

Aşağıdaki kod, depolama QueueService bağlantı dizesini kullanarak bir nesnesi oluşturur.

# Retrieve the connection string from an environment
# variable named AZURE_STORAGE_CONNECTION_STRING
connect_str = os.getenv("AZURE_STORAGE_CONNECTION_STRING")

# Create a unique name for the queue
queue_name = "queue-" + str(uuid.uuid4())

# Create a QueueService object which will
# be used to create and manipulate the queue
print("Creating queue: " + queue_name)
queue_service = QueueService(connection_string=connect_str)

# Create the queue
queue_service.create_queue(queue_name)

İstemci nesnesini oluştururken Base64 kodlama ve kod çözme işlevlerini yapılandırma.

# Setup Base64 encoding and decoding functions
base64_queue_client = QueueClient.from_connection_string(
                            conn_str=connect_str, queue_name=q_name,
                            message_encode_policy = BinaryBase64EncodePolicy(),
                            message_decode_policy = BinaryBase64DecodePolicy()
                        )

Queue Depolama nesne üzerinde Base64 kodlama ve Depolama yapılandırma.

# Setup Base64 encoding and decoding functions
queue_service.encode_function = QueueMessageFormat.binary_base64encode
queue_service.decode_function = QueueMessageFormat.binary_base64decode

Kuyruğa ileti eklemek için yöntemini send_message kullanın.

message = u"Hello World"
print("Adding message: " + message)
queue_client.send_message(message)

Kuyruğa ileti eklemek için yöntemini put_message kullanarak yeni bir ileti oluşturun ve kuyruğa ekleyin.

message = u"Hello, World"
print("Adding message: " + message)
queue_service.put_message(queue_name, message)

yöntemini çağırarak iletileri kuyruktan kaldırmadan göz peek_messages atabilirsiniz. Varsayılan olarak, bu yöntem tek bir iletiye göz atıyor.

# Peek at the first message
messages = queue_client.peek_messages()

for peeked_message in messages:
    print("Peeked message: " + peeked_message.content)

yöntemini çağırarak iletileri kuyruktan kaldırmadan göz peek_messages atabilirsiniz. Varsayılan olarak, bu yöntem tek bir iletiye göz atıyor.

messages = queue_service.peek_messages(queue_name)

for peeked_message in messages:
    print("Peeked message: " + peeked_message.content)

Aşağıdaki kod, bir update_message iletiyi güncelleştirmek için yöntemini kullanır. Görünürlük zaman aşımı 0 olarak ayarlanır, yani ileti hemen görünür ve içerik güncelleştirilir.

messages = queue_client.receive_messages()
list_result = next(messages)

message = queue_client.update_message(
        list_result.id, list_result.pop_receipt,
        visibility_timeout=0, content=u'Hello World Again')

print("Updated message to: " + message.content)

Aşağıdaki kod, bir update_message iletiyi güncelleştirmek için yöntemini kullanır. Görünürlük zaman aşımı 0 olarak ayarlanır, yani ileti hemen görünür ve içerik güncelleştirilir.

messages = queue_service.get_messages(queue_name)

for message in messages:
    queue_service.update_message(
        queue_name, message.id, message.pop_receipt, 0, u"Hello, World Again")

aşağıdaki get_queue_properties yöntemi, dahil olmak üzere kuyruk özelliklerini approximate_message_count döndürür.

properties = queue_client.get_queue_properties()
count = properties.approximate_message_count
print("Message count: " + str(count))

yöntemi get_queue_metadata dahil olmak üzere kuyruk özelliklerini approximate_message_count döndürür.

metadata = queue_service.get_queue_metadata(queue_name)
count = metadata.approximate_message_count
print("Message count: " + str(count))

receive_messages çağırarakvarsayılan olarak kuyrukta bir sonraki iletiyi alırsınız. 'den döndürülen receive_messages ileti, bu kuyruktan iletileri okuyan diğer kodlar için görünmez hale gelir. Varsayılan olarak bu ileti 30 saniye görünmez kalır. İletiyi kuyruktan kaldırmayı tamamlamak için aynı zamanda delete_message.

messages = queue_client.receive_messages()

for message in messages:
    print("Dequeueing message: " + message.content)
    queue_client.delete_message(message.id, message.pop_receipt)

get_messages çağırarakvarsayılan olarak kuyrukta bir sonraki iletiyi alırsınız. 'den döndürülen get_messages ileti, bu kuyruktan iletileri okuyan diğer kodlar için görünmez hale gelir. Varsayılan olarak bu ileti 30 saniye görünmez kalır. İletiyi kuyruktan kaldırmayı tamamlamak için aynı zamanda delete_message.

messages = queue_service.get_messages(queue_name)

for message in messages:
    print("Deleting message: " + message.content)
    queue_service.delete_message(queue_name, message.id, message.pop_receipt)

Aşağıdaki kod örneği iletileri receive_messages toplu olarak almak için yöntemini kullanır. Ardından, iç içe geçmiş bir döngü kullanarak her toplu iş içindeki her iletiyi for işler. Ayrıca her ileti için görünmezlik zaman aşımı beş dakika olarak ayarlanır.

messages = queue_client.receive_messages(messages_per_page=5, visibility_timeout=5*60)

for msg_batch in messages.by_page():
   for msg in msg_batch:
      print("Batch dequeue message: " + msg.content)
      queue_client.delete_message(msg)

Aşağıdaki kod örneği, bir get_messages çağrıda 16 ileti almak için yöntemini kullanır. Ardından döngü kullanarak her iletiyi for işler. Ayrıca her ileti için görünmezlik zaman aşımı beş dakika olarak ayarlanır.

messages = queue_service.get_messages(queue_name, num_messages=16, visibility_timeout=5*60)

for message in messages:
    print("Deleting message: " + message.content)
    queue_service.delete_message(queue_name, message.id, message.pop_receipt)

Bir kuyruğu ve içinde yer alan tüm iletileri silmek için yöntemini delete_queue çağırabilirsiniz.

print("Deleting queue: " + queue_client.queue_name)
queue_client.delete_queue()

Bir kuyruğu ve içinde yer alan tüm iletileri silmek için yöntemini delete_queue çağırabilirsiniz.

print("Deleting queue: " + queue_name)
queue_service.delete_queue(queue_name)