Eu sou novo em corretores de mensagens como o RabbitMQ, que podemos usar para criar tarefas / filas de mensagens para um sistema de agendamento como o Aipo . Agora, aqui está a pergunta: Posso criar uma tabela no PostgreSQL que pode ser anexada com novas tarefas e consumida pelo programa do...
Como posso excluir todas as tarefas pendentes sem saber o task_idpara cada
Como recuperar uma lista de tarefas em uma fila que ainda precisa ser
A documentação do Celery menciona o teste do Celery dentro do Django, mas não explica como testar uma tarefa do Celery se você não estiver usando o Django. Como você faz
Fechado . Esta questão precisa ser mais focada . Atualmente não está aceitando respostas. Quer melhorar esta questão? Atualize a pergunta para que ela se concentre em apenas um problema, editando esta postagem . Fechado há 3 anos . Melhore esta...
Estou tentando executar um exemplo da documentação do Celery. Eu corro: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." %...
Estou tendo problemas para entender o propósito das 'filas de tarefas distribuídas'. Por exemplo, a biblioteca de aipo do python . Eu sei que no aipo, o framework Python, você pode definir janelas temporizadas para que as funções sejam executadas. No entanto, isso também pode ser feito facilmente...
Tenho lido o documento e pesquisado, mas não consigo encontrar uma resposta direta: Você pode cancelar uma tarefa já em execução? (como na tarefa foi iniciada, demora um pouco e precisa ser cancelada no meio) Eu encontrei isso no documento no FAQ do Celery >>> result =...
Como verificar se uma tarefa está sendo executada no aipo (especificamente, estou usando o celery-django)? Eu li a documentação e pesquisei, mas não consigo ver uma chamada como: my_example_task.state() == RUNNING Meu caso de uso é que tenho um serviço externo (java) para transcodificação....
Suponha que eu tenho um modelo Event. Quero enviar uma notificação (email, push, qualquer que seja) a todos os usuários convidados depois que o evento terminar. Algo ao longo das linhas de: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited =...