Resultados da pesquisa a pedido "celery"
Como fazer uma tarefa de aipo falhar de dentro da tarefa?
Sob algumas condições, quero fazer uma tarefa de aipo falhar nessa tarefa. Eu tentei o seguinte: from celery.task import task from celery import states @task() def run_simulation(): if ...
Celery - agende tarefas periódicas começando em um horário específico
Qual é a melhor maneira de agendar uma tarefa periódica iniciando em data / hora específica? (Não estou usando cron para isso, considerando que tenho a necessidade de agendar cerca de cem rsyncs remotos, onde eu calculo o deslocamento ...
riando filas dinamicamente com o aipo
Estou escrevendo um gerenciador de listas de discussão usando Django, Aipo e RabbitMQ. Quando uma mensagem chega, uma tarefa é executada para cada destinatário. Todas as tarefas vão para uma única fila e um ou mais funcionários consomem tarefas ...
Exemplos de Django e Aipo: Tarefas Periódicas
Estive lutando contra a documentação do Django / Aipo há um tempo e preciso de ajuda. Gostaria de poder executar tarefas periódicas usando o django-aipo. Eu já vi pela internet (e pela documentação) vários formatos e esquemas diferentes ...
Detectar se o Aipo está Disponível / Em Execução
Estou a usarSalsã [http://celeryproject.org/] para gerenciar tarefas assíncronas. Ocasionalmente, no entanto, o processo de aipo é interrompido, o que faz com que nenhuma das tarefas seja executada. Gostaria de poder verificar o status do aipo e ...
Forking processos para todas as tarefas no aipo
Atualmente, uso uma biblioteca de extensão C para Python, mas parece haver vazamento de memória. Tarefas executadas no meuceleryd faça algo usando esta biblioteca de extensão C eceleryd consome muita memória cerca de uma hora depois. Não consigo ...
Como verificar o status da tarefa no aipo?
Como verificar se uma tarefa está sendo executada no aipo (especificamente, estou usando o aipo-django Li a documentação e pesquisei no Google, mas não consigo ver uma ligação como: my_example_task.state() == RUNNING Meu caso de uso é que eu ...
Trabalhe com o aipo sendo um único ponto de falha
Estou procurando a solução recomendada para contornar o aipo, sendo um ponto único de falha na implantação do aipo / rabbitmq. Não encontrei nada que fizesse sentido até agora pesquisando na Web. No meu caso, o agendador programado uma vez por ...
Aumente o tempo de repetição do aipo a cada ciclo de repetição
Fiz novas tentativas com o aipo, como no Docs-Example: @task() def add(x, y): try: ... except Exception, exc: add.retry(exc=exc, countdown=60) # override the default and # retry in 1 minuteComo posso aumentar a contagem regressiva sempre que ...
arefas @Retry Aipo com recuo exponencial
Para uma tarefa como esta: from celery.decorators import task @task() def add(x, y): if not x or not y: raise Exception("test error") return self.wait_until_server_responds(se lançar uma exceção e desejar tentar novamente do lado do daemon, como ...