Apio es un marco de trabajo de cola de tareas distribuido para Python, que se utiliza para la ejecución asíncrona y paralela.
Soy nuevo en los corredores de mensajes como RabbitMQ que podemos usar para crear tareas / colas de mensajes para un sistema de programación como Celery . Ahora, aquí está la pregunta: Puedo crear una tabla en PostgreSQL que se puede agregar con nuevas tareas y consumir por el programa de...
¿Cómo puedo eliminar todas las tareas pendientes sin conocer el task_idde cada
¿Cómo puedo recuperar una lista de tareas en una cola que aún no se han
La documentación de Celery menciona probar Celery dentro de Django, pero no explica cómo probar una tarea de Celery si no está usando Django. ¿Cómo haces
Cerrado . Esta pregunta debe estar más enfocada . Actualmente no acepta respuestas. ¿Quieres mejorar esta pregunta? Actualice la pregunta para que se centre en un solo problema editando esta publicación . Cerrado hace 3 años . Mejora esta pregunta...
He estado leyendo el documento y buscando, pero parece que no puedo encontrar una respuesta directa: ¿Puede cancelar una tarea que ya se está ejecutando? (ya que la tarea ha comenzado, lleva un tiempo y la mitad debe cancelarse) Encontré esto en el documento en Preguntas frecuentes sobre...
Estoy tratando de ejecutar un ejemplo de la documentación de Celery. Corro: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to...
¿Cómo se comprueba si una tarea se está ejecutando en apio (específicamente, estoy usando celery-django)? Leí la documentación y busqué en Google, pero no puedo ver una llamada como: my_example_task.state() == RUNNING Mi caso de uso es que tengo un servicio externo (java) para la...
Tengo problemas para comprender el propósito de las 'colas de tareas distribuidas'. Por ejemplo, la biblioteca de apio de Python . Sé que en apio, el marco de Python, puede configurar ventanas temporizadas para que las funciones se ejecuten. Sin embargo, eso también se puede hacer fácilmente en...
Estoy tratando de encontrar una metodología de prueba para nuestro proyecto django-celery . He leído las notas en la documentación , pero no me dio una buena idea de qué hacer realmente. No me preocupa probar las tareas en los demonios reales, solo la funcionalidad de mi código. Principalmente...
Tengo una tarea de apio intensiva en la CPU. Me gustaría usar toda la potencia de procesamiento (núcleos) en muchas instancias EC2 para hacer este trabajo más rápido (una tarea distribuida en paralelo de apio con multiprocesamiento, creo ) . Los términos, subprocesamiento , multiprocesamiento ,...
Me acabo de enterar de la opción de configuración CELERYD_PREFETCH_MULTIPLIER( documentos ). El valor predeterminado es 4, pero (creo) quiero que la captación previa esté desactivada o lo más baja posible. Lo configuré en 1 ahora, que está lo suficientemente cerca de lo que estoy buscando, pero...
Supongamos que tengo un modelo Event. Quiero enviar una notificación (correo electrónico, push, lo que sea) a todos los usuarios invitados una vez que haya transcurrido el evento. Algo en la línea de: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...)...