Запуск 2 бутылочных приложений одновременно с помощью multiprocess.Pool - PullRequest
Новая
       7

Запуск 2 бутылочных приложений одновременно с помощью multiprocess.Pool

0 голосов
/ 12 декабря 2018

Я попал в ситуацию, когда мне нужно запускать 2 приложения (на другом порту) одновременно.Я понимаю, что это, вероятно, не лучшая идея / дизайн, но, пожалуйста, потерпите меня.

Основная проблема в том, что bottle.run блокирует.Очевидным обходным решением было использование multiprocessing.Pool, но я думаю, что это не так очевидно.

Это работает (работает одно и то же приложение на 2 разных портах): 

from multiprocessing import Pool
import bottle

app = bottle.Bottle()

@app.route('/')
def index():
    return 'hi'


def run_app(port):
    bottle.run(port=port)


if __name__ == '__main__':
    pool = Pool(2)

    ps = [pool.apply_async(run_app, (port,))
          for port in (8081, 8082)]

    [p.get() for p in ps]  # YES, using a list comp for side-effect

Вывод 

Bottle v0.12.15 server starting up (using WSGIRefServer())...
Listening on http://127.0.0.1:8081/
Hit Ctrl-C to quit.

Bottle v0.12.15 server starting up (using WSGIRefServer())...
Listening on http://127.0.0.1:8082/
Hit Ctrl-C to quit.

Однако попытка использовать 2 разных приложения просто не работает. 

from multiprocessing import Pool
import bottle

app1 = bottle.Bottle()
app2 = bottle.Bottle()
apps = [app1, app2]


@app1.route('/')
def index_app1():
    return 'app1'


@app2.route('/')
def index_app2():
    return 'app2'


def run_app(app, port):
    bottle.run(app, port=port)


if __name__ == '__main__':
    pool = Pool(2)

    ps = [pool.apply_async(run_app, (app, port))
          for app, port in zip(apps, [8081, 8082])]

    [p.get() for p in ps]

Это выводит 

Traceback (most recent call last):
  File "test.py", line 29, in <module>
    [p.get() for p in ps]
  File "test.py", line 29, in <listcomp>
    [p.get() for p in ps]
  File "D:\Python37\Lib\multiprocessing\pool.py", line 657, in get
    raise self._value
  File "D:\Python37\Lib\multiprocessing\pool.py", line 431, in _handle_tasks
    put(task)
  File "D:\Python37\Lib\multiprocessing\connection.py", line 206, in send
    self._send_bytes(_ForkingPickler.dumps(obj))
  File "D:\Python37\Lib\multiprocessing\reduction.py", line 51, in dumps
    cls(buf, protocol).dump(obj)
AttributeError: Can't pickle local object 'ConfigDict.__init__.<locals>.<lambda>'

ОБНОВЛЕНИЕ

Изменение первого примера на: 

.
.
.

def run_app(app, port):
    # instead of bottle.run(port=port) which uses default_app()
    app.run(port=port) # or bottle.run(app=app, port=port)
.
.
.
ps = [pool.apply_async(run_app, (app, port))
      for port in (8081, 8082)]

также вызывает ту же ошибку

1 Ответ

0 голосов
/ 12 декабря 2018

Получается, что подходящим способом решения этой проблемы является использование Bottle.mount.Это прекрасно работает: 

import bottle

parent_app = bottle.Bottle()
child_app = bottle.Bottle()


@parent_app.route('/')
def index_app1():
    return 'parent_app'


@child_app.route('/')
def index_app2():
    return 'child_app'


if __name__ == '__main__':
    parent_app.mount('/child_app/', child_app)
    parent_app.run()
...