动态更改芹菜任务的周期性间隔运行时
问题描述:
我每分钟运行一次周期性芹菜任务,像这样:动态更改芹菜任务的周期性间隔运行时
#tasks.py
@periodic_task(run_every=(crontab(hour="*", minute="*", day_of_week="*")))
def scraping_task():
result = pollAPI()
凡功能pollAPI()
,你可能已经从名字猜到了,民意调查的API。问题在于API的速率限制是未公开的,并且如果达到该限制,有时会给出错误响应。我希望能够采取该响应,并且如果达到限制,则动态减少周期性任务间隔(或者甚至暂停任务)。这可能吗?
我在关于覆盖schedules
的is_due
方法的文档中阅读,但我迷失在正确地做什么来给我在这里寻找的行为。谁能帮忙?
答
您可以尝试使用celery.conf.update
更新您的CELERYBEAT_SCHEDULE
。