Je suis en train de configurer une tâche planifiée à l'aide DjangoCéleri utilisant RabbitMQ. Après avoir créé l'objet pour la classe de céleri et quelques tâches dans mon répertoire de projet, quand je suis en train de configurer des travailleurs en utilisant la commande suivantequand je suis Executing "travailleur céleri -A myproj" dans Django-céleri se WindowsError: [Erreur 87]
« céleri travailleur -A myproj » Je reçois le retraçage suivant
Traceback (most recent call last):
File "c:\users\murugk7\envs\celery_test\lib\site-packages\celery\worker\worker.py", line 203, in sta
rt
self.blueprint.start(self)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\celery\bootsteps.py", line 119, in start
step.start(parent)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\celery\bootsteps.py", line 370, in start
return self.obj.start()
File "c:\users\murugk7\envs\celery_test\lib\site-packages\celery\concurrency\base.py", line 131, in
start
self.on_start()
File "c:\users\murugk7\envs\celery_test\lib\site-packages\celery\concurrency\prefork.py", line 112,
in on_start
**self.options)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\pool.py", line 1008, in __init__
self._create_worker_process(i)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\pool.py", line 1117, in _create_w
orker_process
w.start()
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\process.py", line 122, in start
self._popen = self._Popen(self)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\context.py", line 383, in _Popen
return Popen(process_obj)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\popen_spawn_win32.py", line 64, i
n __init__
_winapi.CloseHandle(ht)
TypeError: must be integer<k>, not _subprocess_handle
(celery_test) C:\kavin\Assigner\assigner>Traceback (most recent call last):
File "<string>", line 1, in <module>
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\spawn.py", line 159, in spawn_mai
n
new_handle = steal_handle(parent_pid, pipe_handle)
File "c:\users\murugk7\envs\celery_test\lib\site-packages\billiard\reduction.py", line 121, in steal
_handle
_winapi.PROCESS_DUP_HANDLE, False, source_pid)
WindowsError: [Error 87] The parameter is incorrect
en settings.py il a
app = Celery('assigner',
broker='amqp://myuser:[email protected]/my_Vhost',
backend='rpc://',
include=['assigner.tasks'])
en tasks.py, il a
from __future__ import absolute_import
from assigner.celery import app
import time
@app.task
def longtime_add(x, y):
print 'long time task begins'
# sleep 5 seconds
time.sleep(5)
print 'long time task finished'
return x + y
J'utilise Django-1.8, céleri 4.0, AMQP = 2.1.1 où myporj est mon nom de projet Django
S'il vous plaît aidez-moi à résoudre ce problème.