AI 技能AI 插件人工智能【免费下载链接】agentic-awesome-skillsAAS Core is the local, agent-first control plane for complete catalog discovery, agent-owned selection, stack validation, and planning, backed by 2,600 agentic skills. Includes CLI, local MCP, catalog, plugins, and Workbench.项目地址https://gitcode.com/GitHub_Trending/an/agentic-awesome-skills点击查看免费下载导读本文以 agentic-awesome-skills 仓库中收录的官方技能文档 azure-servicebus-rust 为主体系统讲解如何用 Rust 通过官方azure_messaging_servicebuscrate 接入 Azure Service Bus实现基于队列的点对点消息与基于主题/订阅的发布-订阅消息。读完本文你将掌握从依赖安装、Entra ID 认证、发送/接收消息到消息结算complete/abandon与 RBAC 授权的完整落地路径并理解该 SDK 目前处于早期开发阶段这一关键前提。技能定位与使用场景该技能对应微软官方 Skills 仓库中azure-sdk-rust插件下的同名技能source_type 标注为official风险等级为critical日期为 2026-07-01。其触发词包括service bus rust、ServiceBusClient rust、send message servicebus rust、receive message servicebus rust、queue rust messaging、topic subscription rust。适用场景非常明确应用需要从 Rust 中通过 Azure Service Bus 发送或接收消息需要基于队列的点对点消息配合竞争消费者competing consumers模型需要基于主题和订阅的发布-订阅消息实现一对多扇出需要具备完成语义completion semantics的可靠消息投递。⚠️重要警告该 crate 正处于早期开发阶段不应在生产环境中使用API 可能在没有通知的情况下发生变化。任何引入该依赖的工程都需要接受这一风险并通过固定版本号来约束升级。⚠️包来源约束只能使用由 crates.io 上 azure-sdk 用户发布的官方azure_messaging_servicebuscrate不要使用非官方或社区 crate。官方 crate 均使用下划线命名且没有任何官方 crate 的版本是 0.21.0——这是甄别山寨包的重要信号。安装与依赖管理技能文档明确要求通过cargo add管理依赖永远不要直接手改Cargo.tomlcargo add azure_messaging_servicebus azure_identity tokio依赖取舍要点如果代码中直接使用了azure_core的类型例如azure_core::http::Url、azure_core::http::RequestContent、azure_core::error::ErrorKind需要额外cargo add azure_core如果只使用azure_messaging_servicebus重导出的类型则azure_core的直接依赖是可选的azure_identity提供全部认证凭据类型tokio为异步运行时二者均为必选项。环境变量与命名空间使用 Entra ID原 Azure AD认证时唯一的必需环境变量是命名空间SERVICEBUS_NAMESPACEnamespace.servicebus.windows.net # Required — fully qualified namespacenamespace.servicebus.windows.net是全限定命名空间主机名Service Bus 客户端通过该主机名定位到命名空间下的全部消息组件。若使用服务主体Service Principal认证可参考同仓库 azure-identity-rust 技能补充以下环境变量# Service Principal生产/CI 环境 AZURE_TENANT_IDyour-tenant-id AZURE_CLIENT_IDyour-client-id AZURE_CLIENT_SECRETyour-client-secret # 用户分配托管身份可选 AZURE_CLIENT_IDmanaged-identity-client-id关键概念概念说明Namespace所有消息组件的容器是连接与管理的边界Queue点对点消息支持竞争消费者一个消息只被一个消费者处理Topic发布-订阅消息——一个发送者多个订阅者Subscription从主题接收消息的实体每个订阅独立获得消息副本Message数据与元数据的封装具有完成complete/放弃abandon语义理解这四个实体的关系是使用本技能的前提Queue 适合任务分发与负载均衡Topic Subscription 适合事件广播与扇出fan-out场景——当多个消费者需要同一份消息时应选择主题而非队列。认证从本地开发到生产该 SDK 采用与 azure-sdk-for-rust 一致的凭据模型。技能文档强调Rust 没有单一的DefaultAzureCredential类型因此本地开发使用DeveloperToolsCredential生产环境使用ManagedIdentityCredential。use azure_identity::DeveloperToolsCredential; use azure_messaging_servicebus::ServiceBusClient; #[tokio::main] async fn main() - Result(), Boxdyn std::error::Error { // Local dev: DeveloperToolsCredential. Production: use ManagedIdentityCredential. let credential DeveloperToolsCredential::new(None)?; let client ServiceBusClient::builder() .open(your_namespace.servicebus.windows.net, credential.clone()) .await?; Ok(()) }凭据链与凭据类型据同仓库 azure-identity-rust 技能文档DeveloperToolsCredential会按固定顺序尝试开发者工具顺序凭据环境要求1AzureCliCredential已执行az login2AzureDeveloperCliCredential已执行azd auth login完整的凭据类型覆盖了本地、Azure 托管资源与 CI 等全部场景凭据适用场景DeveloperToolsCredential本地开发自动尝试 CLI 工具ManagedIdentityCredentialAzure VM、App Service、Functions、AKS 等托管资源WorkloadIdentityCredentialKubernetes 工作负载身份ClientSecretCredential使用密钥的服务主体ClientCertificateCredential使用证书的服务主体AzureCliCredential直接使用 Azure CLI 认证AzureDeveloperCliCredential直接使用 azd CLI 认证AzurePipelinesCredentialAzure Pipelines 服务连接ClientAssertionCredential自定义断言联合身份生产环境使用托管身份的写法use azure_identity::ManagedIdentityCredential; // 系统分配托管身份 let credential ManagedIdentityCredential::new(None)?; // 用户分配托管身份 let options ManagedIdentityCredentialOptions { client_id: Some(user-assigned-mi-client-id.into()), ..Default::default() }; let credential ManagedIdentityCredential::new(Some(options))?;若采用服务主体 密钥适合无托管身份的 CI 场景use azure_identity::ClientSecretCredential; let credential ClientSecretCredential::new( tenant-id.into(), client-id.into(), client-secret.into(), None, )?;凭据是Arc包裹的clone 成本极低同一凭据实例可复用于多个客户端Service Bus、Event Hubs、Cosmos DB 等这是 azure-sdk-for-rust 的统一约定。核心工作流队列消息收发向队列发送消息use azure_identity::DeveloperToolsCredential; use azure_messaging_servicebus::{ServiceBusClient, Message}; #[tokio::main] async fn main() - Result(), Boxdyn std::error::Error { let credential DeveloperToolsCredential::new(None)?; let client ServiceBusClient::builder() .open(your_namespace.servicebus.windows.net, credential.clone()) .await?; let sender client.create_sender(my_queue, None).await?; let message Message::from(Hello, Service Bus!); sender.send_message(message, None).await?; Ok(()) }关键点create_sender(my_queue, None)返回Sender句柄Message::from从字符串构造消息send_message第二个参数为可选选项此处传None。从队列接收消息use azure_identity::DeveloperToolsCredential; use azure_messaging_servicebus::ServiceBusClient; #[tokio::main] async fn main() - Result(), Boxdyn std::error::Error { let credential DeveloperToolsCredential::new(None)?; let client ServiceBusClient::builder() .open(your_namespace.servicebus.windows.net, credential.clone()) .await?; let receiver client.create_receiver(my_queue, None).await?; let messages receiver.receive_messages(5, None).await?; for message in messages { println!(Received: {}, message.body_as_string()?); receiver.complete_message(message, None).await?; } Ok(()) }receive_messages(5, None)一次性拉取至多 5 条消息body_as_string()解码消息体处理成功后必须调用complete_message否则消息会被重新投递。核心工作流主题与订阅向主题发送消息let sender client.create_sender(my_topic, None).await?; let message Message::from(Hello, Topic subscribers!); sender.send_message(message, None).await?;发送到主题与发送到队列的 API 完全一致区别仅在于目标实体发送到主题后该消息会被投递到主题下每个订阅的独立副本中。从订阅接收消息let receiver client .create_receiver_for_subscription(my_topic, my_subscription, None) .await?; let messages receiver.receive_messages(5, None).await?; for message in messages { println!(Received: {}, message.body_as_string()?); receiver.complete_message(message, None).await?; }接收订阅消息使用create_receiver_for_subscription需要同时指定主题名与订阅名。循环内的complete_message语义与队列接收完全一致。消息结算Message Settlement动作用途complete从队列/订阅移除消息——处理成功abandon释放锁——消息重新变为可投递用于重试务必在成功处理之后完成complete消息以防止重复投递。abandon 场景则用于处理失败时主动交还消息让其他消费者重试。RBAC 角色与授权使用 Entra ID 认证时需要为身份用户、服务主体或托管身份分配以下数据平面角色之一角色访问权限Azure Service Bus Data Sender发送消息Azure Service Bus Data Receiver接收消息Azure Service Bus Data Owner完整访问最小权限原则下只发送就分配 Data Sender只接收就分配 Data Receiver避免直接使用 Data Owner。与 Event Hubs 等其他 Azure 消息服务的 RBAC 模型保持一致可在 Azure 门户的命名空间访问控制 (IAM)中完成分配。最佳实践清单技能文档给出 8 条最佳实践逐条展开如下用cargo add管理依赖不要直接编辑Cargo.toml。添加/移除 Rust SDK 依赖一律通过 cargo 命令避免手改清单导致版本漂移或依赖图损坏。仅在直接导入azure_core类型时才添加azure_core依赖。判断标准是代码中是否出现azure_core::http::Url、azure_core::http::RequestContent、azure_core::error::ErrorKind等路径否则直接依赖可选。本地开发用DeveloperToolsCredential生产用ManagedIdentityCredential。Rust 生态没有DefaultAzureCredential单类型方案必须按环境显式选择。绝不硬编码凭据——使用环境变量或托管身份。分配 RBAC 角色——确保身份具备恰当的 Service Bus 数据角色见上节。总是完成消息——处理完成后调用complete_message将消息从队列/订阅移除防止重复投递。扇出场景用主题——当多个消费者需要同一份消息时使用主题 订阅而非队列。该 crate 处于预发布阶段——API 可能变动务必在依赖工作流中固定依赖版本pin version。参考资源API 参考azure_messaging_servicebus的 docs.rs 最新文档对应 crate 名称azure_messaging_servicebus发布页面crates.io 上的azure_messaging_servicebus页面注意甄别发布者为 azure-sdk 用户源码Azure/azure-sdk-for-rust 仓库的sdk/servicebus/azure_messaging_servicebus目录。在 agentic-awesome-skills 仓库中本文所依据的技能文件位于 azure-servicebus-rust/SKILL.md与之配套的认证技能 azure-identity-rust 提供了完整的凭据体系说明同为消息家族的 azure-eventhub-rust 与数据库客户端 azure-cosmos-rust 展示了 azure-sdk-for-rust 统一的凭据 客户端 builder/open使用模式可交叉参考。使用限制与注意事项仅在任务与技能的上游来源及本地项目上下文明确匹配时使用本技能应用改动前务必验证命令、生成的代码、依赖、凭据及外部服务行为不要将示例当作环境特定测试、安全审查或对破坏性/高成本操作的用户批准的替代品再次强调当前 crate 处于早期开发阶段引入生产系统前需充分评估 API 稳定性风险并固定版本。赞分享AI 技能AI 插件人工智能【免费下载链接】agentic-awesome-skillsAAS Core is the local, agent-first control plane for complete catalog discovery, agent-owned selection, stack validation, and planning, backed by 2,600 agentic skills. Includes CLI, local MCP, catalog, plugins, and Workbench.项目地址https://gitcode.com/GitHub_Trending/an/agentic-awesome-skills点击查看免费下载相关推荐使用 Azure Queue Storage Python SDK 构建可靠消息队列azure-storage-queue-py 实战指南使用 Azure Queue Storage Python SDK 构建可靠消息队列azure storage queue py 实战指南 导读 本文围绕 aAI 技能AI 插件人工智能agentic-awesome-skills 仓库中的 azure-eventhub-rust 技能用 Rust 实现 Azure Event Hubs 事件流收发实战指南agentic awesome skills 仓库中的 azure eventhub rust 技能用 Rust 实现 Azure Event Hubs 事件AI 技能AI 插件人工智能Azure Service Bus Python SDK 实战指南队列、主题订阅与会话消息全解析Azure Service Bus Python SDK 实战指南队列、主题订阅与会话消息全解析 本指南基于 agentic awesome skills 仓AI 技能AI 插件人工智能上一篇ILLA Builder表单提交体验优化加载状态与成功反馈下一篇终极DNS反向解析指南使用dig -x命令快速查询IP对应的域名创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
