Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy enfrentando un problema al depurar tareas de Celery que se ejecutan en cadena. Si configuro la variable CELERYALWAYSEAGER, las tareas se ejecutarán en el mismo proceso una por una y puedo depurar. Sin embargo, al configurar esta variable, se plantea otro problema, tengo un problema al crear un socket. . . . Read more
Estoy encolando trabajos en AWS SQS desde un entorno local y puedo consumirlos correctamente desde el mismo entorno local, pero cuando intento empacar el trabajador en una instancia de Docker y ejecutarlo, no recogerá los trabajos. Hasta donde puedo ver, está accediendo a las colas correctas, no hay errores, pero . . . Read more
Soy nuevo en esto de celery, rabbitmq y django. Estoy muy confundido con este error, no sé cómo rastrearlo y leer el registro de errores. Usé: celery 4.1.0 rabbitmq 3.7.15 Erlang/OTP 22 [erts-10.4] [source] [64-bit] [smp:2:2] [ds:2:2:10] [async-threads:64] Esta es una imagen de cuando ejecuté celery -A tasks worker: aquí . . . Read more
Contexto Utilicé este tutorial para crear un límite de velocidad para mis tareas de celery que funciona en múltiples colas/empleados. https://alievmagomed.com/celery-throttling-setting-rate-limit-for-queues/ Utiliza el concepto de un cubo de tokens. Una función crea tokens en una cola en un intervalo especificado. La tarea actual no puede ejecutarse si no hay un . . . Read more
Estoy en proceso de actualizar a celery 5.x para un proyecto de Django. Dado que ya no hay un decorador @scheduled_task, cambié todos esos por @shared_task y escribí código para crear instancias de CrontabSchedule y asociar instancias de PeriodicTask con ellas para cada tarea que deba ejecutarse según una programación. . . . Read more