Tornado RDBMS統合

Question

通常、RDBMSドライバはブロックされていますが、Tornadoはブロックされていないサーバです。これは、SQLクエリが終了するまでIOLoopがブロックされるため、CRUD操作を実行する際に非同期的に非同期的に使用されます。

（ACIDのために）RDBMSをデータベースとして使用するプロジェクトに取り組んでいますが、いくつかの機能的な機能（つまりプッシュ通知）を編成するためにWebソケットが必要です。通常のRESTとWebソケットは1つのアプリケーションで実装できます。

私は（：https://gist.github.com/methane/2185380こちら）：このスニペットを見つけたウェブの閲覧

import time 

from tornado.concurrent import run_on_executor 
from concurrent.futures import ThreadPoolExecutor # `pip install futures` for python2 

MAX_WORKERS = 4 


class Handler(tornado.web.RequestHandler): 
    executor = ThreadPoolExecutor(max_workers=MAX_WORKERS) 

    @run_on_executor 
    def background_task(self, i): 
     """ This will be executed in `executor` pool. """ 
     time.sleep(10) 
     return i 

    @tornado.gen.coroutine 
    def get(self, idx): 
     """ Request that asynchronously calls background task. """ 
     res = yield self.background_task(idx) 
     self.write(res) 

は何それは基本的にないのは、別のスレッドにCRUDタスクをプッシュします。 私の質問は、これは、非同期HTTPサーバーを使用している場合、RDBMSドライバーをブロックするというデフォルトのアプローチですか？これらのブロックボトルネックを最小限に抑える他の方法はありますか？非同期サーバーでブロッキングRDBMSドライバーを使用するのも合理的ですか？

Answer 1

TornadoでRDBMSを処理する方法は複数あります。

Tornadoで非同期処理を実行するためのさまざまなDBのライブラリがあります。 https://github.com/tornadoweb/tornado/wiki/Links

GEventを使用して、トルネードで非同期データベースアクセスを取得することもできます。

別のオプションは、次のようなトルネードとのpython3非同期IOライブラリを使用することです：あなたは別のオプションを指摘したように https://aiopg.readthedocs.io/en/stable/

他の場所でDBの負荷をオフロードすることです。 ZeroMQやRabbitMQ、複数のスレッド、複数のプロセス、別のボックスのAPIなどのメッセージキューを使用できます。

標準のブロッキングデータベースアクセスメカニズムを使用することもできますが、それでもトルネードでは機能しますが、戻ってくるまでブロックされるだけです。これは問題でも問題ではないかもしれません。

私は昨年PyOhioで桃子、Aiopg、およびGEventについての講演を行いました： http://pyvideo.org/video/3698/from-synchronous-to-asynchronous-postgres-with-to