動態更改芹菜任務的週期性間隔運行時

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。