V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python Sites
PyPI - Python Package Index
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
RynItme
V2EX  ›  Python

celery 清空任务队列的疑问

  •  
  •   RynItme · 2019-05-21 10:40:54 +08:00 · 3573 次点击
    这是一个创建于 2021 天前的主题,其中的信息可能已经有所发展或是发生改变。
    目前在用 celery broker backend 都是 redis 。 有一个需求是要查看所有的 等待执行的延迟任务 和 清空等待执行的任务。 有一个方式是操作 redis 代码层面有没有好的方式。
    2 条回复    2019-05-21 15:09:27 +08:00
    a852695
        1
    a852695  
       2019-05-21 14:30:31 +08:00
    同直接操作 redis
    RynItme
        2
    RynItme  
    OP
       2019-05-21 15:09:27 +08:00
    from proj.celery import app
    app.control.purge()

    官网是有这种方式 然而 我操作之后返回条数为 0
    reids 中 unacked_index 这个索引厉害依然存在数据


    ```
    127.0.0.1:6379> ZRANGE unacked_index 0 10 WITHSCORES
    1) "dc96716a-c8f7-4797-9029-64eb0a7ffd22"
    2) "1558418885.3853481"
    3) "01d96271-a3b8-418d-aa88-0117db7ebd69"
    4) "1558421585.326695"

    ```
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2943 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 12:38 · PVG 20:38 · LAX 04:38 · JFK 07:38
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.