【问题标题】:How to specify filepath for celery task logs?如何为 celery 任务日志指定文件路径?
【发布时间】:2020-08-08 00:19:58
【问题描述】:

我已经使用 Django 创建了一些 REST API,并且我正在使用 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")

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

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

【问题讨论】:

  • 检查工人configuration
  • 好吧,我在 settings.py 中没有提到任何日志路径。对于 api.py,我已经在该文件本身中定义了记录器并且它可以工作。我希望同样适用于 actions.py,但它没有
  • @Kurohige。感谢它的实际工作。我在运行 celery 时指定了 --logfile 并且我能够在正确的位置获取日志。然而,只有“信息”级别的日志即将到来。我需要那里所有类别的日志。但我想我可以用谷歌搜索这个解决方案
  • @DejanLekic 这就是页面所说的“在调试、信息、警告、错误、严重或致命之间进行选择。”但我不想选择一个。我想知道如何将它们全部放在同一个日志文件中。
  • 它们是 LEVELS - DEBUG 包括 ALL,INFO 大部分,WARNING 包括警告和错误,最后 ERROR 只包括错误。这就是 Python 日志框架的一般工作方式......

标签: python django django-rest-framework celery django-celery


【解决方案1】:

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

-f, --logfile

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

例如:

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2013-09-30
    • 1970-01-01
    • 1970-01-01
    • 2013-02-20
    • 2013-02-06
    • 2011-02-17
    • 2020-08-04
    相关资源
    最近更新 更多