Produits Entr'ouvert » Mandaye

import multiprocessing

    result = None

    waiting_time = getattr(settings, 'PHANTOM_JS_WAITING_TIME', 10)

    def run(send_end):

        phantom = subprocess.Popen([

            settings.PHANTOM_JS_BINARY,

            '--ignore-ssl-errors=yes', '--ssl-protocol=any',

            os.path.join(settings.BASE_DIR, 'mandayejs', script)],

            close_fds=True,

            stdin=subprocess.PIPE,

            stdout=subprocess.PIPE

        )

        stdout, stderr = phantom.communicate(json.dumps(data))

        try:

            result = json.loads(stdout)

        except (ValueError,):

            result = {"result": "failure, couldn't decode JSON"}

            logger.error(stdout)

        if result.get('stderr', None):

            logger.warning(result['stderr'])

        send_end.send(result)

    recv_end, send_end = multiprocessing.Pipe(False)

    process = multiprocessing.Process(target=run, args=(send_end,))

    process.start()

    process.join(waiting_time)

    if process.is_alive():

        process.terminate()

        logger.error("Phantomjs process stalled with conetext : %s " % data.pop('locators'))

        result = {'result': 'failure'}

    else:

        result = recv_end.recv()