Azure Queue Storage SDK for Python
Gérer le stockage de files d'attente Azure en Python
Implémentez une mise en file d'attente de messages fiable et un traitement asynchrone avec le SDK Azure Queue Storage. Cette compétence fournit des modèles prêts pour la production pour la distribution de tâches, le traitement des tâches en arrière-plan et la communication d'applications découplées.
Télécharger le ZIP du skill
Importer dans Claude
Allez dans Paramètres → Capacités → Skills → Importer un skill
Activez et commencez à utiliser
Tester
Utilisation de "Azure Queue Storage SDK for Python". Comment envoyer un message JSON dans la file d'attente ?
Résultat attendu:
Importez json et utilisez queue_client.send_message(json.dumps({'task': 'process', 'id': 123})). La file d'attente stockera le JSON comme une chaîne. Récupérez-le avec json.loads(message.content).
Utilisation de "Azure Queue Storage SDK for Python". Quelle est la différence entre receive_messages et peek_messages ?
Résultat attendu:
receive_messages rend les messages invisibles pour les autres consommateurs (les verrouillera pour le traitement), tandis que peek_messages les lit uniquement sans affecter la visibilité. Utilisez peek pour la surveillance et receive pour le traitement réel.
Utilisation de "Azure Queue Storage SDK for Python". Comment gérer les messages poison qui échouent反复 ?
Résultat attendu:
Vérifiez message.dequeue_count - s'il dépasse votre seuil, déplacez le message vers une file d'attente de messages incohérents au lieu de réessayer. Cela empêche les boucles infinies sur les mauvais messages.
Audit de sécurité
SûrPrompt-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.
Score de qualité
Ce que vous pouvez construire
Traitement des tâches en arrière-plan
Mettez en file d'attente les tâches de longue durée pour un traitement asynchrone par les processus de travail. Idéal pour les applications web qui doivent décharger les calculs lourds ou les traitements par lots.
Communication entre microservices
Permettez une communication basée sur les messages fiable entre microservices. Découplez les services avec des files d'attente pour une messagerie asynchrone tolérante aux pannes.
Gestion de la file d'attente des travaux
Implémentez la planification distribuée des tâches et les systèmes de file d'attente. Gérez la distribution du travail entre plusieurs workers avec le contrôle du délai de visibilité.
Essayez ces prompts
Aidez-moi à créer une file d'attente Azure Queue Storage nommée 'tasks' en utilisant QueueServiceClient. Montrez-moi la configuration d'authentification avec DefaultAzureCredential.
Montrez-moi comment envoyer un message à la file d'attente 'tasks' avec un délai de visibilité de 5 minutes et une durée de vie de 24 heures. Le contenu du message doit être JSON.
Écrivez une fonction qui reçoit jusqu'à 10 messages, traite chacun d'eux et les supprime uniquement après un traitement réussi. Gérez les erreurs correctement.
Convertissez ce code de traitement de file d'attente pour utiliser QueueClient asynchrone depuis azure.storage.queue.aio. Montrez-moi le pattern du gestionnaire de contexte asynchrone.
Bonnes pratiques
- Supprimez toujours les messages après un traitement réussi pour éviter le retraitement et l'encombrement de la file d'attente
- Définissez le délai de visibilité en fonction du temps de traitement réel plus une marge de sécurité
- Surveillez dequeue_count pour détecter et gérer les messages poison avant qu'ils ne consomment des ressources
- Utilisez peek_messages pour la surveillance et le débogage sans affecter la visibilité des messages
Éviter
- Recevoir des messages sans les supprimer après le traitement provoque un travail en double et un encombrement de la file d'attente
- Définir un délai de visibilité trop court fait réapparaître les messages avant la fin du traitement
- Ignorer dequeue_count conduit à des tentatives infinies sur des messages malformés ou impossibles à traiter
- Utiliser receive_messages pour la surveillance alors que peek_messages est l'outil correct