Celery

Céleri a été initialement créé pour Django, mais est maintenant une application Python-sympa aussi.
Il a été conçu pour fonctionner avec des files d'attente asynchrones tâche / emploi, soit en temps réel ou pour les opérations planifiées.
Le céleri a été testé et il est utilisé dans des environnements de production pour traiter des millions de tâches par jour.
La plate-forme a également été testé avec des cadres de Python comme Flask, Django, web2py, Pylônes, Tornado et Pyramid.
courtiers en charge:
RabbitMQ
Redis
Django ORM
Amazon SQS
MongoDB
Tige d'haricot
CouchDB
SQLAlchemy

En charge des magasins de données:
SQLAlchemy
Django ORM
Cassandra
AMQP
Redis
memcached
MongoDB
sérialiseurs pris en charge:
Pétrin
JSON
YAML
msgpack
compression zlib ou bzip2

Ce qui est nouveau dans cette version:

• amélioration de la piscine Prefork
• Django soutenu hors de la boîte
• Les événements sont maintenant commandés en utilisant temps logique
• Nouveau format du nom de nœud de travailleur (nom @ host)
• Rebond tâches
• Mingle: la synchronisation des travailleurs
• Gossip: Travailleur & # x3C; - & # X3e; la communication des travailleurs
• Bootsteps: Extension du travailleur
• Nouveau résultat RPC backend
• Les limites de temps peuvent maintenant être définies par le client
• Redis: Les messages de diffusion et des hôtes virtuels
• pytz remplace python-dateutil dépendance
• Support pour setuptools exigences supplémentaires
• sous-tâche .__ appel __ () exécute maintenant la tâche directement

Ce qui est nouveau dans la version 3.1.17:

• amélioration de la piscine Prefork
• Django soutenu hors de la boîte
• Les événements sont maintenant commandés en utilisant temps logique
• Nouveau format du nom de nœud de travailleur (nom @ host)
• Rebond tâches
• Mingle: la synchronisation des travailleurs
• Gossip: Travailleur & # x3C; - & # X3e; la communication des travailleurs
• Bootsteps: Extension du travailleur
• Nouveau résultat RPC backend
• Les limites de temps peuvent maintenant être définies par le client
• Redis: Les messages de diffusion et des hôtes virtuels
• pytz remplace python-dateutil dépendance
• Support pour setuptools exigences supplémentaires
• sous-tâche .__ appel __ () exécute maintenant la tâche directement

Quoi de neuf dans la version 3.0.0:

• Le travailleur est maintenant thread-moins, donnant une grande des améliorations de performances.
• Le nouveau & quot; Toile & quot; il est facile de définir des workflows complexes.
• Nouvelle API.
• Tous les programmes de ligne de commande de céleri sont maintenant disponibles à partir d'une seule commande de parapluie de céleri.
• Ceci est la dernière version de soutenir Python 2.5.

Ce qui est nouveau dans la version 2.5.1:.

• Support Fuseau horaire
• New sérialiseur de sécurité en utilisant la signature cryptographique.
• Prise en charge expérimentale pour le module rechargement automatique.
• New CELERY_ANNOTATIONS réglage.
• actuelle fournit la tâche en cours d'exécution.

Quoi de neuf dans la version 2.4.1:

• Le présent communiqué contient Python 3 support, URL de courtier, moins de dépendances, et des charges de corrections de bugs.

Quoi de neuf dans la version 2.3.0:

• Le présent communiqué contient connexion automatique soutien de la piscine (pas activé par défaut), accords (aka rappels taskset), les limites de temps personnalisés pour différentes tâches, et plus encore.
• Les résultats sont désormais désactivés par défaut, si vous comptez sur le résultat AMQP backend étant la valeur par défaut, alors vous devez configurer manuellement avant que la mise à niveau.
• Tout est détaillé dans le Changelog, que vous devriez avoir lu avant la mise à niveau.
• Les utilisateurs de Django doivent également passer à django-céleri 2.3.

Quoi de neuf dans la version 2.2.4:

• celeryd: 2.2.3 cassé la journalisation des erreurs, résultant dans tracebacks étant pas connecté.
• AMQP résultat backend: tâches états de vote ne fonctionnait pas correctement, si il y avait plus d'un message de résultat dans la file d'attente
.
• TaskSet.apply_async () et TaskSet.apply () supporte maintenant un argument de mot-clé taskset_id option (Issue # 331).
• Le id taskset actuelle (le cas échéant) est maintenant disponible dans le contexte de la tâche que request.taskset (Issue # 329).
• Résultat SQLAlchemy backend: date_done ne faisait plus partie des résultats comme il l'avait été supprimé accidentellement. Il est maintenant à nouveau disponible (Issue # 325).
• SQLAlchemy résultat backend: Ajouté contrainte unique sur Task.task_id et TaskSet.taskset_id. Tableaux doit être recréé pour que cela prenne effet.
• Correction d'exception soulevée lors de l'itération sur le résultat de TaskSet.apply ().
• Tâches userguide: Ajout d'une section sur le choix d'un backend de résultat
.

Ce qui est nouveau dans la version 2.2.3:

• Maintenant dépend Kombu 1.0.3
• Task.retry prend désormais un argument de max_retries, utilisée pour changer la valeur par défaut.
• multiprocessing.cpu_count peut soulever NotImplementedError sur les plateformes où ce ne sont pas pris en charge (Issue # 320).
• Coloriage des messages du journal cassé si l'objet connecté était pas une chaîne.
• Corrections de plusieurs fautes dans la documentation du script d'initialisation.
• Une régression causée Task.exchange et Task.routing_key de ne plus avoir aucun effet. Ceci est maintenant corrigé.

Quoi de neuf dans la version 2.2.0:

• Les celery.task.builtins module interne a été supprimée.
• Les celery.task.schedules module est obsolète, et celery.schedules devraient être utilisés à la place.

Quoi de neuf dans la version 2.1.4:

• programmes de céleri détourne maintenant l'enregistreur de root par défaut.

Exigences :

• Python 2.5 ou supérieur
• Jython 2.5 ou supérieur