Resultados de la búsqueda a petición "celery"
¿Cómo ejecutar tareas en Celery usando datetime de MySQL?
Las noticias se almacenan en la base de datos MySQL condatetime de publicación. En cualquier momento, el usuario puede agregar un nuevo en la tabla con publicación de fecha de retraso. ¿Cómo usar Celery para escuchar la tabla de la base de ...
El uso del grupo de multiprocesamiento de la tarea de apio genera una excepción
PARA AQUELLOS QUE LEAN ESTO: He decidido usar RQ en su lugar, lo que no falla al ejecutar código que usa el módulo de multiprocesamiento. Te sugiero que uses eso. Estoy tratando de usar un grupo de multiprocesamiento desde una tarea de ...
¿Cómo le digo al trabajador de apio que deje de aceptar tareas? ¿Cómo puedo verificar si se están ejecutando las tareas de los trabajadores de apio?
El escenario: Sistema que se ejecuta en un servidor que consta de una aplicación web Python / Flask y tareas en segundo plano con CeleryTanto la aplicación web como los trabajadores de apio se ejecutan como trabajos iniciales (aplicación web ...
Apio + Eventlet + solicitudes sin bloqueo
Estoy usando Pythonrequests en apioworkers para realizar un gran número de llamadas API (~ 10 / seg) (incluye GET, POST, PUT, DELETE). Cada solicitud tarda entre 5 y 10 segundos en completarse. Traté de ejecutar trabajadores de apio eneventlet ...
Apio y Django: ningún módulo llamado 'django'
Yo uso las instrucciones descritasaquí [http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html]. Python 2.7 y apio 3.1.17. En celery.py tengo (en principio): from __future__ import absolute_import import os from celery ...
Colas con GUID aleatorio generado en el servidor RabbitMQ
Las colas con un GUID aleatorio se generan a partir del intercambio 'resultados de apio'. Esto sucedió cuando activé una tarea desde el shell, usando el método de retraso, pero olvidé ingresar los parámetros de mi función original en la lista de ...
Flujo de aire + apio o dask. ¿Para qué, cuándo?
Leí en la documentación oficial de Airflowel seguimiento [https://airflow.apache.org/configuration.html#scaling-out-with-celery]: [/imgs/BeHip.png] Que significa exactamente? ¿Qué quieren decir los autores con escalamiento horizontal? Es ...
¿Cómo hacer dos tareas mutuamente excluyentes en Apio?
¿Hay alguna manera de no permitir que dos tareas diferentes se ejecuten simultáneamente en Celery? Estaba pensando en definir una nueva cola con nivel de concurrencia = 1 y enviar esas tareas a esa cola, pero no pude encontrar un ejemplo. ¿Es eso ...
¿Puede apio celerito usar un programador de base de datos sin Django?
Tengo un pequeño plan de infraestructura quenoincluye Django. Pero, debido a mi experiencia con Django, realmente me gusta el apio. Todo lo que realmente necesito es Redis + Celery para hacer mi proyecto. En lugar de usar el sistema de archivos ...
Ejecutar mientras bucle simultáneamente con el servidor Flask
Estoy actualizando algunos LED usando Python. He estado haciendo esto así: from LEDs import * myLEDs = LEDs() done = False while not done: myLEDs.iterate() Quería usar Flask para actuar como un puente entre una interfaz de ReactJS de aspecto ...