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

浅浅的花香味﹌ 2024-03-17 13:36 38阅读 0赞

这一篇笔记介绍一下 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()

发表评论取消回复

表情：

评论列表（有 0 条评论，38人围观）

还没有评论，来说两句吧...

相关阅读

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

这一篇笔记介绍一下 celery 的 task 运行之后结果的查看。前面我们使用的配置是这样的： settings.py CELERY_RE

浅浅的花香味﹌/ 2024年03月17日 13:36/ 0 赞/ 39 阅读

相关 celery笔记六之worker介绍

前面我们介绍过 celery 的理想的设计方式是几个 worker 处理特定的任务队列的数据，这样可以避免任务在队列中的积压。这一篇笔记我们介绍一下如何使用 worker

谁践踏了优雅/ 2024年03月17日 13:36/ 0 赞/ 44 阅读

相关 celery笔记五之消息队列的介绍

前面我们介绍过 task 的处理方式，将 task 发送到队列 queue，然后 worker 从 queue 中一个个的获取 task 进行处理。 task 的队列 que

曾经终败给现在/ 2024年03月17日 13:36/ 0 赞/ 9 阅读

相关 celery笔记四之在Django中使用celery

这一篇笔记介绍一下如何在 Django 系统中使用 celery。如果是想纯粹使用 celery，这一篇笔记可以略过。本篇笔记目录如下： 1. 文件配置 2. t

刺骨的言语ヽ痛彻心扉/ 2024年03月17日 13:36/ 0 赞/ 42 阅读

相关 celery笔记一之celery介绍、启动和运行结果跟踪

本篇笔记内容如下： 1. celery 介绍 2. celery 准备 3. celery 启动和异步任务的运行 4. 运行结果跟踪 1、celery 介绍

淡淡的烟草味﹌/ 2024年03月17日 12:59/ 0 赞/ 42 阅读

相关 Celery使用报错：Received unregistered task of type '***.tasks.sms.task_sms.send_template_sms'.

问题描述：有多个任务需要时使用Celery目录结构，在程序启动之后，任务列表里面没有任务显示，而且程序收到任务之后，报错：Received unregistered t

傷城~/ 2023年06月26日 08:27/ 0 赞/ 13 阅读

相关 celery task php,Celery(示例代码)

Celery 1.Celery是什么 Celery 一个懂得异步任务 , 定时任务 , 周期任务的芹菜 Celery 是基于Python实现的模块, 用于执行异步定时

曾经终败给现在/ 2023年01月16日 02:56/ 0 赞/ 147 阅读

相关 Gradle学习之列之九——自定义Task类型

> 学习了大佬的文章，感觉写的太好了，感谢大佬分享，可惜是gradle4.x的，升级为6.5。大佬博客地址 https://www.cnblogs.com/davenkin/

太过爱你忘了你带给我的痛/ 2022年12月16日 00:48/ 0 赞/ 132 阅读

相关 Celery 框架学习笔记

学习Celery之前，我先简单的去了解了一下什么是生产者消费者模式。生产者消费者模式在实际的软件开发过程中，经常会碰到如下场景：某个模块负责产生数据，这些数据由另一

ゝ一世哀愁。/ 2022年03月22日 05:22/ 0 赞/ 230 阅读

相关《CLR Via C# 第3版》笔记之（十九） - 任务（Task）

除了[上篇][Link 1]中提到的线程池，本篇介绍一种新的实现异步操作的方法--任务(Task)。主要内容：任务的介绍任务的基本应用子任务和任务

电玩女神/ 2021年12月22日 11:09/ 0 赞/ 201 阅读