Flask 在 Flask 中如何找到 Celery 日志

在本文中，我们将介绍在 Flask 中如何找到 Celery（一种用于处理异步任务的Python库）的日志。

阅读更多：Flask 教程

什么是Celery？

Celery是一个常用的分布式任务队列，用于处理异步任务。它可以实现在后台执行耗时的、低优先级的任务，而不会阻塞主应用程序。

Flask 是一个轻量级的Web应用程序框架，它主要用于快速构建简单的Web应用。当我们在Flask中使用Celery时，我们可能会面临查看Celery任务日志的需求。

配置Celery日志

在Flask中，要找到Celery的日志，需要确保已正确配置Celery的日志输出。

你可以在Flask的配置文件（通常是应用程序的config.py文件）中添加以下配置：

# Flask配置
CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//'
CELERY_RESULT_BACKEND = 'db+sqlite:///results.db'

# Celery配置
CELERY_TASK_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Shanghai'

CELERYD_HIJACK_ROOT_LOGGER = False

在上面的示例中，我们指定了Celery的代理地址和结果后端，以及相关的序列化和时区配置。

其中，CELERYD_HIJACK_ROOT_LOGGER这个配置选项是关键，它将日志委托给Flask应用程序，这样我们就可以通过Flask的日志记录来查看Celery的日志。

查看Celery日志

在Flask应用程序中，我们可以使用Flask内置的日志记录来查看Celery的日志。Flask使用Werkzeug库来记录日志，我们可以通过在应用程序中设置合适的日志级别来控制日志的输出。

例如，我们可以在Flask应用程序中添加以下代码来设置日志的级别和格式：

app.logger.setLevel(logging.DEBUG)
app.logger.addHandler(logging.StreamHandler())

上面的代码将应用程序的日志级别设置为DEBUG，并将日志输出到控制台。

Flask的日志记录器还允许我们根据需要将日志输出到文件中。我们可以使用以下代码来将日志输出到文件：

from logging.handlers import RotatingFileHandler

file_handler = RotatingFileHandler('logs/app.log', maxBytes=1024 * 1024, backupCount=10)
file_handler.setLevel(logging.INFO)
file_handler.setFormatter(logging.Formatter('%(asctime)s %(levelname)s: %(message)s'))

app.logger.addHandler(file_handler)

上面的代码将应用程序的INFO级别的日志输出到logs/app.log文件中，并保留最近的10个日志文件备份。

一旦我们配置好了Flask的日志记录，就可以使用Flask提供的app.logger对象来记录和查看日志了。

在处理Celery任务的函数中，我们可以使用app.logger来记录任务的执行情况和输出日志：

from flask import Flask
from celery import Celery

app = Flask(__name__)
celery = Celery(app.name)

@celery.task
def process_task():
    app.logger.info('Task started.')

    # 执行任务的代码

    app.logger.info('Task completed.')

在上面的示例中，我们使用app.logger记录了任务的开始和完成。