view Sphinx/source/plugins/python/multiprocessing-4.py @ 855:12f8932ee3a7

jobs update
author Alain Mazy <am@osimis.io>
date Wed, 08 Jun 2022 16:58:44 +0200
parents 6e02cd89eb6a
children
line wrap: on
line source

import json
import multiprocessing
import orthanc
import requests
import signal

TOKEN = orthanc.GenerateRestApiAuthorizationToken()

def SlaveProcess():
    r = requests.get('http://localhost:8042/instances',
                     headers = { 'Authorization' : TOKEN })
    return json.dumps(r.json())

def Initializer():
    signal.signal(signal.SIGINT, signal.SIG_IGN)

POOL = multiprocessing.Pool(4, initializer = Initializer)

def OnRest(output, uri, **request):
    answer = POOL.apply(SlaveProcess)
    output.AnswerBuffer(answer, 'text/plain')

orthanc.RegisterRestCallback('/computation', OnRest)