在django中使用celery的worker问题

大家好,小白弱弱的问个问题。/坏笑 在django中用celery异步。 每个任务延迟1分种后执行,一个worker执行的话,每个任务延迟1分种,越到后面的任务延迟越久。 所以要每个任务都只延迟一分钟是每个任务都要开一个worker还是有什么办法用一个worker同时执行? 谢谢

评论 1

  • 你的延迟写在了哪里?

  • 之前是用time.sleep(180)。后来改为:tasks.again_order_winxin_push.apply_async((post,user_id,'再次提醒'),countdown=180)就还勉强能用。 只是假如有预定单的细信息还是不知道怎么处理。比如用户下第二天的预订单。到达预定时间的时候要提醒,不知道怎么弄。难道要延时24小时吗?那不是太耗资源了?有什么办法处理吗?