2014-11-22 31 views
2

我想監視一個隊列,當它變爲空時將被通知。要做到這一點,我需要找出隊列中有多少條消息,並且這個任務需要運行每隔一段時間。每15秒。芹菜:如何統計每個間隔隊列中的消息總數?

我很困惑閱讀它說,你不應該在生產工人使用celerybeat的文檔,那麼這是否意味着我需要創建一個使用週期任務的獨立python腳本?不知道我該如何實現這一點。

+0

只要運行在另一個進程中拍:'說使用pyrabbit IM $芹菜beat' – nathancahill 2014-11-22 05:53:39

回答

1

您可以使用this answer隊列檢索消息的數量。

拍子,你可以隨時使用

celery beat 

啓動一個新的進程。如果你不想用擊敗所有,你可以安排一個cron作業,這將做到這一點你。

+0

,如何將我告訴芹菜節拍來運行這個每30秒? – user299709 2014-11-22 07:49:56

+0

運行週期性任務http://celery.readthedocs.org/en/latest/userguide/periodic-tasks.html#entries – ChillarAnand 2014-11-22 07:51:44

+0

我在哪裏放CELERYBEAT_SCHEDULE,在同一個腳本作爲一個我的工人正在使用?會不會創造多個時間表?或者只有帶'-B'選項的工作人員每隔一段時間運行一次?如果工人沒有指定-B,它會忽略它? – user299709 2014-11-22 07:55:53