Celery之任務處於PENDING處理

2021-08-29 09:40:49 字數 1051 閱讀 6917

1.問題描述:任務一直處於pending,重啟redis不行!

任務:1ead8f07-8f49-4ef2-9c8c-54a49d90d362 當前的 state 為:pending

任務:0570e1b6-1d98-4731-849a-8adfb70bfa14 當前的 state 為:pending

任務:1ead8f07-8f49-4ef2-9c8c-54a49d90d362 當前的 state 為:pending

任務:0570e1b6-1d98-4731-849a-8adfb70bfa14 當前的 state 為:pending

2.解決方案:

要把celery起起來

celery worker -a progressbar_form.celery --loglevel=info

2.1如果之前測試起了太多工,那麼首先要把redis內的任務清除掉

redis-cli -n 11 ltrim transcode 0 196 (任務太多要多試幾次)

-n 後面跟的是你要清除的第幾個資料庫(redis無密碼)

參考文件:

celery實測之定時任務

新建乙個tasks檔案,裡面 如下 coding utf 8 import requests from celery import celery ip def setup periodic tasks sender,kwargs 每5秒鐘就呼叫一次test方法 sender.add periodic...

Celery任務佇列

使用任務佇列作為分發任務的機制。乙個任務佇列的輸入是一組被稱為任務的工作單元。專用的工人會持續監聽任務佇列來等待完成新的工作。celery通過訊息進行通訊,通常使用中間人作為客戶端和工人 workers 間的媒介。為了初始化一項任務,客戶端會新增一條訊息到佇列中,然後中間人傳遞這條訊息給乙個work...

celery 任務模組

每天不知道忙啥,到了這個點才開始學習 1.新建python檔案 from future import absolute import 絕對路徑的匯入 from celery import celery from django.conf import settings import os 設定系統的環...