celery清空佇列

2021-07-25 03:03:07 字數 396 閱讀 2345

本人在使用python celery佇列時,有時候需要清空佇列,但是python  celery似乎並沒有清空佇列的api(至少我沒找到),所以使用redis-cli工具進行佇列清空:

使用redis-cli工具,命令如下,在終端直接輸入:

redis-cli -n 15 ltrim transcode 0 196

-n 15 :       資料庫編號15

transcode:          你自己的redis   key值(一般為queue名稱),此處transcode這個key值,對應的資料為list

0:      起始索引

196:       結尾索引

命令含義:       保留15號庫,key值為transcode,索引從0開始至196的資料,刪除其他

Celery任務佇列

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

訊息佇列和Celery

訊息佇列 message queue,簡稱mq 提供非同步通訊協議。可以實現程序間通訊或同一程序的不同執行緒間通訊 其中 訊息 是指包含必要資訊的資料。訊息的傳送者傳送完畢後立即返回,訊息被儲存進佇列中,對這個訊息感興趣的消費者會訂閱訊息並接收和處理它。使用訊息佇列的好處如下 本章主要包含以下內容 ...

Celery多佇列配置

專案結構 proj init celeryconfig.py celery的配置檔案 tasks.py celery編寫任務檔案 coding utf 8 from future import absolute import from celery import celery proj includ...