Tengo algunos códigos keras que funcionan de forma sincrónica para predecir una entrada determinada, incluso he realizado modificaciones para que pueda trabajar con subprocesos múltiples estándar (utilizando lockings en una clase separada de esto) sin embargo, cuando se ejecuta a través de apio asíncrono (incluso con un trabajador y una tarea) Me sale un error […]
Estoy pasando por el tutorial de apio. Ellos están usando Python2 y estoy tratando de implementar lo mismo usando python3. Tengo 2 archivos: celery_proj.py : from celery import Celery app = Celery( ‘proj’, broker=’amqp://’, backend=’amqp://’, include=[‘proj.tasks’]) app.conf.update(Celery_TAST_RESULT_EXPIRES=3600,) if __name__ == ‘__main__’: app.start() y tareas.py : from celery_proj import app @app.task def add(x, y): return x […]
Python 3.x, Apio 4.x … Tengo una tarea basada en la clase. myproj/celery.py from celery import Celery # django settings stuff… app = Celery(‘myproj’) app.autodiscover_tasks() app1/tasks.py import celery class EmailTask(celery.Task): def run(self, *args, **kwargs): self.do_something() Si lo hago: $ celery worker -A myproj -l info [tasks] . app2.tasks.debug_task . app2.tasks.test Por lo tanto, los decoradores […]
Actualmente estoy experimentando con futuras tareas en apio utilizando la función ETA y un agente redis. Uno de los problemas conocidos con el uso de un agente redis tiene que ver con el tiempo de espera de visibilidad : Si una tarea no se reconoce dentro del Tiempo de espera de visibilidad, la tarea se […]
Por lo que he visto, el estado de la tarea depende completamente del valor establecido para CELERY_TASK_RESULT_EXPIRES: si verifico el estado de la tarea dentro de este intervalo después de que la tarea haya terminado de ejecutarse, el estado regresó: AsyncResult(task_id).state es correcto. Si no, el estado no se actualizará y permanecerá para siempre PENDIENTE. […]
Estoy creando un marco para ejecutar tareas sobre el marco de apio. Me gustaría ver la lista de tareas ejecutadas recientemente (para los últimos 2 a 7 días). Al buscar en la API puedo encontrar el objeto app.backend , pero no puedo averiguar cómo realizar una consulta para recuperar tareas. Por ejemplo, puedo usar backends […]
Pregunta Después de ejecutar tareas a través del progtwigdor de tareas periódicas de apio, batir, ¿por qué tengo tantas colas sin consumir en RabbitMQ? Preparar Aplicación web Django ejecutándose en Heroku Tareas progtwigdas a través del apio. Las tareas se ejecutan a través de apio trabajador El intermediario de mensajes es RabbitMQ de ClouldAMQP Procfile […]
Por lo general, envío correos electrónicos transaccionales en respuesta a ciertas acciones en mi sitio web, algunas de las cuales demoro el envío por un par de horas. La función que realmente pone en cola el correo electrónico es una función de tarea de apio llamada con .delay() que eventualmente realiza una llamada de API […]
Tengo una aplicación de matraz basada en Python en la que estoy utilizando la cola de tareas de Celery para manejar un conjunto de tareas de correo electrónico. Me gustaría que la tarea de Celery pueda consultar una base de datos sqlite que he vinculado a toda la aplicación para extraer y usar ciertos datos, […]
Tenemos una configuración de aplicación en heroku, que utiliza apio para ejecutar trabajos en segundo plano. La aplicación de apio utiliza RabbitMQ como agente. Usamos el complemento RabbitMQ Bigwig de heroku como agente de mensajes AMQP. Este complemento especifica dos direcciones URL separadas, una optimizada para el productor y otra optimizada para el consumidor. Además, […]