Azure Queue Storage SDK for Python
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.
Die Skill-ZIP herunterladen
In Claude hochladen
Gehe zu Einstellungen → Fähigkeiten → Skills → Skill hochladen
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
SicherPrompt-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.
Qualitätsbewertung
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
Helfen Sie mir, eine Azure Queue Storage-Warteschlange namens 'tasks' mit QueueServiceClient zu erstellen. Zeigen Sie mir die Authentifizierungseinrichtung mit DefaultAzureCredential.
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.
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.
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?
Wie handhabe ich die Authentifizierung sicher?
Was passiert, wenn ich das Löschen einer Nachricht vergesse?
Kann ich Binärdaten in Nachrichten senden?
Wie viele Nachrichten kann ich auf einmal abrufen?
Ist dieser Skill mit asynchronem Python kompatibel?
Entwicklerdetails
Autor
sickn33Lizenz
MIT
Repository
https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-storage-queue-pyRef
main
Dateistruktur
📄 SKILL.md