celery笔记九之task运行结果查看

合集 - Celery笔记(9)

1.celery笔记一之celery介绍、启动和运行结果跟踪06-012.celery笔记二之建立celery项目、配置及几种加载方式06-023.celery笔记三之task和task的调用06-134.celery笔记四之在Django中使用celery06-155.celery笔记五之消息队列的介绍06-216.celery笔记六之worker介绍06-237.celery笔记七之周期/定时任务及crontab定义06-258.celery笔记八之数据库操作定时任务06-26

9.celery笔记九之task运行结果查看06-29

收起

本文首发于公众号：Hunter后端
原文链接：celery笔记九之task运行结果查看

这一篇笔记介绍一下 celery 的 task 运行之后结果的查看。

前面我们使用的配置是这样的：

# settings.py 

CELERY_RESULT_BACKEND = "redis://localhost/1"

是将 task 的运行结果保存在 redis 的第二个数据库（数据库索引从0开始）。

我们还可以将 task 的运行结果保存到 Django 的数据库，这一篇笔记将介绍如何查看 redis 和 Django 数据库中 task 运行的结果。

1. 查看 redis 中的 task 结果
2. 使用 Django 数据库保存 task 结果

1、查看 redis 中的 task 结果

在 redis 中查看运行的结果，可以直接进入 redis 的交互界面，我这里启动 redis 是使用的 docker，所以命令如下：

docker exec -it container_id redis-cli

其中，container_id 为启动的 docker 容器的 id。

进入之后，选择第二个数据库，可以通过查看 keys * 命令查看所有 key：

select 1
keys *

会输出类似如下数据：

 1) "celery-task-meta-5592a992-2035-49b2-9af2-3e79e50a22a1"
 2) "celery-task-meta-1fc394c2-fb2b-4a85-bcee-a27fe069ec39"
 3) "celery-task-meta-4bff6f33-7ff7-43e7-b844-719018ea1d3d"
 4) "celery-task-meta-fb582658-3eac-471e-8b68-b1248f7b8596"

所有 task 运行的结果都会被冠以 celery-task-meta- 前缀，后面加上的是 task_id。

因为每条数据都是存储的 string 类型的数据，所以可以直接使用 get 命令获取结果：

get celery-task-meta-5592a992-2035-49b2-9af2-3e79e50a22a1

返回的结果会有 状态字段 status，函数返回结果 result，任务id task_id 等信息。

2、使用 Django 数据库保存 task 结果

首先我们需要安装一个依赖：

pip3 install django-celery-results

然后在 settings.py 的 INSTALLED_APPS 里添加：

INSTALLED_APPS = [
    …,
    'django_celery_results',
]

通过 migrate 创建相应的表：

python3 manage.py migrate django_celery_results

执行上面的命令后，数据库会多出三张表：django_celery_results_chordcounter，django_celery_results_groupresult，django_celery_results_taskresult

目前我们 task 的结果都会存储在 django_celery_results_taskresult 表中。

修改 CELERY_RESULT_BACKEND 的值，把原来指向 redis 的去掉：

# settings.py

# CELERY_RESULT_BACKEND = "redis://localhost/1"
CELERY_RESULT_BACKEND = 'django-db'

然后我们正常启动 worker，然后执行一个延时任务，就可以看到在 django_celery_results_taskresult 表中多出一条数据，那就是保存的结果：

from blog.tasks import add
add.delay(1, 2)

除了使用 workbench，navicat 等工具查看数据之外，我们还可以使用命令查看 task 运行的结果：

from django_celery_results.models import TaskResult
TaskResult.objects.count()

如果想获取更多后端相关文章，可扫码关注阅读：