动态更改芹菜任务的周期性间隔运行时

Question

我每分钟运行一次周期性芹菜任务，像这样：

#tasks.py 
@periodic_task(run_every=(crontab(hour="*", minute="*", day_of_week="*")))   
def scraping_task(): 
    result = pollAPI() 

凡功能pollAPI()，你可能已经从名字猜到了，民意调查的API。问题在于API的速率限制是未公开的，并且如果达到该限制，有时会给出错误响应。我希望能够采取该响应，并且如果达到限制，则动态减少周期性任务间隔（或者甚至暂停任务）。这可能吗？

我在关于覆盖schedules的is_due方法的文档中阅读，但我迷失在正确地做什么来给我在这里寻找的行为。谁能帮忙？

Answer 1

您可以尝试使用celery.conf.update更新您的CELERYBEAT_SCHEDULE。