Biblioteca Azure Queue Storage para Rust

Quando Usar

Use esta funcionalidade quando precisar da biblioteca Azure Queue Storage para Rust. Envie, receba e gerencie mensagens de fila. Gatilhos: "queue storage rust", "QueueClient rust", "send message rust", "receive messages rust", "QueueServiceClient rust", "queue rust".

Biblioteca cliente para Azure Queue Storage — envie, receba e gerencie mensagens de fila.

Use esta funcionalidade quando:

• Um aplicativo precisar enviar ou receber mensagens do Azure Queue Storage em Rust
• Você precisar criar ou gerenciar filas
• Você precisar inspecionar, receber ou excluir mensagens de fila
• Você precisar de autenticação baseada em RBAC para operações de fila

IMPORTANTE: Use apenas o crate oficial azure_storage_queue publicado pelo usuário do crates.io azure-sdk. NÃO use crates não oficiais ou da comunidade. Crates oficiais usam underscores nos nomes e nenhum deles tem a versão 0.21.0.

Instalação

cargo add azure_storage_queue azure_identity azure_core tokio

Se o seu código usar tipos azure_core diretamente, adicione azure_core a Cargo.toml. Se você usar apenas reexportações de azure_storage_queue, a dependência direta de azure_core é opcional.

Variáveis de Ambiente

AZURE_STORAGE_QUEUE_ENDPOINT=https://<account>.queue.core.windows.net/ # Required for all operations

Autenticação

use azure_core::http::Url;
use azure_identity::DeveloperToolsCredential;
use azure_storage_queue::QueueServiceClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Local dev: DeveloperToolsCredential. Production: use ManagedIdentityCredential.
    let credential = DeveloperToolsCredential::new(None)?;
    let service_url = Url::parse("https://<storage_account_name>.queue.core.windows.net/")?;
    let service_client = QueueServiceClient::new(service_url, Some(credential), None)?;

    // Derive a queue client by name.
    let queue_client = service_client.queue_client("<queue_name>")?;
    Ok(())
}

Tipos de Cliente

Fluxo de Trabalho Principal

Enviar uma Mensagem

use azure_core::http::Url;
use azure_identity::DeveloperToolsCredential;
use azure_storage_queue::{models::QueueMessage, QueueServiceClient};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let credential = DeveloperToolsCredential::new(None)?;
    let service_url = Url::parse("https://<storage_account_name>.queue.core.windows.net/")?;
    let service_client = QueueServiceClient::new(service_url, Some(credential), None)?;
    let queue_client = service_client.queue_client("<queue_name>")?;

    let message = QueueMessage {
        message_text: Some("hello world".to_string()),
    };
    queue_client.send_message(message.try_into()?, None).await?;
    Ok(())
}

Receber Mensagens

use azure_core::http::Url;
use azure_identity::DeveloperToolsCredential;
use azure_storage_queue::QueueServiceClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let credential = DeveloperToolsCredential::new(None)?;
    let service_url = Url::parse("https://<storage_account_name>.queue.core.windows.net/")?;
    let service_client = QueueServiceClient::new(service_url, Some(credential), None)?;
    let queue_client = service_client.queue_client("<queue_name>")?;

    let response = queue_client.receive_messages(None).await?;
    let messages = response.into_model()?;
    for msg in messages.items.unwrap_or_default() {
        println!("{}", msg.message_text.as_deref().unwrap_or("<empty>"));
    }
    Ok(())
}

Excluir uma Mensagem

Após receber uma mensagem, exclua-a usando o ID da mensagem e o pop receipt:

let response = queue_client.receive_messages(None).await?;
let messages = response.into_model()?;
for msg in messages.items.unwrap_or_default() {
    if let (Some(id), Some(pop_receipt)) = (&msg.message_id, &msg.pop_receipt) {
        queue_client.delete_message(id, pop_receipt, None).await?;
    }
}

Inspecionar Mensagens

Inspecione mensagens sem removê-las da fila:

…