Azure Service Bus SDK for Python
在 Python 中使用 Azure Service Bus
使用 Azure Service Bus 队列和发布/订阅主题为您的 Python 应用程序添加可靠的云消息传递，实现企业级消息传递。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“Azure Service Bus SDK for Python”。 如何向 Azure Service Bus 队列发送消息？
预期结果:
使用 ServiceBusSender 发送消息。首先使用您的命名空间和凭据创建 ServiceBusClient，然后获取队列的发送者，使用 send_messages() 发送 ServiceBusMessage 对象。
正在使用“Azure Service Bus SDK for Python”。 PEEK_LOCK 和 RECEIVE_AND_DELETE 模式有什么区别？
预期结果:
PEEK_LOCK（默认）保持消息锁定直到您完成或放弃它们，实现至少一次传递。RECEIVE_AND_DELETE 立即删除消息，提供最多一次传递，但在处理失败时无法恢复。
安全审计
安全Documentation-only skill containing Azure Service Bus SDK usage examples. Static analysis scanned 0 files (0 lines) and detected 0 potential security issues. This is a prompt-only skill with no executable code that could pose security risks.
质量评分
你能构建什么
云应用消息传递
使用队列在微服务之间实现异步通信，实现可靠的消息传递。
事件驱动架构
使用主题和订阅设置发布/订阅模式，实现分布式系统事件处理。
企业集成
使用会话、批次和死信队列处理高容量消息传递，实现强大的集成。
试试这些提示
展示如何使用 Python SDK 的异步客户端向 Azure Service Bus 队列发送消息并接收。
创建一个 Python 脚本，向 Azure Service Bus 主题发送消息并从订阅接收消息。
编写 Python 代码接收消息，处理后完成成功的消息，并将失败的消息移动到死信队列。
展示如何在 Python 中使用 Azure Service Bus 会话来确保相关消息（如订单处理）的 FIFO 排序。
最佳实践
- 为生产工作负载使用异步客户端（ServiceBusClient）以处理高并发
- 始终使用上下文管理器（async with）以确保正确的资源清理
- 在接收操作上设置 max_wait_time 以防止无限阻塞
避免
- 处理完消息后不要忘记完成 - 未处理的消息将保持锁定
- 避免发送非常大的消息 - Service Bus 每条消息限制为 256KB
- 不要跳过死信队列监控 - 没有它失败的消息将失去可见性