2

ここで説明されているセロリ信号に接続しようとしています：
http
： //docs.celeryproject.org/en/latest/userguide/signals.htmltask_sentシグナルに問題なく接続できます。

しかし、task_successまたはtask_postrunに接続しようとしても、何も起こりません。ブローカーとバックエンドには、postgressqlを使用しています。

なぜ機能しないのか理解しようとしています

ここのドキュメントから私が疑問に思っていたことが1つあります：http：
//docs.celeryproject.org/en/latest/getting-started/brokers/sqlalchemy.html#broker-sqlalchemy
それは言う：

制限：DjangoAdminモニターを含むイベント。

彼らがイベントと言うとき、彼らが合図を意味するかどうかは明らかではありません。

助けてください。

tasks.py

from celery import Celery
from celery.signals import task_sent, task_success, task_postrun
import celeryconfig

celery_config_dict = {** stuff **}

celery = Celery('tasks',)
celery.add_defaults(celery_config_dict)


@celery.task
def add(x, y):
    return x + y



@task_sent.connect
def task_sent_handler(sender=None, task_id=None, task=None, args=None, kwargs=None, **kwds):
    print('''   Task Sent!
    sender: %s
    task_id: %s
    task: %s
    args: %s
    kargs: %s
    kwds: %s''' % (   sender, 
                        task_id, 
                        task,
                        args,
                        kwargs,
                        kwds))


@task_success.connect
def task_success_handler(sender=None, result=None, args=None, kwargs=None, **kwds):
    print('''   Success!
    sender:%s
    result:%s
    args:%s
    kwargs:%s
    kwds:%s''' % (sender, result, args, kwargs, kwds))


@task_postrun.connect
def task_postrun_handler(sender=None, task_id=None, task=None, args=None, kwargs=None, retval=None, state=None, **kwds):
    print('''   Done!
    sender: %s
    task_id: %s
    task: %s 
    retval: %s
    state: %s
    args:%s
    kwargs:%s   
    kwds:%s''' % (sender, task_id, task, retval, state, args, kwargs, kwds,))

Pythonインタープリターで

>>> import tasks
>>> r = tasks.add.apply_async((3,8), countdown=10)
   Task Sent!
    sender: tasks.add
    task_id: None
    task: tasks.add
    args: (3, 8)
    kargs: {}
    kwds: {'utc': True, 'chord': None, 'retries': 0, 'signal': <Signal: Signal>, 'expires': None, 'callbacks': None, 'errbacks': None, 'taskset': None, 'eta': '2013-02-01T01:43:35.978889', 'id': '87c8d0f4-ae67-4c3d-9e94-45e99cf6304a'}
>>>
4

1 に答える 1

5

いいえ、イベントとシグナルは同じではありません。http://docs.celeryproject.org/en/latest/userguide/monitoring.html#eventsを参照してください

シグナルは現在のプロセスに対してローカルであるため、そのインタープリターで何も出力されることは期待できません。したがって、実行前/実行後のシグナルは、タスクが実行されているプロセスでトリガーされます。

于 2013-02-01T11:07:12.177 に答える