本文首發于公眾號：Hunter后端
原文鏈接：celery筆記九之task運行結果查看
這一篇筆記介紹一下 celery 的 task 運行之后結果的查看，
前面我們使用的配置是這樣的：
# settings.py
CELERY_RESULT_BACKEND = "redis://localhost/1"
是將 task 的運行結果保存在 redis 的第二個資料庫（資料庫索引從0開始），
我們還可以將 task 的運行結果保存到 Django 的資料庫，這一篇筆記將介紹如何查看 redis 和 Django 資料庫中 task 運行的結果，
- 查看 redis 中的 task 結果
- 使用 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()
如果想獲取更多后端相關文章，可掃碼關注閱讀：
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/556311.html
標籤：其他
上一篇：【python爬蟲案例】用python爬豆瓣音樂TOP250排行榜！
下一篇：返回列表