未从就绪状态中删除的芹菜拍打处理过的邮件

我的芹菜节拍定义为:

@periodic_task(run_every=(crontab(minute='*/15')),name='threshold_monitor',ignore_result=True,queue='default',options={'queue': 'default'})
def threshold_monitor():
     #Threshold check login

Celery通过以下方式进行监督:

celery -A ProjectName beat --loglevel=info

该任务每15分钟执行一次很好,但未如预期那样从芹菜队列中删除。 RabbitMq中的数量一直在增长。这是预期的行为吗?如果没有,该如何解决。

其他芹菜设置:

CELERY_RESULT_BACKEND = 'rpc'

CELERY_ACKS_LATE = True

CELERY_IGNORE_RESULT = True

CELERY_TASK_IGNORE_RESULT = True

CELERYD_PREFETCH_MULTIPLIER = 1

CELERY_TASK_DEFAULT_QUEUE = 'default'

CELERY_TASK_ALWAYS_EAGER = False

CELERYD_TASK_TIME_LIMIT = 60

RabbitMQ队列屏幕快照:请注意,默认的队列项目已执行并释放,但芹菜仍在增长。

未从就绪状态中删除的芹菜拍打处理过的邮件

未从就绪状态中删除的芹菜拍打处理过的邮件

dunhuangheisha 回答:未从就绪状态中删除的芹菜拍打处理过的邮件

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3168910.html

大家都在问