Fähigkeiten Azure Queue Storage SDK for Python
📦

Azure Queue Storage SDK for Python

Sicher

Azure Queue Storage in Python verwalten

Implementieren Sie zuverlässiges Message-Queuing und asynchrone Verarbeitung mit dem Azure Queue Storage SDK. Dieser Skill bietet produktionsreife Muster für Task-Verteilung, Hintergrundjob-Verarbeitung und entkoppelte Anwendungskommunikation.

Unterstützt: Claude Codex Code(CC)
🥉 73 Bronze
1

Die Skill-ZIP herunterladen

2

In Claude hochladen

Gehe zu Einstellungen → Fähigkeiten → Skills → Skill hochladen

3

Einschalten und loslegen

Teste es

Verwendung von "Azure Queue Storage SDK for Python". How do I send a JSON message to the queue?

Erwartetes Ergebnis:

Importieren Sie json und verwenden Sie queue_client.send_message(json.dumps({'task': 'process', 'id': 123})). Die Warteschlange speichert den JSON als String. Rufen Sie ihn mit json.loads(message.content) ab.

Verwendung von "Azure Queue Storage SDK for Python". What is the difference between receive_messages and peek_messages?

Erwartetes Ergebnis:

receive_messages macht Nachrichten für andere Consumer unsichtbar (sperrt sie zur Verarbeitung), während peek_messages sie nur liest, ohne die Sichtbarkeit zu beeinflussen. Verwenden Sie Peek für Monitoring und Receive für die eigentliche Verarbeitung.

Verwendung von "Azure Queue Storage SDK for Python". How do I handle poison messages that fail repeatedly?

Erwartetes Ergebnis:

Überprüfen Sie message.dequeue_count - wenn es Ihren Schwellenwert überschreitet, verschieben Sie die Nachricht in eine Dead-Letter-Warteschlange, anstatt sie erneut zu versuchen. Dies verhindert Endlosschleifen bei fehlerhaften Nachrichten.

Sicherheitsaudit

Sicher
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
Gescannte Dateien
0
Analysierte Zeilen
0
befunde
1
Gesamtzahl Audits
Keine Sicherheitsprobleme gefunden
Auditiert von: claude

Qualitätsbewertung

38
Architektur
100
Wartbarkeit
87
Inhalt
50
Community
100
Sicherheit
83
Spezifikationskonformität

Was du bauen kannst

Hintergrund-Task-Verarbeitung

Warteschlangen Sie langlaufende Tasks für die asynchrone Verarbeitung durch Worker-Prozesse. Ideal für Web-Anwendungen, die schwere Berechnungen oder Batch-Jobs auslagern müssen.

Microservices-Kommunikation

Ermöglichen Sie zuverlässige nachrichtenbasierte Kommunikation zwischen Microservices. Entkoppeln Sie Services mit Warteschlangen für fehlertolerantes asynchrones Messaging.

Job-Warteschlangenverwaltung

Implementieren Sie verteilte Task-Planung und Job-Warteschlangensysteme. Verwalten Sie die Arbeitsverteilung auf mehrere Worker mit Sichtbarkeits-Timeout-Steuerung.

Probiere diese Prompts

Warteschlange erstellen
Helfen Sie mir, eine Azure Queue Storage-Warteschlange namens 'tasks' mit QueueServiceClient zu erstellen. Zeigen Sie mir die Authentifizierungseinrichtung mit DefaultAzureCredential.
Nachrichten mit Optionen senden
Zeigen Sie mir, wie ich eine Nachricht mit einem 5-Minuten-Sichtbarkeits-Timeout und einer 24-Stunden-Time-to-Live in die 'tasks'-Warteschlange sende. Der Nachrichteninhalt sollte JSON sein.
Nachrichten zuverlässig verarbeiten
Schreiben Sie eine Funktion, die bis zu 10 Nachrichten empfängt, jede verarbeitet und sie erst nach erfolgreicher Verarbeitung löscht. Behandeln Sie Fehler korrekt.
Asynchrone Warteschlangenoperationen
Konvertieren Sie diesen Warteschlangen-Verarbeitungscode, um den async QueueClient von azure.storage.queue.aio zu verwenden. Zeigen Sie mir das async Context Manager-Muster.

Bewährte Verfahren

  • Löschen Sie Nachrichten immer nach erfolgreicher Verarbeitung, um Wiederholungsverarbeitung und Warteschlangen-Überflutung zu vermeiden
  • Setzen Sie das Sichtbarkeits-Timeout basierend auf der tatsächlichen Verarbeitungszeit plus Sicherheitsspielraum
  • Überwachen Sie dequeue_count, um Poison-Nachrichten zu erkennen und zu behandeln, bevor sie Ressourcen verbrauchen
  • Verwenden Sie peek_messages für Monitoring und Debugging, ohne die Nachrichtensichtbarkeit zu beeinflussen

Vermeiden

  • Nachrichten empfangen, ohne sie nach der Verarbeitung zu löschen, verursacht doppelte Arbeit und Warteschlangen-Überflutung
  • Sichtbarkeits-Timeout zu kurz setzen führt dazu, dass Nachrichten vor Abschluss der Verarbeitung wieder erscheinen
  • dequeue_count ignorieren führt zu Endloswiederholungen bei fehlerhaften oder nicht verarbeitbaren Nachrichten
  • receive_messages für Monitoring verwenden, wenn peek_messages das richtige Werkzeug ist

Häufig gestellte Fragen

Was ist der Unterschied zwischen Queue Storage und Service Bus?
Queue Storage ist einfacher und kostengünstiger für grundlegendes Message-Queuing. Service Bus bietet erweiterte Funktionen wie Topics, Sessions und Transaktionen. Verwenden Sie Queue Storage für einfache Task-Warteschlangen.
Wie handhabe ich die Authentifizierung sicher?
Verwenden Sie DefaultAzureCredential von azure-identity. Es unterstützt mehrere Authentifizierungsmethoden und wählt automatisch die richtige basierend auf Ihrer Umgebung.
Was passiert, wenn ich das Löschen einer Nachricht vergesse?
Die Nachricht wird wieder sichtbar, nachdem das Sichtbarkeits-Timeout abgelaufen ist. Sie wird erneut verarbeitet, was potenziell doppelte Arbeit verursacht. Löschen Sie immer nach erfolgreicher Verarbeitung.
Kann ich Binärdaten in Nachrichten senden?
Ja. Verwenden Sie BinaryBase64EncodePolicy und BinaryBase64DecodePolicy beim Erstellen des QueueClient, um Binärnachrichten automatisch zu verarbeiten.
Wie viele Nachrichten kann ich auf einmal abrufen?
Verwenden Sie den Parameter messages_per_page in receive_messages. Das Maximum sind 32 Nachrichten pro Batch. Für größere Mengen führen Sie mehrere Aufrufe durch.
Ist dieser Skill mit asynchronem Python kompatibel?
Ja. Importieren Sie von azure.storage.queue.aio für den async-Client. Alle Operationen haben asynchrone Versionen (await client.send_message, async for in receive_messages).

Entwicklerdetails

Dateistruktur

📄 SKILL.md