Perguntas marcadas [celery]

0 votos
0 respostas
Não é possível transmitir mensagem usando aipo
Estou tentando usar a compilação do aipo para dar suporte ao roteamento de broadcast usando o Broadcast e usando o rabbitmq como intermediário....
perguntei há 8 meses
0 votos
1 respostas
Remover itens do celery_beat não os remove do agendamento do banco de dados
Estou usando o django-celery-beat em um aplicativo django (isso armazena o planejamento no banco de dados em vez de um arquivo local). Eu config...
perguntei há 8 meses
0 votos
0 respostas
aipo: por que é útil quando eu apago o item “search localdomain” em /etc/resolv.conf
quando eu uso "celery -A tasks worker -l info", o worker node ocorre a seguir: [2019-04-26 20:27:00,290: ERROR/MainProcess] consumer: Cannot...
perguntei há 8 meses
0 votos
0 respostas
Iniciando trabalhos do Celery do CouchDB _changes
O CouchDB pode produzir "notificações" por sondagem em um ponto de extremidade _changes . Eu gostaria de ter o Celery puxando os argumentos ta...
perguntei há 8 meses
0 votos
0 respostas
Não é possível executar o Django Aipo após seguir a documentação
Estou tentando implementar o aipo em um projeto atual do django 2 em andamento. Estou usando django 2.13 e aipo 4.3. Aqui o código no init .py...
perguntei há 8 meses
0 votos
0 respostas
Adicionando Filas ao Rabbitmq e Trabalhadores às Filas no Aipo
Tentando executar cerca de 66 scripts python que executam algumas tarefas de manipulação de dados. Três scripts levam muito tempo para serem exe...
perguntei há 8 meses
0 votos
1 respostas
Por que o Aipo tem comportamentos diferentes em duas maneiras de iniciar o trabalhador?
Eu adicionei um trabalhador de aipo no pacote app: proj ├── app │   ├── worker.py │   └── server.py └── db ├── db.sql ├── check_db_hea...
0 votos
0 respostas
Flask - jsonify Resultados da tarefa de aipo
Eu tenho uma longa tarefa de aipo: @celery.task(queue='cache') def cache_user_tracks(user_id): # generator - yields external api calls...
perguntei há 8 meses
0 votos
1 respostas
aipo: imprime o status de cada tarefa dentro de um grupo iniciado com apply_async
Estou tentando imprimir o status de 4 tarefas remotas, obtendo informações de cada AsyncResult dentro do grupo. Até agora eu posso imprimir o...
perguntei há 8 meses
0 votos
0 respostas
Aipo: O módulo não foi encontrado
Estou usando o Open SEmantic Search (OSS) e gostaria de monitorar seus processos usando a ferramenta Flor . Os trabalhadores que o Aipo precis...
perguntei há 8 meses
0 votos
1 respostas
Como posso alterar o nome de uma tarefa que o Celery envia para um back-end?
Eu construí um sistema de fila usando o Celery que aceita solicitações da web e executa algumas tarefas para atuar nessas solicitações. Estou us...
perguntei há 8 meses
0 votos
0 respostas
Ramificação do uso de fila única para cada tarefa com back-end de redis
Eu percebi que o Redis backend para aipo armazena cada solicitação de tarefa em uma lista em uma fila. Isso faz com que a exclusão (abortar) de...
perguntei há 8 meses
0 votos
0 respostas
Operadores de fluxo de ar on_kill e timeout de aipo
Gostaríamos de definir um tempo limite de aipo para 2 horas com a opção visibility_timeout. nosso dag envia os trabalhos para uma API externa a...
perguntei há 8 meses
0 votos
1 respostas
Aipo Aceitando mais tarefas do que a concorrência do trabalhador
Estou executando algumas tarefas de longa duração na fila dedicada. Portanto, não há tempo curto executando tarefas. Atualmente, quando inicio m...
0 votos
1 respostas
Não é possível importar o nome App ao usar o aipo no frasco
Estou escrevendo um aplicativo Flask simples que usa o Celery para executar uma tarefa em segundo plano, mas quando tento executar o aplicativo...
perguntei há 9 meses
0 votos
2 respostas
Falha ao iniciar o processo de trabalho Tarefa de aipo com Django em debug = False (produção)
Esta é uma tarefa de Aipo para enviar e-mail, o engraçado é que tudo funciona corretamente no modo DEBUG = True, mas não funciona na produçãoDEB...
perguntei há 9 meses
0 votos
1 respostas
Resultados da consulta do backend de resultados do aipo MYSQL
Qual é a maneira mais simples de consultar todos os resultados de um backend de resultado no aipo? Eu estou usando um datastore MySQL como meu b...
perguntei há 9 meses
2 votos
2 respostas
Não é possível ver as mensagens de saída das tarefas executadas na combinação aipo-rabbitMQ
Estou experimentando as combinações aipo e rabbitMQ para agendamento de tarefas assíncronas, abaixo está o programa de amostra que testei no Pyc...
perguntei há 9 meses
0 votos
1 respostas
Como pode um trabalhador (thread) reservar espaço em disco e comunicar a reserva com outros trabalhadores
Estou tentando configurar uma classe de autoescala que verificará o recurso de disco para ver se um trabalhador pode ser executado com segurança...
perguntei há 9 meses
0 votos
0 respostas
converter rrule para o valor do cron em python para suportar batida de aipo
Oi eu estou tentando implementar a batida de aipo para agendar serviços, mas a nossa interface é projetada para enviar dados em formato rrule na...
perguntei há 9 meses
0 votos
1 respostas
Não é possível iniciar os trabalhadores de aipo (aplicação de balão)
Estou experimentando aipo com o Python Flask. celery_example.py from __future__ import absolute_import, unicode_literals from flask import...
perguntei há 9 meses
0 votos
0 respostas
É possível chamar uma tarefa em uma cadeia com a opção * max_retries * sendo parametrizada?
Eu preciso executar a mesma tarefa em diferentes cadeias com comportamento diferente. Para a cadeia A, quero limitar o número de reinicializaçõe...
perguntei há 9 meses
1 votos
1 respostas
Tarefa de aipo chamando a si mesma depois que a tarefa é bem-sucedida sem aipo
Eu quero ligar para a minha tarefa de aipo, ocasionalmente, como a cada 30 minutos após a tarefa atual feita, mas às vezes a tarefa demora mais...
perguntei há 9 meses
1 votos
0 respostas
Qual é o significado da variável CELERY_TIMEZONE no arquivo settings.py de um projeto Django?
Eu sei que USE_TZ=True salva todos os datetime objetos em UTC no banco de dados. Nesse caso, quando uma tarefa é programada para ser executada e...
perguntei há 10 meses
0 votos
1 respostas
Exceção não tratada no aipo congela trabalhadores
Estou usando aipo no docker por meio de um back-end de redis. Eu tenho recipiente de aipo-batida container de trabalho de aipo container...
perguntei há 9 meses