技能 Azure Queue Storage SDK for Python
📦

Azure Queue Storage SDK for Python

安全

PythonでAzure Queue Storageを管理

Azure Queue Storage SDKで信頼性の高いメッセージキュー和非同期処理を実装します。このスキルは、タスク分散、バックグラウンドジョブ処理、分離されたアプリケーション通信のための本番環境対応のモデルを提供します。

支持: Claude Codex Code(CC)
🥉 73 青铜
1

下载技能 ZIP

2

在 Claude 中上传

前往 设置 → 功能 → 技能 → 上传技能

3

开启并开始使用

测试它

正在使用“Azure Queue Storage SDK for Python”。 How do I send a JSON message to the queue?

预期结果:

jsonをインポートし、queue_client.send_message(json.dumps({'task': 'process', 'id': 123}))を使用します。キューはJSONを文字列として保存します。json.loads(message.content)で取得します。

正在使用“Azure Queue Storage SDK for Python”。 What is the difference between receive_messages and peek_messages?

预期结果:

receive_messagesは他のコンシューマーに対してメッセージを見えなくします(処理用にロックします)。一方、peek_messagesは可視性に影響を与えずに読むだけです。監視にはpeek、實際の処理にはreceiveを使用してください。

正在使用“Azure Queue Storage SDK for Python”。 How do I handle poison messages that fail repeatedly?

预期结果:

message.dequeue_countがしきい値を超えている場合は、 再試行する代わりにデッドレターキューにメッセージを移動してください。これにより、不正なメッセージでの無限ループを防ぎます。

安全审计

安全
v1 • 2/25/2026

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.

0
已扫描文件
0
分析行数
0
发现项
1
审计总数
未发现安全问题
审计者: claude

质量评分

38
架构
100
可维护性
87
内容
50
社区
100
安全
83
规范符合性

你能构建什么

バックグラウンドタスク処理

長時間実行されるタスクを非同期処理のためにワーカープロセスにキューイングします。重い計算やバッチジョブをオフロードする必要があるWebアプリケーションに最適です。

マイクロサービス通信

マイクロサービス間で信頼性の高いメッセージベースの通信を可能にします。障害許容の非同期メッセージングのためにキューでサービスを分離します。

ジョブキュー管理

分散タスクスケジューリングとジョブキューシステムを実装します。可視性タイムアウト制御で複数のワーカー間で作業分散を管理します。

试试这些提示

キューの作成
QueueServiceClientを使用して'tasks'という名前のAzure Queue Storageキューを作成する方法を教えてください。DefaultAzureCredentialでの認証セットアップを示してください。
オプション付きメッセージの送信
'tasks'キューに5分の可視性タイムアウトと24時間の有効期限を持つメッセージを送信する方法を教えてください。メッセージコンテンツはJSONにしてください。
信頼性の高いメッセージ処理
最大10件のメッセージを受け取り、それぞれを処理し、成功した後にのみ削除する関数を書いてください。エラーは適切に処理してください。
非同期キュー操作
このキュー処理コードをazure.storage.queue.aioの非同期QueueClientを使用するように変換してください。非同期コンテキストマネージャーパターンを示してください。

最佳实践

  • 処理に成功した後は常にメッセージを削除して、再処理とキューの詰まりを防ぎます
  • 実際の処理時間に安全マージンを加えた可視性タイムアウトを設定します
  • dequeue_countを監視して、リソースを消費する前に毒メッセージを発見して処理します
  • 監視とデバッグにはpeek_messagesを使用してメッセージの可視性に影響を与えないようにします

避免

  • 処理後にメッセージを削除せずに受信すると、重複した作業とキューの肥大化が発生します
  • 可視性タイムアウトを短く設定しすぎると、処理が完了する前にメッセージが再表示されます
  • dequeue_countを無視すると、形式不正または処理不能なメッセージで無限リトライが発生します
  • 監視にreceive_messagesを使用し、peek_messagesが正しいツールである場合

常见问题

Queue StorageとService Busの違いは何ですか?
Queue Storageは基本的メッセージキューイングに適しており、コスト効率的です。Service Busはトピック、セッション、トランザクションなどの高度な機能を提供します。シンプルなタスクキューにはQueue Storageを使用してください。
認証を安全に処理するにはどうすればいいですか?
azure-identityのDefaultAzureCredentialを使用してください。複数の認証方法をサポートしており、環境に基づいて自動的に適切なものを選択されます。
メッセージを削除し忘れた場合はどうなりますか?
可視性タイムアウトが期限切れになると、メッセージは再度表示ようになります。 重複する処理が発生する可能性があります。成功処理後は常に削除してください。
メッセージにバイナリデータを送信できますか?
はい。QueueClient作成時にBinaryBase64EncodePolicyとBinaryBase64DecodePolicyを使用して、バイナリメッセージを自動的に処理できます。
一度にいくつのメッセージを取得できますか?
receive_messagesのmessages_per_pageパラメータを使用してください。バッチあたりの最大は32件です。より大きな量の場合は、複数の呼び出しを行ってください。
このスキルは非同期Pythonに対応していますか?
はい。非同期クライアントはazure.storage.queue.aioからインポートしてください。すべての操作に非同期バージョンがあります(await client.send_message、async for in receive_messages)。

开发者详情

文件结构

📄 SKILL.md