我的芹菜节拍定义为:
@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队列屏幕快照:请注意,默认的队列项目已执行并释放,但芹菜仍在增长。