Articles of django apio

Fugas de memoria Django 1.6 y Celery 3.0

Después de actualizar Django a 1.6, mi trabajador de apio está consumiendo RAM. Parece que la memoria asignada para los trabajadores no se libera y crece después de cada tarea. Ajustes relacionados: # DB: DATABASES = { ‘default’: { ‘ENGINE’: ‘django.db.backends.postgresql_psycopg2’, ‘NAME’: ‘somedb’, ‘USER’: ”, ‘PASSWORD’: ”, ‘HOST’: ‘localhost’, ‘PORT’: ”, } } # CELERY […]

Apio auto recarga en CUALQUIER cambio.

Podría hacer que el apio se vuelva a cargar automáticamente cuando haya cambios en los módulos en CELERY_IMPORTS en settings.py . Intenté dar módulos de la madre para detectar cambios incluso en módulos secundarios, pero no detectó cambios en los módulos secundarios. Eso me hace entender que la detección no se hace recursivamente por el […]

Python Celery versus Threading Library para ejecutar solicitudes asíncronas

Estoy ejecutando un método de python que analiza una gran cantidad de datos. Dado que requiere mucho tiempo, me gustaría ejecutarlo de forma asíncrona en un subproceso separado para que el usuario todavía pueda acceder al sitio web / UI. ¿Terminan los subprocesos que usan el módulo “desde subprocesos de subprocesamiento de subprocesos” si un […]

Crear tareas de apio y luego ejecutar de forma síncrona

Mi aplicación reúne un montón de números de teléfono en una página. Una vez que el usuario presiona el botón Enviar, creo una tarea de apio para llamar a cada número y dar un mensaje de recordatorio, luego redirigirlos a una página donde pueden ver las actualizaciones en vivo sobre la llamada. Estoy utilizando sockets […]

Agregue n tareas a la cola de apio y espere los resultados

Yo agregaría múltiples tareas a la cola de apio y esperaría los resultados. Tengo varias ideas de cómo lograría esto utilizando algún tipo de almacenamiento compartido (memcached, redis, db, etc.), sin embargo, pensé que es algo que Celery puede manejar automáticamente pero no puedo encontrar ningún recurso en línea. Ejemplo de código def do_tasks(b): for […]

¿Cómo monitorear eventos de trabajadores en una aplicación Celery-Django?

De acuerdo con el tutorial de apio con respecto al monitoreo en tiempo real de los trabajadores del apio , también se puede capturar programáticamente los eventos producidos por los trabajadores y actuar en consecuencia. Mi pregunta es ¿cómo puedo integrar un monitor como el de este ejemplo, en una aplicación Celery-Django? EDITAR: El ejemplo […]

¿Cómo puedo ejecutar una tarea periódica de apio desde el shell manualmente?

Estoy usando apio y django-apio. He definido una tarea periódica que me gustaría probar. ¿Es posible ejecutar la tarea periódica desde el shell manualmente para que vea la salida de la consola?

Revocar la tarea de apio antes de ejecutar utilizando la base de datos django

Estoy usando la base de datos Django en lugar de RabbitMQ por razones de concurrencia. Pero no puedo resolver el problema de revocar una tarea antes de que se ejecute. Encontré algunas respuestas sobre este asunto, pero no parecen estar completas o no puedo obtener suficiente ayuda. primera respuesta segunda respuesta ¿Cómo puedo extender la […]

Notificar a apio tarea de cierre trabajador

Estoy usando apio 2.4.1 con python 2.6, el servidor de rabbitmq y django. Me gustaría que mi tarea fuera capaz de limpiar correctamente si el trabajador se cierra. Por lo que sé, no se puede suministrar un destructor de tareas, así que intenté conectarme a la señal worker_shutdown . Nota: AbortableTask solo funciona con el […]

AsyncResult (task_id) devuelve el estado “PENDIENTE” incluso después de que se inició la tarea

En el proyecto, trato de sondear task.state de una tarea de larga ejecución y actualizar su estado de ejecución. Funcionó en el desarrollo, pero no funcionará cuando muevo el proyecto al servidor de producción. Seguí recibiendo “PENDIENTES”, incluso cuando veo que la tarea comenzó en la flor. Sin embargo, todavía puedo obtener los resultados actualizados […]