Resultados da pesquisa a pedido "celery"
Corretor na memória para testes de unidade de aipo
Eu tenho uma API REST escrita no Django, com um ponto de extremidade que enfileira uma tarefa de aipo ao postar nela. A resposta contém o ID da tarefa que eu gostaria de usar para testar se a tarefa foi criada e obter o resultado. Então, eu ...
Tarefa de multiprocessamento Python para tarefa de aipo, mas AttributeError
Eu criei uma função multiprocessada como esta, import multiprocessing import pandas as pd import numpy as np def _apply_df(args): df, func, kwargs = args return df.apply(func, **kwargs) def apply_by_multiprocessing(df, func, **kwargs): workers = ...
Problemas de tarefas agendadas do aipo com o Fuso Horário
Estou usando o aipo em um servidor em que a hora do servidor é agoraBSTe, de repente, minhas tarefas agendadas estão em execuçãouma hora antes!Anteriormente, o horário do servidor era Europa / Londres, que era GMT, mas agora, devido ao horário de ...
Fluxo de ar + aipo ou dask. Para que quando?
Eu li na documentação oficial do AirflowOs seguintes [https://airflow.apache.org/configuration.html#scaling-out-with-celery]: [/imgs/BeHip.png] o que isso significa, exatamente? O que os autores querem dizer com escalar? Isso é,quandoé ...
Posso usar Tornado + Aipo + RabbitMQ + Redis?
Para o streaming em tempo real de dados na Web, planejo usar o Redis como minha camada de dados de cache, onde os dados são instantâneos. O aipo é o gerenciador de filas e o RabbitMQ é o broker que enfileira no Redis e chega à camada Tornado. ...
Adicione, modifique, remova celery.schedules em tempo de execução
existe uma maneira de adicionar, modificar, remover aipo.schedules em tempo de execução. Eu preciso de algo que leia uma tabela db periodicamente para saber a lista de agendas. Documento diz que alguém pode ...
Aipo: maneira limpa de revogar toda a cadeia de dentro de uma tarefa
Minha pergunta provavelmente é bem básica, mas ainda não consigo obter uma solução no documento oficial. Eu defini uma cadeia de aipo dentro do meu aplicativo Django, executando um conjunto de tarefas dependentes de eanch other: chain( ...
Biblioteca de aipo do Python versus Threading para executar solicitações assíncronas [fechado]
Estou executando um método python que analisa muitos dados. Como é demorado, eu gostaria de executá-lo de forma assíncrona em um thread separado para que o usuário ainda possa acessar o site / interface do usuário. Os encadeamentos que usam o ...
Aipo: preso em tempos limite repetidamente infinitos (Tempo limite excedido, aguardando a mensagem UP)
Eu defini algumas tarefas com um limite de tempo de 1200: @celery.task(time_limit=1200) def create_ne_list(text): c = Client() return c.create_ne_list(text)Eu também estou usando oworker_process_init sinal para fazer alguma inicialização, sempre ...
A lista agendada do aipo retorna Nenhuma
Sou relativamente novo no Celery e tenho tentado configurar um script simples para agendar e cancelar o agendamento de tarefas. No entanto, sinto que estou enfrentando um problema estranho. Eu tenho a seguinte configuração from celery import ...