Resultados de la búsqueda a petición "celery"
apio 'Worker-n' pid: xxxx salió con 'exitcode 1' cuando importo hmmlearn
En mi archivo task.py, cuando importo hmmlearn, from hmmlearn import hmmy comienzo mis trabajadores de apio, me sale el siguiente error [2017-06-14 09:18:27,638: INFO/MainProcess] Received ...
Actualización de un índice de búsqueda de Haystack con Django + Celery
En mi proyecto Django estoy usando Celery. Cambié un comando de crontab para que sea una tarea periódica y funciona bien, pero solo está llamando a un método en un modelo. ¿Es posible actualizar mi índice Haystack desde una tarea ...
Prioridad de la tarea de apio
Quiero gestionar tareas usando Celery. Quiero tener una sola cola de tareas (con concurrencia 1) y poder empujar tareas a la cola con diferentes prioridades de modo que las tareas de mayor prioridad se adelanten a las demás. Estoy agregando tres ...
Recarga automática de apio en CUALQUIER cambio
Podría hacer que el apio se vuelva a cargar automáticamente cuando haya cambios en los módulos enCELERY_IMPORTS ensettings.py. Traté de dar módulos madre para detectar cambios incluso en los módulos secundarios, pero no detectó cambios en los ...
Python Celery: cómo llamar a las tareas de apio dentro de otra tarea
Estoy llamando a una tarea dentro de una tarea en Django-Celery Aquí están mis tareas. @shared_task def post_notification(data,url): url = "http://posttestserver.com/data/?dir=praful" # when in production, remove this line. headers = ...
Ejecutar una araña Scrapy en una tarea de apio
Esto ya no funciona [https://stackoverflow.com/a/11657239/560659], la API de scrapy ha cambiado. Ahora la documentación presenta una forma de "Ejecute Scrapy desde un ...
Intermediario en memoria para pruebas unitarias de apio
Tengo una API REST escrita en Django, con un punto final que pone en cola una tarea de apio cuando se publica en ella. La respuesta contiene la identificación de la tarea que me gustaría usar para probar que la tarea se creó y obtener ...
Trabajo de multiprocesamiento de Python a tarea de apio pero AttributeError
Hice una función multiprocesada como esta, import multiprocessing import pandas as pd import numpy as np def _apply_df(args): df, func, kwargs = args return df.apply(func, **kwargs) def apply_by_multiprocessing(df, func, **kwargs): workers = ...
manejar la señal `post_save` en apio
Tengo una tarea de ejecución bastante larga que debe ejecutarse después de insertar o actualizar un modelo específico. Decidi usarpost_save señal en lugar de anularsave Método para reducir el acoplamiento. Como las señales de Django no son ...
¿Puedo usar Tornado + Celery + RabbitMQ + Redis?
Para la transmisión de datos en tiempo real en la web, planeo usar Redis como mi capa de datos de caché, donde los datos son instantáneos. Celery es el gestor de colas y RabbitMQ es el intermediario que hace cola desde Redis y llega a la ...