如何在Celery-Django应用程序中监视来自工人的事件？

如何在Celery-Django应用程序中监视来自工人的事件？

好的，尽管我不确定这是否是解决方案，但我找到了一种解决方法，但是对我有用。监视功能基本上直接连接到代理，并侦听不同类型的事件。我的代码如下所示：

from celery.events import EventReceiverfrom kombu import Connection as BrokerConnectiondef my_monitor:    connection = BrokerConnection('amqp://guest:guest@localhost:5672//')    def on_event(event):        print "EVENT HAPPENED: ", event    def on_task_failed(event):        exception = event['exception']        print "TASK FAILED!", event, " EXCEPTION: ", exception    while True:        try: with connection as conn:     recv = EventReceiver(conn,handlers={'task-failed' : on_task_failed,          'task-succeeded' : on_event,          'task-sent' : on_event,          'task-received' : on_event,          'task-revoked' : on_event,          'task-started' : on_event,          # OR: '*' : on_event          }) recv.capture(limit=None, timeout=None)    except (KeyboardInterrupt, SystemExit):        print "EXCEPTION KEYBOARD INTERRUPT"        sys.exit()

这是所有的了。而且我在与正常应用程序不同的过程中运行此程序，这意味着我为我的celery应用程序创建了一个子进程，该子进程仅运行此功能。高温超导