요청을 받으면 백그라운드에서 장기 실행 스크립트를 실행하고 싶습니다. subprocess
에 대해 읽었지만 요청이 시간 내에 완료 될 수 있도록 호출이 비 차단이어야합니다. 다른 post에서 제안하지만 분명히 내 if pid == 0
부분으로 흐르지 않고 제어로django : os.fork를 사용하여 백그라운드 프로세스 만들기?
def controlCrawlers(request):
if request.method == 'POST' and 'type' in request.POST and 'cc' in request.POST:
if request.POST['type'] == '3':
if request.POST['cc'] == '1':
try: #temp solution checking socket is occupied by trying to connect
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('localhost',DISCOVERY_SOCKET))
s.close()
return HttpResponse(simplejson.dumps({'success':0,'message': 'Socket is occupied. Possible crawler is already running'}), \
mimetype='application/json')
except:
pid = os.fork()
if pid == 0:
#f = open('/home/foo/django','a')
#f.write('abc')
# f.close()
path = os.path.join(os.path.dirname(__file__), 'blogcontentReader/blogpost_crawler.py')
os.system("python %s" %path)
os._exit(0)
return HttpResponse(simplejson.dumps({'success':1,'message': 'Running...'}), \
mimetype='application/json')
나는 os.fork를 사용했다. 이 작업을 수행하는 올바른 방법입니까?
가'보십시오 스크립트를 실행 cronjob에를 설정 한 경우 request.method == 'POST'와 request.POST.get ('유형') == '3'과 request.POST.get ('CC ') =='1 ':'두 개의 들여 쓰기 레벨을 저장하십시오. 또한,'try'로 돌아 오기 때문에,'except : pass'를하고 그 내용을 들여 쓰기 레벨 밖으로 옮기십시오. 모든 것을 더 읽기 쉽게 만듭니다. – agf
'subprocess.Popen'이 작동하지 않는 이유를 모르겠습니다. 실행이 계속되는 것을 멈추지 않습니까? – agf
@agf, yea, 내 게시물의 링크에서 보는 것부터 자식 프로세스의 실행이 완료 될 때까지 차단됩니다. – goh