在多进程模式下使用 aiomysql 运行 tornado

Question

我一直在尝试使用以下代码在多进程模式下使用 aiomysql 运行 tornado

@asyncio.coroutine
def get_mysql_connection(loop):
    return (yield from aiomysql.create_pool(host=host,port=3306,user=user, password=pass, db=db, loop=loop))


if __name__ == "__main__":
    tornado.platform.asyncio.AsyncIOMainLoop().install()
    ioloop = asyncio.get_event_loop()
    mysql = ioloop.run_until_complete(get_mysql_connection(ioloop))
    options.parse_config_file("app.conf")
    app = make_app(mysql)
    print('listening on %s:%s...' %(options.host, options.port))
    server = tornado.httpserver.HTTPServer(app)
    server.listen(options.port)
    server.start(0) #this is my problem
    ioloop.run_forever()

但我不断收到以下错误

RuntimeError: Cannot run in multiple processes: IOLoop instance has already been initialized. You cannot call IOLoop.instance() before calling start_processes()

除了ioloop.start(0) 行之外，一切都运行良好，是否可以让aiomysql 和tornado 这两个库在多进程模式下正常工作？如果没有，我的其他选择是什么

Tornado 版本 4.4.2

python 版本 3.6.0

aiomysql 0.0.9版

Answer 1

如消息所述，只有在 IOLoop 初始化之前 才能派生工作进程。这对 AsyncIOMainLoop 来说有点微妙，因为您想尽早安装它。解决方案是按以下顺序启动您的程序：

tornado.options.parse_config_file(...)
socks = tornado.netutil.bind_sockets(options.port, options.host)
tornado.process.fork_processes(0)
tornado.asyncio.AsyncIOMainLoop().install()
# Initialize the rest of your app, create the HTTPServer, 
# and instead of listen() or start(), do
server.add_sockets(socks)

我的其他选择是什么

在我看来，最好使用像 supervisord 这样的外部进程管理器，而不是在您的应用程序中分叉多个进程。这避免了大多数这些初始化顺序陷阱。