Así que tengo una aplicación Django que ocasionalmente envía una tarea a Celery para su ejecución asíncrona. Descubrí que mientras trabajo en mi código en desarrollo, el servidor de desarrollo de Django sabe cómo detectar automáticamente cuándo ha cambiado el código y luego reiniciar el servidor para que pueda ver mis cambios. Sin embargo, la […]
Estoy usando Celery y MongoEngine como parte de mi aplicación Django con. Recibo esta advertencia, cuando un apio @shared_task accede a la base de datos mongodb a través de las clases del modelo mongoengine: UserWarning: MongoClient opened before fork. Create MongoClient with connect=False,or create client after forking. See PyMongo’s documentation for details: http://api.mongodb.org/python/current/faq.html#using-pymongo-with-multiprocessing Claramente, tiene […]
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 […]