不同文件中的芹菜 + Redis 任务

Question

当我从命令行运行 Celery 时，我只能看到与 Celery 对象位于同一文件中的任务，而看不到其他文件中的任务。

该项目的结构如下：

celery_test
celery_tasks
__init__.py
celery_app.py
async
__init__.py
tasks.py
marker
__init__.py
tasks.py

文件内容如下

celery_app.py
from __future__ import absolute_import
from celery import Celery
celery_application = Celery('celery_test', backend='redis://localhost', broker='redis://localhost')
@celery_application.task
def test_celery():
print 4

任何tasks.py文件都有这样的东西

async/tasks.py
from __future__ import absolute_import
import time
from celery_tasks.celery_app import celery_application

@celery_application.task
def async_test():
print 'Start async_test'
time.sleep(3)
print 'Finish async_test'

当我按如下方式运行芹菜时

celery --app=celery_tasks.celery_app:celery_application worker -l debug

我得到以下内容

-------------- celery@LAPTOP-HCR4G00Q v3.1.25 (Cipater)
---- **** -----
--- * ***  * -- Windows-10-10.0.16299
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         celery_test:0x6ff3f28
- ** ---------- .> transport:   redis://localhost:6379//
- ** ---------- .> results:     redis://localhost/
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ----
--- ***** ----- [queues]
-------------- .> celery           exchange=celery(direct) key=celery

[tasks]
. celery.backend_cleanup
. celery.chain
. celery.chord
. celery.chord_unlock
. celery.chunks
. celery.group
. celery.map
. celery.starmap
. celery_tasks.celery_app.test_celery

这只是与应用程序位于同一文件中的任务。

关于如何解决它的任何建议？我确实需要按主题分隔任务，因为它们很多，因此它们位于一个文件中。

Answer 1

我花了很多时间写这个问题，我刚刚解决了它，所以我分享了解决方案，因为没有太多关于它的信息(或者至少我没有找到它(。

定义 Celery 对象后，我尝试自动发现任务，但没有成功。我的最后一次尝试是更改应用程序的名称并通过以下方式强制检测：

celery_application.autodiscover_tasks(['celery_tasks.async', 'celery_tasks.marker'], force=True)

从celery_test/运行：

celery --app=celery_tasks.celery_app:celery_application worker -l info

这解决了我的问题。我希望这对你有帮助