django-celery排队与结果检索

Question

我们使用django-celery作为应用程序。我对我们遵循的工作流程持怀疑态度。

目前，当用户单击链接时，任务将使用以下代码进行排队

result=retrieveDatausingWorker.apply_async(args=[type,dictParamList]) 

然后视图返回一个页面，该页面向user.This页面显示等待消息，还返回当前任务的task_id，然后使用ajax调用将任务id发送到服务器，我正在检查当前排队任务的状态。

代码

def getDocketDownloaderWorkerStatus(request):

 if request.method=="POST":         

     task_id=request.POST.get('task_id')
     result = AsyncResult(task_id)
     if result:
         state, retval = result.state, result.result
         response_data = dict(id=task_id, status=state, result=safe_str(retval))            

     if (state=='SUCCESS' or state=='FAILURE') and ('task_id' in request.session):
         del request.session['task_id']             
     return HttpResponse(serialize(response_data), mimetype="application/json")

此ajax函数将每隔5秒调用一次，直到服务器返回status=='SUCCESS‘和result。

这条路对吗？或者使用result = AsyncResult(task_id)的成本很高

我使用数据库作为我的代理。数据库托管在xeround云数据库中。每当我运行worker时，CPU使用率超过95%，我们收到关于这一点的严重错误消息。

Answer 1

您使用的检查方法是正确的，但是并不推荐使用数据库作为代理。

我建议改用Redis或RabbitMQ (对于你的情况来说，RabbitMQ可能有点过头了)。这应该会大大降低cpu的使用率。