Resultados da pesquisa a pedido "celery"
Como posso logar do meu aplicativo python para splunk, se eu usar o aipo como meu agendador de tarefas?
Eu tenho um script python em execução em um servidor, que deve ser executado uma vez por dia pelo agendador de aipo. Quero enviar meus logs diretamente do script para splunk. Estou tentando usar isso ...
Celery - execute diferentes trabalhadores em um servidor
Tenho 2 tipos de tarefas: Tipo1 - Algumas pequenas tarefas de alta prioridade. Tipo2 - Muitas tarefas pesadas com menor prioridade. Inicialmente eu tinha uma configuração simples com roteamento padrão, nenhuma chave de roteamento foi usada. ...
O que são as tabelas django-aipo (djcelery)?
Quando executo o syncdb, noto muitas tabelas criadas como: djcelery_crontabschedule ... djcelery_taskstate @ django-kombu está fornecendo o transporte, portanto não pode estar relacionado à fila real. Mesmo quando executo tarefas, ainda não vejo ...
Evite save recursivo () ao usar o aipo para atualizar os campos do modelo do Django
Estou substituindo o método save () de um modelo para chamar uma tarefa assíncrona com o Celery. Essa tarefa também salva o modelo e, portanto, acabo com uma situação recursiva em que a tarefa do aipo é chamada repetidamente. Aqui está o ...
Torcido ou Aipo? Qual é o melhor para o meu aplicativo com muitas chamadas SOAP?
Estou escrevendo um aplicativo Python que precisa de simultaneidade e assincronicidade. Tive algumas recomendações para Twisted e Aipo, mas estou tendo problemas para determinar qual é a melhor opção para este aplicativo (não tenho experiência ...
Tarefa de celery que executa mais tarefas
Estou usando o aipo para iniciar uma tarefa principal que inicia várias tarefas secundárias. Eu já tenho as duas tarefas escritas. Existe uma maneira de fazer isso facilmente? O Aipo permite que as tarefas sejam executadas de dentro das ...
Como proibir a serialização de picles no aipo
@Celery usa o pickle como método de serialização para tarefas. Conforme observado noPERGUNTAS FREQUENTE [http://ask.github.com/celery/faq.html#isn-t-using-pickle-a-security-concern], isso representa uma falha de segurança. O Aipo permite que ...
Interoperação com Django / Aipo a partir de Java
@Nossa empresa possui um site baseado em Python e alguns nós de trabalho baseados em Python que se comunicam via Django / Celery e RabbitMQ. Eu tenho um aplicativo baseado em Java que precisa enviar tarefas aos trabalhadores baseados no aipo. ...
Como recuperar mensagens AMQP não reconhecidas de outros canais que não os da minha conexã
Parece que quanto mais tempo eu mantenho meu servidor rabbitmq em execução, mais problemas tenho com mensagens não reconhecidas. Eu adoraria reencaminhá-los. De fato, parece haver um comando amqp para fazer isso, mas ele se aplica apenas ao ...
Excluindo todas as tarefas pendentes no aipo / rabbitmq
Como posso excluir todas as tarefas pendentes sem conhecer otask_id para cada tarefa?