celery

Estoy tratando de llegar a una metodología de prueba para nuestro proyecto django-apio . He leído las notas en la documentac ... tenemos que usar un corredor personalizado? En general, cualquier sugerencia o consejo para probar con apio sería muy útil.

La documentación de Apio menciona probar Apio dentro de Django pero no explica cómo probar una tarea de Apio si no está usando Django. ¿Cómo haces esto?

He estado leyendo el documento y buscando, pero parece que no puedo encontrar una respuesta directa: ¿Se puede cancelar un ... cancelará las tareas en cola o si matará un proceso en ejecución en un worker. Gracias por cualquier luz que pueda arrojar!

¿Cómo puedo obtener el valor task_id para una tarea desde dentro de la tarea? Aquí está mi código: from celery.decorators ... pués de que la tarea se completa, y puede o no existir. En el ejemplo anterior, ¿cómo obtendría el valor de current_task_id?

Actualmente estoy trabajando en un proyecto python que requiere implementar algunos trabajos en segundo plano (principalmente ... , pero parece que carece de algunas características útiles (por ejemplo, revocación de tareas, recarga automática de código)

Tengo problemas para entender el propósito de las 'colas de tareas distribuidas'. Por ejemplo, la biblioteca de apio de pytho ... vez una explicación de alto nivel de cómo funcionan las colas de tareas / crontabs en general también sería bueno. Gracias.

Estoy trabajando en un proyecto que escanea la bandeja de entrada de gmail del usuario y proporciona un informe. Lo he desple ... nfirmación (cambios: eliminé una imagen de medios de la carpeta de medios) muestra el mismo error nuevo. Gracias de antemano

Me pregunto cómo configurar un sistema de registro más específico. Todas mis tareas usan logger = logging.getLogger(__name__ ... de registro relacionados con celeryd a celeryd.registro pero no hay rastro de los mensajes de registro creados en mis tareas.

¿Cómo se comprueba si una tarea se está ejecutando en apio (específicamente, estoy usando apio-django)? He leído la documen ... cuta ese servicio se está ejecutando, y si no, para (re)iniciarlo. Estoy usando las versiones estables actuales - 2.4, creo.

Tengo una tarea de apio intensiva en CPU. Me gustaría usar toda la potencia de procesamiento (núcleos) en muchas instancias E ... itir que esta tarea se divida utilizando toda la potencia de la CPU informática en todas las máquinas disponibles en la nube?

Uso apio para actualizar los canales RSS en mi sitio de agregación de noticias. Utilizo una tarea @para cada feed, y las cosa ... Tal vez hay una forma más sofisticada/robusta de lograr el mismo resultado utilizando algún mecanismo de apio que me perdí ?

Desde mi punto de vista, Apio es una cola de tareas distribuidas, lo que significa que lo único que debe hacer es enviar tare ... tarea cuando se recibe un mensaje. Esto logra exactamente lo que ofrece el apio, así que ¿por qué necesita apio en absoluto?

Estoy usando celerybeat para iniciar una tarea primaria que inicia una serie de tareas secundarias. Ya tengo ambas tareas esc ... #do some stuff compute se llama desde celerybeat, pero causa un IOError cuando intenta ejecutar apply_async. Alguna idea?

Quiero usar Amazon SQScomo broker respaldado por Apio. Está la implementación de transporte SQS para Kombu , de la que dep ... o, por lo que no puedo encontrar cómo configurar SQS en Celery. ¿Hay alguien que haya tenido éxito en configurar SQS en Apio?

Celery usa por defecto pickle como su método de serialización para las tareas. Como se indica en FAQ , esto representa un a ... ibiendo objetos encurtidos maliciosos. ¿Cómo puedo evitar que los hilos de trabajo ejecuten tareas serializadas con pickle?

En mi archivo de configuración /etc/defaults/celeryd, he establecido: CELERYD_NODES="agent1 agent2 agent3 agent4 agent5 age ... ers + concurrencia + autoscaling es excesiva y me gustaría obtener una mejor comprensión de lo que hacen estas tres opciones.

Tengo un sitio de Django donde ocurre un raspado cuando un usuario lo solicita, y mi código inicia un script independiente Sc ... el error ReactorNotRestartable. Cualquiera puede compartir algún consejo con las arañas corriendo dentro del marco de Apio?

Almaceno el task_id de un celery.result.AsyncResult en una base de datos y lo relaciono con el elemento al que afecta la tare ... ués de recuperar el task_id de la base de datos, ¿cómo puedo recuperar información sobre el estado/resultado/etc de la tarea?

El apio no parece estar manejando las excepciones correctamente. Si tengo tarea: def errorTest(): raise Exception() ... er para excepciones de captura en Apio? / La versión de apio es 3.0.13, broker es RabbitMQ ejecutándose en mi máquina local

En mi proyecto Django estoy usando Apio. Cambié un comando de crontab para ser una tarea periódica y funciona bien, pero solo ... el comando para actualizar el índice de la documentación de Haystack, pero no estoy seguro de cómo llamarlo desde una tarea.