我正在尝试通过我的应用程序的多重处理进行数据库连接。我假设我调用函数的地方发生了错误。这几天我一直在为多处理而苦苦挣扎。我从https://engineering.talentpair.com/django-multiprocessing-153dbcf51dab/找到了代码
我的代码如下
视图.py
from src.conf.multiproces import MultiProcess
class GridSearchAPI(generics.GenericAPIView):
@transaction.atomic
def post(self, request):
with MultiProcess() as mp:
mp.map(request)
returnData = mp.results()
if returnData['result']:
return Response(returnData, status=status.HTTP_200_OK)
else:
returnData["message"] = "no data found"
return Response(result, status=status.HTTP_400_BAD_REQUEST)
Run Code Online (Sandbox Code Playgroud)
多进程.py
from __future__ import print_function, absolute_import, unicode_literals
import time
try:
from Queue import Empty
except ImportError:
from queue import Empty
# from pathos import
from multiprocessing import Process,cpu_count, Manager
import logging
import traceback
from django import db
from django.conf import settings
from django.core.cache …Run Code Online (Sandbox Code Playgroud)