更少的 Celery 任务日志记录

Question

我们使用 Celery 来管理 Python Django 应用程序中的任务。
我们还使用 Django structlog 来记录 Celery 打印的日志消息。
我们通过 Logstash 将这些消息摄取到 ElasticSearch，并注意到我们收到的绝大多数消息是这 2 条：

收到的任务：%s

任务 %(name)s[%(id)s] 在 %(runtime)ss 中成功：%(return_value)s

Celery 使用 INFO 日志记录级别转储它们。
有什么方法可以将这些消息更改为 DEBUG 级别？
这样我们仍然可以使用 -l INFO 运行 celery 并查看其他 INFO 消息，但看不到这些消息？

更新

对于第二条日志消息。

快速阅读后：

• https://docs.celeryproject.org/en/stable/internals/reference/celery.app.trace.html

• https://docs.celeryproject.org/en/latest/_modules/celery/app/trace.html

如果没有 Celery、Django 和 structlog 的很多知识，这样的东西会起作用吗？

LOGGING = {
...
'loggers': {
        'celery.app.trace': {
          'handlers': ['null'],
          'propagate': False,
         }
...
}

Answer 1

我只能忽略这两条消息：

初始化.py

import celery
from unittest import mock

app = celery.Celery()


from celery.app import trace
old_info = trace.info
trace.info = mock.Mock()


class MyTask(celery.Task):
    Strategy = '61242484.strategy:my_default'


@app.task(base=MyTask)
def test():
    print("123")


test.apply_async()

strategy.py

from unittest import mock
from celery.worker.strategy import default


def my_default(*args, **kwargs):
    kwargs['info'] = mock.Mock()
    return default(*args, **kwargs)