Resultados da pesquisa a pedido "celery"
O aipo está executando novamente tarefas concluídas de longa duração repetidas vezes
Eu tenho uma fila python aipo-redis processando uploads e downloads que valem shows e shows de dados por vez. Poucos envios levam algumas horas. No entanto, quando essa tarefa é concluída, estou testemunhando esse comportamento bizarro do aipo ...
Usar pool de multiprocessamento da tarefa de aipo gera exceção
Para aqueles que leem isso: Decidi usar o RQ, que não falha ao executar o código que usa o módulo de multiprocessamento. Eu sugiro que você use isso. Estou tentando usar um pool de multiprocessamento de dentro de uma tarefa de aipo usando Python ...
Como digo ao trabalhador do aipo para parar de aceitar tarefas? Como posso verificar se alguma tarefa de trabalhador de aipo está em execução?
O cenário: Sistema em execução em um servidor que consiste em um aplicativo Web Python / Flask e tarefas em segundo plano usando o CeleryOs trabalhadores de aplicativos da Web e de aipo são executados como trabalhos iniciados (aplicativo da Web ...
Solicitações de aipo + Eventlet + sem bloqueio
Eu estou usando Pythonrequests no aipoworkers para fazer um grande número de chamadas de API (~ 10 / s) (inclui GET, POST, PUT, DELETE). Cada solicitação leva entre 5 e 10s para ser concluída. Tentei executar trabalhadores de aipo emeventlet ...
Aipo e Django - Nenhum módulo chamado 'django'
Eu uso as instruções descritasaqui [http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html]. Python 2.7 e Aipo 3.1.17. No celery.py eu tenho (no começo): from __future__ import absolute_import import os from celery import ...
Como tornar duas tarefas mutuamente exclusivas no aipo?
Existe uma maneira de não permitir que duas tarefas diferentes sejam executadas simultaneamente no Aipo? Eu estava pensando em definir uma nova fila com nível de simultaneidade = 1 e enviar essas tarefas para essa fila, mas não consegui encontrar ...
Filas com GUID aleatório sendo gerado no servidor RabbitMQ
Filas com um GUID aleatório estão sendo geradas a partir da troca 'celeryresults'. Isso aconteceu quando eu disparei uma tarefa do shell, usando o método delay, mas esqueci de inserir parâmetros da minha função original na lista de argumentos ...
O aipo pode usar um agendador de banco de dados sem o Django?
Eu tenho um pequeno plano de infraestrutura quenãoinclua o Django. Mas, por causa da minha experiência com o Django, eu realmente gosto do aipo. Tudo o que realmente preciso é de Redis + Aipo para fazer meu projeto. Em vez de usar o sistema de ...
Executar o loop while simultaneamente com o servidor Flask
Estou atualizando alguns LEDs usando python. Eu tenho feito isso assim: from LEDs import * myLEDs = LEDs() done = False while not done: myLEDs.iterate() Eu queria usar o Flask para atuar como uma ponte entre um front-end do ReactJS de boa ...
supervisor - como executar vários comandos
Estou gerenciando um trabalhador de aipo que processa a fila via supervisor. Aqui está o meu /etc/supervisor/celery.conf: [program:celery] command = /var/worker/venv/bin/celery worker -A a_report_tasks -Q a_report_process --loglevel=INFO ...