2

我们使用 django-celery 进行应用。我对我们遵循的工作流程有疑问。

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

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

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

代码

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 = AsyncResult(task_id)

我使用数据库作为我的经纪人。该数据库托管在 xeround 云数据库中。当我运行一个工作线程时，CPU 使用率会超过 95%，我们会收到有关此的严重错误消息。

4

1 回答 1

2

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

我建议切换到 Redis 或 RabbitMQ（RabbitMQ 对您的情况来说可能是多余的）。这应该会大大减少cpu的使用。

于 2012-09-03T09:26:02.490 回答