如何为芹菜任务日志指定文件路径



我已经使用Django创建了一些RESTAPI,并且我正在使用Celery来运行一些异步作业。API在api.py中定义,异步作业函数在actions.py

以下是我的api.py的样子:

from myproject import actions
def sample_api(request):
actions.sample_job.delay()
return HttpResponse('success')

以下是我的actions.py的样子:

from celery.utils.log import get_task_logger
from celery.decorators import task
logger = get_task_logger(__name__)

@task(name="sample_job")
def sample_job():
logger.info("start operation")
<some operations>
logger.info("stop operation")

现在的问题是,我不知道日志写在哪里。我试过在项目目录中搜索,但在任何地方都看不到。我想提供一个日志文件的路径,应该在其中写入这些日志。我该如何在芹菜中提供日志文件的路径?

(我知道StackOverflow中有很多关于这方面的问题。但没有一个真正提到如何为日志文件指定文件路径(

您需要从文档中指定日志文件:

-f,--日志文件

日志文件的路径。如果未指定日志文件,则使用stderr

例如:

celery -A project worker --logfile=<path>

最新更新