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 […]
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 […]
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 […]
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 […]
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 […]
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 […]
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?
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 […]
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 […]
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 […]