V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
0bit
V2EX  ›  RQ

RQ中,在一个Queue执行完之后触发事件的方法

  •  
  •   0bit · 2013-07-09 08:44:38 +08:00 · 6330 次点击
    这是一个创建于 3915 天前的主题,其中的信息可能已经有所发展或是发生改变。
    先吐槽一句,RQ的官方文档,真的是少得可怜,很多东西都要自己到源码里开才会发现。

    我现在要处理很多包,因为要每个包独立处理,所以每个包生成一个Queue,然后我需要的是,在这个Queue处理完成之后,对这个Queue的结果进行统计,貌似RQ中没有这种触发机制,不知道有没有什么好的方法。

    我现在用的方法是,不用rqworker,自己在程序里调用Worker,然后设置burst=True,把相关的统计代码,放到worker执行完之后,但是总觉得不是十分的靠谱。

    代码大概是这样的:

    queueList = sorted([q for q in Queue.all() if q.name != 'failed'])
    w = Worker(queueList.pop())
    w.work(burst=True)
    # 相关的统计函数()
    3 条回复    1970-01-01 08:00:00 +08:00
    Livid
        1
    Livid  
    MOD
       2013-07-09 08:52:26 +08:00
    这种处理方法也挺环保的。

    因为 worker 本来就应该是持续运行的,所以只有 burst queue 才会存在说运行结束的概念。
    wuxqing
        2
    wuxqing  
       2013-07-09 08:54:39 +08:00
    0bit
        3
    0bit  
    OP
       2013-07-09 09:28:01 +08:00
    @Livid 那我应该把每个任务,加上timeout,免得卡死。多谢了。


    @wuxqing 多谢,之前还真的没看过这个例子。
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   1020 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 25ms · UTC 19:43 · PVG 03:43 · LAX 12:43 · JFK 15:43
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.