根据Django-Celery模块中的代码,您可以尝试执行以下操作:
from __future__ import absolute_import, unipre_literalsfrom celery import current_appfrom celery.bin import workerif __name__ == '__main__': app = current_app._get_current_object() worker = worker.worker(app=app) options = { 'broker': 'amqp://guest:guest@localhost:5672//', 'loglevel': 'INFO', 'traceback': True, } worker.run(**options)


