Je suis nouveau dans les courtiers de messages comme RabbitMQ que nous pouvons utiliser pour créer des tâches / files d'attente de messages pour un système de planification comme Celery . Maintenant, voici la question: Je peux créer une table dans PostgreSQL qui peut être ajoutée à de nouvelles...
Comment puis-je supprimer toutes les tâches en attente sans connaître le task_idpour chaque
Comment puis-je récupérer une liste de tâches dans une file d'attente qui doivent encore être
La documentation de Celery mentionne le test de Celery dans Django mais n'explique pas comment tester une tâche Celery si vous n'utilisez pas Django. Comment est-ce que tu fais
Fermé . Cette question doit être plus ciblée . Il n'accepte pas les réponses actuellement. Vous souhaitez améliorer cette question? Mettez à jour la question pour qu'elle se concentre sur un problème uniquement en éditant ce message . Fermé il y a 3 ans . Améliorez cette question Actuellement, je...
J'essaye d'exécuter l' exemple de la documentation Celery. Je cours: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." %...
Comment vérifier si une tâche est en cours dans le céleri (en particulier, j'utilise céleri-django)? J'ai lu la documentation et j'ai cherché sur Google, mais je ne vois pas un appel comme: my_example_task.state() == RUNNING Mon cas d'utilisation est que j'ai un service externe (java) pour le...
J'ai du mal à comprendre le but des «files d'attente de tâches distribuées». Par exemple, la bibliothèque de céleri de python . Je sais que dans celery, le framework python, vous pouvez définir des fenêtres chronométrées pour que les fonctions soient exécutées. Cependant, cela peut également être...
J'ai lu le document et recherché mais je n'arrive pas à trouver une réponse claire: Pouvez-vous annuler une tâche déjà en cours d'exécution? (comme dans la tâche a commencé, prend un certain temps, et à mi-chemin, elle doit être annulée) J'ai trouvé cela dans le doc sur Celery FAQ >>>...
Supposons que j'ai un modèle Event. Je souhaite envoyer une notification (e-mail, push, etc.) à tous les utilisateurs invités une fois l'événement terminé. Quelque chose dans le sens de: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited =...