芹菜不是每次都处理任务

Question

我有以下芹菜的配置

celery = Celery(__name__,
broker=os.environ.get('CELERY_BROKER_URL', 'redis://'),
backend=os.environ.get('CELERY_BROKER_URL', 'redis://'))
celery.config_from_object(APP_SETTINGS)
ssl = celery.conf.get('REDIS_SSL', True)
r = redis.StrictRedis(REDIS_BROKER, int(REDIS_BROKER_PORT), 0, 
charset='utf-8', decode_responses=True, ssl=ssl)
db_uri = celery.conf.get('SQLALCHEMY_DATABASE_URI')
@celery.task 
def process_task(data):
#some code here

我正在API端点内调用流程任务，如process_task.delay(data)

有时是处理任务，有时不是。

有人能帮我解决这个问题吗？

我正在运行类似celery worker -A api.celery --loglevel=DEBUG --concurrency=10的工作程序

Answer 1

一旦所有工作进程都很忙，新任务就会出现在队列中，等待下一个空闲的工作进程启动任务。这很可能就是为什么你认为这是"不是每次都在处理任务"。浏览Celery文档的监控和管理部分，了解如何监控您的Celery集群。对于初学者，请执行celery worker -A api.celery inspect active以检查当前正在运行的任务。