celery kubernetes 示例:Small Flask应用程序在Kubernetes上部署了可伸缩的异步后端工作程序 源码

Kubernetes上的芹菜 Celery工人使用Kubernetes应用程序的玩具示例。 该系统由HTTP服务组成,该HTTP服务根据输入大小使用两个不同的任务队列异步计算长时间运行的任务。 该示例旨在用于Minikube的本地实验,并且可能不适合直接用于生产。 该Web服务是一个简单的Flask应用程序,部署在其自己的pod中,以及一个用于处理小任务的Celery工作者(一个pod中有两个容器)。 该系统使用RabbitMQ作为Celery消息代理,并将其作为服务部署在另一个Pod中。 此外,还会创建第三个部署,该部署运行独立的无状态Celery工作者以使用大型任务。 第三次部署可以轻松