Resultados de la búsqueda a petición "celery"
¿Cómo puedo recuperar mensajes AMQP no reconocidos de otros canales que no sean los de mi conexión?
Parece que cuanto más tiempo mantengo mi servidor rabbitmq en funcionamiento, más problemas tengo con los mensajes no reconocidos. Me encantaría solicitarlos. De hecho, parece haber un comando amqp para hacer esto, pero solo se aplica al canal ...
Eliminar todas las tareas pendientes en apio / rabbitmq
¿Cómo puedo eliminar todas las tareas pendientes sin conocer latask_id para cada tarea?
¿Cómo hacer que una tarea de apio falle desde dentro de la tarea?
Bajo ciertas condiciones, quiero hacer que una tarea de apio falle desde dentro de esa tarea. Intenté lo siguiente: from celery.task import task from celery import states @task() def run_simulation(): if ...
Celery: programe tareas periódicas a partir de una hora específica
Cuál es la mejor manera de programar una tarea periódica que comience en una fecha y hora específica? (No estoy usando cron para esto teniendo en cuenta que tengo la necesidad de programar alrededor de un centenar de rsyncs remotos, donde ...
Creando colas dinámicamente con Celery
Estoy escribiendo un administrador de listas de correo con Django, Celery y RabbitMQ. Cuando llega un mensaje, se ejecuta una tarea para cada destinatario. Todas las tareas van a una sola cola, y uno o más trabajadores consumen tareas de la cola, ...
Ejemplos de Django y apio: tareas periódicas
He estado luchando contra la documentación de Django / Celery por un tiempo y necesito ayuda. Me gustaría poder ejecutar Tareas periódicas con django-celery. He visto en Internet (y la documentación) varios formatos y esquemas diferentes sobre ...
Detectar si Apio está disponible / En ejecución
Estoy usandoApi [http://celeryproject.org/] para gestionar tareas asincrónicas. Ocasionalmente, sin embargo, el proceso de apio se cae, lo que hace que ninguna de las tareas se ejecute. Me gustaría poder verificar el estado del apio y asegurarme ...
Procesos de trabajo para cada tarea en Celery
Actualmente utilizo una biblioteca de extensiones C para Python, pero parece tener pérdidas de memoria. Tareas que se ejecutan en miceleryd hacer algo usando esta biblioteca de extensiones C, yceleryd come mucha memoria aproximadamente una hora ...
¿Cómo verificar el estado de la tarea en Celery?
¿Cómo se comprueba si una tarea se está ejecutando en apio (específicamente, estoy usando celery-django)? He leído la documentación y busqué en Google, pero no puedo ver una llamada como: my_example_task.state() == RUNNINGMi caso de uso es ...
Trabajar alrededor del apio siendo un único punto de falla
Estoy buscando una solución recomendada para evitar que celerybeat sea un único punto de falla para la implementación de apio / rabbitmq. No encontré nada que tuviera sentido hasta ahora, al buscar en la web. En mi caso, una vez al día, el ...