如何解决Celery 任务在本地运行时正常关闭时重新排队到代理中,但尽管配置相同,但在 kubernetes 中丢失
我在 k8 pod 中运行了一个 celery。这是我的芹菜清单
apiVersion: apps/v1
kind: Deployment
metadata:
name: celery
labels:
deployment: celery
spec:
replicas: 2
selector:
matchLabels:
pod: celery
template:
metadata:
labels:
pod: celery
spec:
containers:
- name: celery
image: local_celery:latest
imagePullPolicy: Never
command: ['celery','-A','proj','worker','-E','-l','info',]
resources:
limits:
cpu: 50m
requests:
cpu: 50m
terminationGracePeriodSeconds: 25
我在 django settings.py 中的 Celery 配置是
CELERY_TASK_ACKS_LATE = True
CELERY_WORKER_PREFETCH_MULTIPLIER = 1
CELERY_BROKER_URL = 'redis://redis:6379'
CELERY_RESULT_BACKEND = 'django-db'
CELERY_WORKER_CONCURRENCY=1
CEELERY_TASK_REJECT_ON_WORKER_LOST=True
当我使用 celery 和 redis 作为消息代理运行一个简单的 django 应用程序时,当我执行 ctrl-C
以启动工作人员的热关机时,我的任务会重新排队到代理中。但是当同一个应用程序部署到 kubernetes 时,celery、django 和 redis 运行在 3 个不同的 pod 中
当 celery pod 正常终止时,我的任务不会重新排队回到 redis。我不明白为什么?在这两种情况下,我的 celery 设置都没有改变。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。