Celery

Aipo foi criado inicialmente para Django, mas agora é um aplicativo ideal para Python também.
Ele foi projetado para trabalhar com filas assíncronas tarefa / emprego, quer em tempo real ou para as operações agendadas.
Aipo foi testado e está sendo usado em ambientes de produção para processar milhões de tarefas por dia.
A plataforma também foi testado com frameworks Python como Flask, Django, web2py, Pilares, Tornado e Pirâmide.
corretores suportados:
RabbitMQ
Redis
Django ORM
Amazon SQS
MongoDB
Beanstalk
CouchDB
SQLAlchemy

Armazenamentos de dados suportados:
SQLAlchemy
Django ORM
Apache Cassandra
AMQP
Redis
memcached
MongoDB
serializers suportados:
Salmoura
JSON
YAML
msgpack
zlib ou bzip2 compressão

O que é novo nesta versão:

• melhorias piscina Prefork
• Django suportado fora da caixa
• Os eventos são agora ordenados usando o tempo lógico
• Novo formato nome do nó trabalhador (nome @ host)
• tarefas vinculados
• Mingle: Trabalhador de sincronização
• Fofoca: Trabalhador & # X3C; - & # x3e; Comunicação Trabalhador
• Bootsteps: Estendendo o trabalhador
• New backend resultado RPC
• Os limites de tempo podem agora ser definido pelo cliente
• Redis: As mensagens de difusão e hosts virtuais
• pytz substitui dependência python-dateutil
• Suporte para setuptools requisitos adicionais
• subtarefa chamada .__ __ () agora executa a tarefa diretamente

O que é novo na versão 3.1.17:

• melhorias piscina Prefork
• Django suportado fora da caixa
• Os eventos são agora ordenados usando o tempo lógico
• Novo formato nome do nó trabalhador (nome @ host)
• tarefas vinculados
• Mingle: Trabalhador de sincronização
• Fofoca: Trabalhador & # X3C; - & # x3e; Comunicação Trabalhador
• Bootsteps: Estendendo o trabalhador
• New backend resultado RPC
• Os limites de tempo podem agora ser definido pelo cliente
• Redis: As mensagens de difusão e hosts virtuais
• pytz substitui dependência python-dateutil
• Suporte para setuptools requisitos adicionais
• subtarefa chamada .__ __ () agora executa a tarefa diretamente

O que é novo na versão 3.0.0:

• O trabalhador é agora thread-menos, dando grande melhorias de desempenho.
• O novo & quot; Canvas & quot; torna mais fácil para definir fluxos de trabalho complexos.
• Nova API.
• Todos os programas de linha de comando do aipo já estão disponíveis a partir de um único comando aipo guarda-chuva.
• Esta é a última versão que suporta Python 2.5.

O que é novo na versão 2.5.1:.

• Suporte Fuso Horário
• New serializer segurança usando assinatura criptográfica.
• Suporte experimental para recarga módulo automático.
• New CELERY_ANNOTATIONS configuração.
• atual fornece a tarefa atualmente em execução.

O que é novo na versão 2.4.1:

• Este comunicado contém 3 apoio Python, URLs corretor, menos dependências, e grande quantidade de correções de bugs.

O que é novo na versão 2.3.0:

• Este comunicado contém piscina de suporte de ligação automática (não habilitado por padrão), acordes (aka callbacks taskset), prazos personalizadas para tarefas individuais e muito mais.
• Os resultados são agora desativado por padrão, se você depender do resultado backend AMQP sendo o padrão, então você tem que configurar isso manualmente antes da atualização.
• Tudo está detalhado no changelog, o que você deveria ter lido antes da atualização.
• Os usuários do Django também devem atualizar para o Django 2.3 aipo.

O que é novo na versão 2.2.4:

• celeryd: 2.2.3 quebrou o registo de erros, resultando em tracebacks não sendo registrados.
• AMQP backend resultado: estados tarefa de consulta não funciona correctamente se houver mais de uma mensagem com o resultado na fila
.
• TaskSet.apply_async () e TaskSet.apply () agora suporta um argumento palavra-chave taskset_id opcional (Issue # 331).
• A corrente id taskset (se houver) está agora disponível no contexto tarefa como request.taskset (Issue # 329).
• backend resultado SQLAlchemy: date_done já não fazia parte dos resultados, uma vez que tinha sido removido acidentalmente. Ele está agora disponível novamente (Issue # 325).
• SQLAlchemy resultado backend: Adicionado restrição exclusiva em Task.task_id e TaskSet.taskset_id. Tabelas precisa ser recriado para que isso tenha efeito.
• exceção fixo gerado quando a iteração de o resultado de TaskSet.apply ().
• Tarefas Userguide: Adicionado seção sobre a escolha de um backend resultado
.

O que é novo na versão 2.2.3:

• Agora depende Kombu 1.0.3
• Task.retry agora suporta um argumento max_retries, usado para alterar o valor padrão.
• multiprocessing.cpu_count pode levantar NotImplementedError em plataformas onde isso não é suportado (Issue # 320).
• Coloring de mensagens de log quebrou se o objeto registrado não era uma string.
• várias Corrigidos problemas na documentação do script de inicialização.
• A regressão causada Task.exchange e Task.routing_key para já não tem qualquer efeito. Isso foi corrigido.

O que é novo na versão 2.2.0:

• Os celery.task.builtins módulo interno tem sido removido.
• Os celery.task.schedules módulo está obsoleto, e celery.schedules deve ser usado em vez disso.

O que é novo na versão 2.1.4:

• programas de aipo agora seqüestra o madeireiro raiz por padrão.

Requisitos :

• Python 2.5 ou superior
• Jython 2.5 ou superior