Azure Queue Storage SDK for Python
在 Python 中管理 Azure Queue Storage
使用 Azure Queue Storage SDK 实现可靠的消息队列和异步处理。此技能提供用于任务分发、后台作业处理和解耦应用程序通信的生产就绪模式。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“Azure Queue Storage SDK for Python”。 如何向队列发送 JSON 消息？
预期结果:
导入 json 并使用 queue_client.send_message(json.dumps({'task': 'process', 'id': 123}))。队列会将 JSON 存储为字符串。使用 json.loads(message.content) 检索它。
正在使用“Azure Queue Storage SDK for Python”。 receive_messages 和 peek_messages 有什么区别？
预期结果:
receive_messages 使消息对其他消费者不可见（锁定进行处理），而 peek_messages 仅读取它们而不影响可见性。使用 peek 进行监控，使用 receive 进行实际处理。
正在使用“Azure Queue Storage SDK for Python”。 如何处理反复失败的毒化消息？
预期结果:
检查 message.dequeue_count - 如果超过阈值，将消息移动到死信队列而不是重试。这可以防止错误消息无限循环。
安全审计
安全Prompt-only skill containing documentation and code examples for Azure Queue Storage SDK. No executable code or scripts present. Static analysis scanned 0 files with 0 suspicious patterns detected. All content is educational reference material for legitimate Azure SDK usage. No security concerns identified.
质量评分
你能构建什么
后台任务处理
将长时间运行的任务排队供工作进程异步处理。适用于需要卸载大量计算或批处理作业的 Web 应用程序。
微服务通信
实现微服务之间可靠的基于消息的通信。使用队列解耦服务，实现容错异步消息传递。
作业队列管理
实现分布式任务调度和作业队列系统。通过可见性超时控制在多个工作进程之间管理工作分配。
试试这些提示
帮我使用 QueueServiceClient 创建一个名为 'tasks' 的 Azure Queue Storage 队列。展示使用 DefaultAzureCredential 的身份验证设置。
展示如何向 'tasks' 队列发送消息，设置 5 分钟可见性超时和 24 小时生存时间。消息内容应为 JSON。
编写一个函数，接收最多 10 条消息，逐条处理，仅在成功处理后删除它们。正确处理错误。
将此队列处理代码转换为使用 azure.storage.queue.aio 中的异步 QueueClient。展示异步上下文管理器模式。
最佳实践
- 成功处理后始终删除消息，防止重新处理和队列杂乱
- 根据实际处理时间加上安全余量设置可见性超时
- 监控 dequeue_count 以检测和处理毒化消息，避免消耗资源
- 使用 peek_messages 进行监控和调试，不影响消息可见性
避免
- 接收消息后不删除会导致重复工作和队列膨胀
- 可见性超时设置过短会导致消息在处理完成前重新出现
- 忽略 dequeue_count 会导致格式错误或无法处理的消息无限重试
- 在应该使用 peek_messages 进行监控时使用了 receive_messages