django-celeron结果的排队和检索

Question

我们使用django-celeron进行应用。我对我们遵循的工作流程表示怀疑。

当前，当用户点击链接时，任务将使用以下代码排队

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

则视图返回一个页面，该页面向用户显示等待消息。这个页面还返回当前任务的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秒调用一次，直到服务器返回状态=="成功"和结果。

这是正确的方式吗。或者使用result = AsyncResult(task_id) 是否昂贵

我使用数据库作为我的经纪人。该数据库托管在静电云数据库中。当我运行一个工人CPU使用率超过95%时，我们收到了关于这一点的严重错误消息。

Answer 1

您使用的是正确的检查方法，但并不建议将数据库用作代理。

我建议切换到Redis或RabbitMQ（对于您的情况，RabbitMQ可能有些过头了）。这应该会大大减少cpu的使用量。