Celery

Sedano è stato inizialmente creato per Django, ma ora è un app Python-cordiale.
E 'stato progettato per funzionare con le code asincrone compito / lavoro, sia in tempo reale o per le operazioni pianificate.
Sedano è stato testato e viene utilizzato in ambienti di produzione per elaborare milioni di operazioni al giorno.
La piattaforma è stata testata anche con i framework Python come Flask, Django, web2py, Piloni, Tornado e Piramide.
broker supportati:
RabbitMQ
Redis
ORM Django
Amazon SQS
MongoDB
Beanstalk
CouchDB
SQLAlchemy

Archivi di dati supportati:
SQLAlchemy
ORM Django
Apache Cassandra
AMQP
Redis
memcached
MongoDB
serializzatori supportati:
Sottaceto
JSON
YAML
msgpack
zlib o bzip2 compressione

Cosa c'è di nuovo in questa versione:

• miglioramenti piscina Prefork
• Django sostenuto dalla scatola
• Gli eventi vengono ora ordinate usando il tempo logico
• Nuovo formato nome nodo lavoratore (nome @ host)
• attività vincolata
• Mingle: sincronizzazione Worker
• Gossip: Worker & # x3c; - & # X3e; Comunicazione Worker
• Bootsteps: Estendere il lavoratore
• Nuovo risultato RPC backend
• I termini possono essere impostate dal client
• Redis: I messaggi broadcast e gli host virtuali
• pytz sostituisce python-dateutil dipendenza
• supporto setuptools ulteriori requisiti
• sottocompito .__ chiamata __ () ora esegue direttamente il compito

Cosa c'è di nuovo nella versione 3.1.17:

• miglioramenti piscina Prefork
• Django sostenuto dalla scatola
• Gli eventi vengono ora ordinate usando il tempo logico
• Nuovo formato nome nodo lavoratore (nome @ host)
• attività vincolata
• Mingle: sincronizzazione Worker
• Gossip: Worker & # x3c; - & # X3e; Comunicazione Worker
• Bootsteps: Estendere il lavoratore
• Nuovo risultato RPC backend
• I termini possono essere impostate dal client
• Redis: I messaggi broadcast e gli host virtuali
• pytz sostituisce python-dateutil dipendenza
• supporto setuptools ulteriori requisiti
• sottocompito .__ chiamata __ () ora esegue direttamente il compito

Cosa c'è di nuovo nella versione 3.0.0:

• Il lavoratore è ora filo-meno, dando grande miglioramenti delle prestazioni.
• Il nuovo & quot; Canvas & quot; lo rende facile definire flussi di lavoro complessi.
• Nuova API.
• Tutti i programmi a riga di comando di sedano sono ora disponibili da un unico comando sedano ombrello.
• Questa è l'ultima versione a supportare Python 2.5.

Cosa c'è di nuovo nella versione 2.5.1:.

• Supporto Fuso orario
• Nuovo serializzatore protezione utilizzando firma crittografica.
• Supporto sperimentale per ricaricare il modulo automatico.
• Nuovo CELERY_ANNOTATIONS impostazione.
• attuale prevede l'attività in corso di esecuzione.

Cosa c'è di nuovo nella versione 2.4.1:

• Questo comunicato stampa contiene Python 3 di supporto, gli URL mediatore, meno le dipendenze, e un sacco di correzioni di bug.

Cosa c'è di nuovo nella versione 2.3.0:

• Questa versione contiene il supporto pool di connessioni automatico (non abilitato per impostazione predefinita), accordi (aka callback taskset), limiti di tempo personalizzate per le singole attività e altro ancora.
• I risultati sono ora disabilitate di default, se si dipende il risultato backend AMQP essere il default, allora si deve configurare che manualmente prima di eseguire l'aggiornamento.
• Il tutto è dettagliato nel Changelog, che avresti dovuto leggere prima l'aggiornamento.
• Gli utenti di Django devono eseguire l'aggiornamento a Django-sedano 2.3.

Cosa c'è di nuovo nella versione 2.2.4:

• celeryd

  : 2.2.3 registrazione degli errori rotto, con conseguente in traceback non essere registrato.

• Risultati AMQP backend: stati del task di polling non funzionava correttamente se ci fosse più di un messaggio risultato nella coda
.
• TaskSet.apply_async () e TaskSet.apply () supporta ora un argomento chiave taskset_id opzionale (Issue # 331).
• L'attuale id taskset (se presente) è ora disponibile nel contesto compito request.taskset (Issue # 329).
• Risultati SQLAlchemy backend: date_done non faceva più parte dei risultati, come era stato rimosso accidentalmente. Ora è nuovamente disponibile (Issue # 325).
• SQLAlchemy risultato backend: Aggiunta vincolo univoco su Task.task_id e TaskSet.taskset_id. Ha bisogno di tabelle di essere ricreato per questo abbia effetto.
• eccezione fisso sollevata quando l'iterazione sul risultato di TaskSet.apply ().
• Attività userguide: Aggiunta la sezione sulla scelta di un backend risultato
.

Cosa c'è di nuovo nella versione 2.2.3:

• Ora dipende Kombu 1.0.3
• Task.retry supporta ora un argomento max_retries, utilizzato per modificare il valore predefinito.
• multiprocessing.cpu_count può sollevare NotImplementedError su piattaforme in cui questo non è supportato (Issue # 320).
• Colorazione dei messaggi di log rotto se l'oggetto registrato non era una stringa.
• Risolti diversi errori di battitura nella documentazione init script.
• Una regressione causata Task.exchange e Task.routing_key avere più alcun effetto. Questo problema è stato risolto.

Cosa c'è di nuovo nella versione 2.2.0:

• I celery.task.builtins modulo interno è stato rimosso.
• I celery.task.schedules modulo è deprecato, e celery.schedules devono essere utilizzati al posto.

Cosa c'è di nuovo nella versione 2.1.4:

• programmi di sedano ora dirotta il logger principale per impostazione predefinita.

Requisiti

• Python 2.5 o superiore
• Jython 2.5 o superiore