Preguntas etiquetadas [celery]

0 votos
0 respuestas
No se puede transmitir el mensaje utilizando apio
Estoy tratando de usar la compilación de apio para el enrutamiento de difusión utilizando Difusión y utilizando rabbitmq como intermediario. He...
preguntó hace 2 meses
0 votos
1 respuestas
Eliminar elementos de celery_beat no los elimina de la programación de la base de datos
Estoy usando django-celery-beat en una aplicación de django (esto almacena la programación en la base de datos en lugar de un archivo local). He...
preguntó hace 2 meses
0 votos
0 respuestas
apio: ¿por qué es útil cuando elimino el elemento "search localdomain" en /etc/resolv.conf?
cuando uso "celery -A task worker -l info", se produce el siguiente nodo de trabajo : [2019-04-26 20:27:00,290: ERROR/MainProcess] consumer:...
preguntó hace 2 meses
0 votos
0 respuestas
Trabajos de Apio a partir de CouchDB _changes
CouchDB puede producir "notificaciones" mediante sondeo en un punto final _changes . Me gustaría que Celery tire task argumentos de _changes....
preguntó hace 2 meses
0 votos
0 respuestas
No se puede ejecutar Django Celery después de la siguiente documentación
Estoy intentando implementar apio en un proyecto actual de django 2 en curso. Estoy usando django 2.13 y apio 4.3. Aquí el código en el inicio...
preguntó hace 2 meses
0 votos
0 respuestas
Agregar colas a Rabbitmq y trabajadores a las colas en Celery
Intentando ejecutar aproximadamente 66 scripts de Python que realizan algunas tareas de manipulación de datos. Tres scripts tardan mucho tiempo...
preguntó hace 2 meses
0 votos
1 respuestas
¿Por qué Celery tiene comportamientos diferentes en dos formas de iniciar al trabajador?
Agregué un trabajador de apio en el paquete app: proj ├── app │   ├── worker.py │   └── server.py └── db ├── db.sql ├── check_db_healt...
preguntó hace 2 meses
0 votos
0 respuestas
Frasco - jsonificar los resultados de la tarea de apio
Tengo una larga tarea de apio: @celery.task(queue='cache') def cache_user_tracks(user_id): # generator - yields external api calls tra...
preguntó hace 2 meses
0 votos
1 respuestas
apio: imprime el estado de cada tarea dentro de un grupo iniciado con apply_async
Estoy tratando de imprimir el estado de 4 tareas remotas, obteniendo información de cada AsyncResult dentro del grupo. Hasta ahora puedo impr...
preguntó hace 2 meses
0 votos
0 respuestas
Apio: el modulo no fue encontrado
Estoy utilizando Open Semantic Search (OSS) y me gustaría monitorear sus procesos con la herramienta Flower . Los trabajadores que necesita el...
preguntó hace 2 meses
0 votos
1 respuestas
¿Cómo puedo cambiar el nombre de una tarea que Celery envía a un servidor?
He construido un sistema de colas usando Celery que acepta solicitudes web y ejecuta algunas tareas para actuar sobre esas solicitudes. Estoy us...
preguntó hace 1 mes
0 votos
0 respuestas
Ramificación del uso de una cola única para cada tarea con redis backend
Me di cuenta de que el backend de Redis para apio almacena cada solicitud de tarea en una lista debajo de una cola. Esto hace que eliminar (abor...
preguntó hace 2 meses
0 votos
0 respuestas
Operadores de flujo de aire on_kill y apio timeout
Nos gustaría establecer un tiempo de espera de apio de 2 horas con la opción visibilidad_tiempo de espera. nuestro dag envía los trabajos a un A...
preguntó hace 2 meses
0 votos
1 respuestas
Apio Aceptar más tareas que la concurrencia del trabajador.
Estoy ejecutando algunas tareas de larga ejecución en una cola dedicada. Así que no hay poco tiempo ejecutando tareas. Actualmente, cuando comie...
preguntó hace 2 meses
0 votos
1 respuestas
No se puede importar la aplicación de nombre cuando se usa apio en matraz
Estoy escribiendo una aplicación sencilla de Flask que usa Celery para ejecutar una tarea en segundo plano, pero cuando intento ejecutar la apli...
preguntó hace 2 meses
0 votos
2 respuestas
Error al iniciar la tarea de apio del proceso de trabajo con Django en debug = False (producción)
Esta es una tarea de apio para enviar correos electrónicos, lo curioso es que todo funciona correctamente en el modo DEBUG = True, pero no funci...
preguntó hace 2 meses
0 votos
1 respuestas
Resultados de la consulta de Celery Results Backend MYSQL
¿Cuál es la forma más sencilla de consultar todos los resultados de un resultado backend en el apio? Estoy usando un almacén de datos de MySQL c...
preguntó hace 2 meses
2 votos
2 respuestas
No se pueden ver los mensajes de salida de las tareas realizadas en la combinación celery-rabbitMQ
Estoy probando combinaciones de apio y conejoMQ para la programación de tareas asíncronas, a continuación se muestra el programa de ejemplo que...
preguntó hace 2 meses
0 votos
1 respuestas
¿Cómo puede un trabajador (subproceso) reservar espacio en disco y comunicar la reserva con otros trabajadores?
Estoy intentando configurar una clase de autoescala que verificará el recurso del disco para ver si un trabajador puede ejecutar de forma segura...
preguntó hace 2 meses
0 votos
0 respuestas
convierta rrule al valor cron en python para soportar el apio
Hola, estoy intentando implementar celery-beat para programar servicios, pero nuestra interfaz de usuario está diseñada para enviar datos en for...
preguntó hace 2 meses
0 votos
1 respuestas
No se puede iniciar los trabajadores de apio (aplicación matraz)
Estoy probando el apio con Python Flask. celery_example.py from __future__ import absolute_import, unicode_literals from flask import Flask...
preguntó hace 2 meses
0 votos
0 respuestas
¿Es posible llamar a una tarea en una cadena con la opción * max_retries * siendo parametrizada?
Necesito realizar la misma tarea en diferentes cadenas con diferente comportamiento. Para la cadena A, quiero limitar el número de reinicios, as...
preguntó hace 2 meses
1 votos
1 respuestas
La tarea de apio se llama a sí misma después de que la tarea tenga éxito sin apio
Quiero llamar a mi tarea de apio de vez en cuando como cada 30 minutos después de la tarea actual, pero a veces la tarea tarda más de lo esperad...
preguntó hace 2 meses
1 votos
0 respuestas
¿Cuál es el significado de la variable CELERY_TIMEZONE en el archivo settings.py de un proyecto Django?
Sé que USE_TZ=True guarda todos los objetos datetime en UTC en la base de datos. En ese caso, cuando una tarea está programada para ejecutarse e...
preguntó hace 3 meses
0 votos
1 respuestas
Excepción no manejada en el apio congela a los trabajadores.
Estoy ejecutando apio en la ventana acoplable a través de un backend redis. Yo tengo contenedor de apio para batir contenedor de apio obre...
preguntó hace 3 meses