Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Los trabajadores de Celery se ejecutan de esta manera: celery -A backend worker –broker=$REDIS_URL Flower: celery -A backend flower –broker=$REDIS_URL Cuando se ejecuta otro trabajador, Flower lo determina. Pero, ¿cómo? ¿Hay información almacenada sobre los trabajadores en Redis, por ejemplo?
He trabajado con celery algunas veces. Cada vez que intento lanzar una excepción en una tarea periódica de celery, la excepción no se lanza. ¿Me estoy perdiendo algo? Solamente recibo un mensaje pequeño, pero la excepción no explica nada en detalle y tampoco hay una traza de seguimiento. from celery.exceptions . . . Read more
¿Cómo es que Celery no puede encontrar mi servicio de sentinel? Tengo: app.conf.broker_url = “sentinel://192.168.29.11:26379” app.conf.broker_transport_options = {“master_name”: “mymaster”} Y lo que obtengo es: {“message”: “consumer: Cannot connect to sentinel://192.168.29.11:26379: No master found for None. Trying again in 2.00 seconds… (1/100)”, “level”: “ERROR”, “logger”: “celery.worker.consumer.consumer”} ¿Por qué aparece “No master . . . Read more
Estoy buscando ejecutar algún código cuando un trabajador de celery se inicia. No cuando, digamos, una tarea se importa para ser utilizada desde una aplicación de tipo cliente. “`python celery_app = Celery(<strong>nombre</strong>) <h1>Quiero crear el motor solo si este archivo es utilizado por un trabajador</h1> engine = create<em>engine(str(POSTGRES</em>URL)) “`
Tengo un script de Python que debe ser una tarea de Celery. Mi aplicación necesita varios trabajadores concurrentes (del mismo script) porque cada trabajador necesita procesar los mensajes secuencialmente. No puedo usar el parámetro concurrency = n porque entonces los mensajes no se procesan secuencialmente, lo cual es una especie . . . Read more