Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando Celery para paralelizar la ejecución de una función de Python que llama a una API de terceros. Esta API impone esperar al menos 3 segundos entre cada llamada. ¿Hay alguna forma de especificar un Mensaje Broker (RabbitMQ o Redis) para respetar este retraso entre cada llamada de los . . . Read more
Estoy empezando a trabajar con Cadena de Tareas en mi proyecto de Django. Tengo la siguiente función: def orquestar_tareas_para_cuenta(id_cuenta): # Obtener la cuenta, establecer el estado en ‘SYNC’ hasta que la cadena esté completa cuenta = Account.objects.get(id=id_cuenta) cuenta.status = “SYNC” cuenta.save() cadena = task1.s(id_cuenta) | task2.s() | task3.s() cadena() # . . . Read more
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
Tengo una tarea de celery que debe ser secuencial, es decir, los mensajes deben ser evaluados uno por uno. Para lograr esto, he utilizado la opción concurrency=1 al iniciar el trabajador. Pero el problema es que las tareas son más lentas de lo que necesito. Probablemente una pregunta tonta, ¿hay . . . Read more
Intento implementar un ejemplo funcional con tareas abortables en Celery (5.1.2) (código a continuación). Cuando llamo al método “abort” en una instancia de AbortableAsyncResult se produce la excepción “RuntimeError: RPC backend missing task request for {task_id}”. ¿Qué estoy haciendo mal? ¿Por qué el fragmento de código no funciona? Intenté buscar . . . Read more