Error de apio: recibió tareas no registradas de tipo 'test_post' -- 16.04 campo con server campo con python campo con rabbitmq camp askubuntu Relacionados El problema

Celery Error: Received unregistered task of type 'test_post'


0
vote

problema

Español

Estoy recibiendo el siguiente error en mi registro de apio:

  [2018-05-04 23:33:42,186: ERROR/MainProcess] Received unregistered task of type 'test_post'. The message has been ignored and discarded.  Did you remember to import the module containing this task? Or maybe you're using relative imports?  Please see http://docs.celeryq.org/en/latest/internals/protocol.html for more information.  The full contents of the message body was: '[[], {}, {"callbacks": null, "errbacks": null, "chord": null, "chain": null}]' (77b) Traceback (most recent call last):   File "/home/james/postr/env/lib/python3.5/site-packages/celery/worker/consumer/consumer.py", li$     strategy = strategies[type_] KeyError: 'test_post'   

ABCDEFGHIJKLMNABCDEFGHIJKLMN3 es mi única tarea de apio, y está en otro módulo (no es mi módulo de aplicación principal), lo que puede ser por eso que estoy encontrando este problema. Me vieron obligados a hacer esto, ya que mi modelo no podía ser importado de la aplicación principal. Mi apio Conf se ve así ( ABCDEFGHIJKLMNABCDEFGHIJKLMN4 no es el módulo principal):

  ABCDEFGHIJKLMNABCDEFGHIJKLMN5   

Puedo recibir con éxito la tarea:

ingrese la descripción de la imagen aquí

Sin embargo, cuando inicio mi ritmo de apio a través de celery -A draft1 beat :

ingrese la descripción de la imagen aquí

Mi registro de apio devuelve el error ( ABCDEFGHIJKLMNABCDEFGHIJKLMN7 ):

He intentado iniciar el ritmo de apio a través de celery -A post beat , sin embargo, no cambia nada.

Mis ajustes se ve así:

  ABCDEFGHIJKLMNABCDEFGHIJKLMN9   

post / tareas.py

  /usr/local0  

POST / CELERY.PY

  /usr/local1  

Draft1 / Celery.py

  /usr/local2  

¿Alguna idea de por qué estoy recibiendo el error y cómo puedo arreglarlo?

Original en ingles

I'm getting the following error in my celery log:

[2018-05-04 23:33:42,186: ERROR/MainProcess] Received unregistered task of type 'test_post'. The message has been ignored and discarded.  Did you remember to import the module containing this task? Or maybe you're using relative imports?  Please see http://docs.celeryq.org/en/latest/internals/protocol.html for more information.  The full contents of the message body was: '[[], {}, {"callbacks": null, "errbacks": null, "chord": null, "chain": null}]' (77b) Traceback (most recent call last):   File "/home/james/postr/env/lib/python3.5/site-packages/celery/worker/consumer/consumer.py", li$     strategy = strategies[type_] KeyError: 'test_post' 

post_jobs is my only celery task, and it's in another module (not my main app module), which may be why I'm encountering this problem. I was forced to do this as my model could not be imported from the main app. My celery conf looks like this (post is not the main module):

[program:postr-celery] command=/home/james/postr/env/bin/celery -A post worker --loglevel=INFO directory=/home/james/postr user=james numprocs=1 stdout_logfile=/var/log/supervisor/celery.log stderr_logfile=/var/log/supervisor/celery.log autostart=true autorestart=true startsecs=10  ; Need to wait for currently executing tasks to finish at shutdown. ; Increase this if you have very long running tasks. stopwaitsecs = 600  stopasgroup=true 

I can successfully receive the task:

enter image description here

however when I start my celery beat via celery -A draft1 beat:

enter image description here

my celery log returns the error (Received unregistered task of type 'test_post'):

I've tried starting celery beat via celery -A post beat instead however it doesn't change anything.

My settings looks like this:

CELERY_BROKER_URL = 'amqp://{}:{}@174.138.62.249/vhost'.format(config('RABBIT_USER'), config('RABBIT_PW')) CELERY_BEAT_SCHEDULER = "django_celery_beat.schedulers.DatabaseScheduler" CELERYBEAT_SCHEDULE = {     'test_post': {         'task': 'post.tasks.test_post',         'schedule': crontab(minute=40),     } } 

