我的应用程序包括django、celery 、redis和scrapy。
在当地,我启动了django( python manage.py runserver
)还有celery ( celery -A web_app worker
). 然后,我触发一个命令,该命令运行一个scrapy webcrawler(通过crawlerrunner),检索一些信息,并进行额外的异步调用,这些调用被推送到我的任务队列中。一切正常。
然而,当我通过kubernetes经营celery 时(称为同一种方式) celery -A web_app worker
),我的任务将在完成该任务后停止运行。除非我重新启动工作进程,否则它不会执行任何其他任务。
思想?
当我在kubernetes用同样的命令运行celery 时,引擎盖下发生了什么,而当我在本地运行celery 时呢?
暂无答案!
目前还没有任何答案,快来回答吧!