post/tasks.py

@app.task def test_post():     from .models import Post     for i in Post.objects.all():         if i.entered_category == "test":             i.entered_category = "not_test"             i.save()     return HttpResponseRedirect('/') 

post/celery.py

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'draft1.settings') app = Celery(broker=CELERY_BROKER_URL) app.config_from_object('django.conf:settings', namespace='CELERY') app.autodiscover_tasks() 

draft1/celery.py

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'draft1.settings') app = Celery("draft1", broker=CELERY_BROKER_URL) app.config_from_object('django.conf:settings', namespace='CELERY') app.autodiscover_tasks() 

Any idea why I'm getting the error and how I can fix it?

           
 
 

Lista de respuestas


Relacionados problema

1  Los comandos de rabbitmq no funcionan  ( Rabbitmq commands are not working ) 
Cuando realizo sudo rabbitmqctl add_user james mypassword devuelve: Creating user "james" ... Error: {badarg, [{erlang,group_leader,[undefined...

1  Erlang desapareció de / usr / bin / erl  ( Erlang disappeared from usr bin erl ) 
La configuración He descargado rabbitmq y lo usé en una máquina EC2 14.04 por unos días. La configuración fue simple: descargué la binario .tar.gz , lo...

0  OpenStack Juno RabbitMQ Charm: Falta el archivo de configuración  ( Openstack juno rabbitmq charm config file missing ) 
Tratando de implementar un Multi-Nodo OpenStack Juno, el 14.04. Aquí está mi archivo de configuración de encanto: nova-cloud-controller: openstack-origin...

3  ¿Cómo instalar el complemento de administración de RabbitMQ (Rabbitmq-Plugins)?  ( How to install rabbitmq management plugin rabbitmq plugins ) 
BREVE: ¿Hay alguna manera de instalar Rabbitmq-Plugins a través de un paquete de Ubuntu? Detalles: Tengo RabbitMQ en funcionamiento en mi sistema Ubuntu, ...

2  La conexión AMQP se cerró cuando las células NOVA están habilitadas en DevStack  ( Amqp connection closed when nova cells are enabled on devstack ) 
He configurado DevStack en 3 servidores que tienen IPS 10.10.1.51,10.10.1.53 y 10.10.1.54. Configuré el devstack en el servidor 53 (IP 10.10.1.53) como la cel...

0  Integergación de Maas con Rabbitmq  ( Maas integeration with rabbitmq ) 
Tengo dudas en Maas ¿Cómo puedo integrar los MAAs con RabbitMQ ¿Hay algún complemento para esto? ¿Puede alguien por favor ayudarme? ...

0  Error de apio: recibió tareas no registradas de tipo 'test_post'  ( Celery error received unregistered task of type test post ) 
Estoy recibiendo el siguiente error en mi registro de apio: [2018-05-04 23:33:42,186: ERROR/MainProcess] Received unregistered task of type 'test_post'. Th...

2  ¿Cómo arreglar errores de dependencia no satisfechas de Erlang?  ( How to fix erlang unmet dependency errors ) 
Estoy enfrentando a los problemas de dependencia al realizar la instalación de rabbitmq-server a través de Apt. Tengo 2 archivos agregados en /etc/apt/sour...

0  Rabbitmq Escucha en el puerto 25672 después de activar la nueva interfaz NIC  ( Rabbitmq listen on port 25672 after activating new nic interface ) 
He instalado a RabbitMQ y funcionó correctamente hasta que active una nueva interfaz NIC y cambió el puerto para IPv4 a 25672. Aquí está la salida de ABCDEFG...

1  Encanto usando rabbitmq  ( Charm using rabbitmq ) 
Aquí está el problema: 1) Tengo un rabbitmq en Juju. 2) Tengo un encanto que intenta usar RabbitMQ, escrito en Java (lo llamaré ABCDEFGHIJKLMNABCDEFGHIJK...




© 2022 respuesta.top Reservados todos los derechos. Centro de preguntas y respuestas reservados todos los derechos