Singleton Verbindungen Pool für Aiohttp + Aiomysql (Python 3.5)

Question

Ich spiele mit Aiohttp + Aiomysql. Ich möchte dieselbe Verbindungspoolinstanz zwischen Anforderungsaufrufen freigeben.

Also ich erstelle eine globale Var und preinit es einmal in Corouting-Aufruf.

Mein Code:

import asyncio 
from aiohttp import web 
from aiohttp_session import get_session, session_middleware 
from aiohttp_session.cookie_storage import EncryptedCookieStorage 
from aiohttp_session import SimpleCookieStorage 
#from mysql_pool import POOL 
from aiomysql import create_pool 

M_POOL = None 

async def get_pool(loop): 
    global M_POOL 
    if M_POOL: return M_POOL 
    M_POOL = await create_pool(host='127.0.0.1', port=3306, user='user', password='user', db='test', loop=loop) 
    return M_POOL 


async def query(request): 
    loop = asyncio.get_event_loop() 
    pool = await get_pool(loop) 

    print(id(pool)) 
    async with pool.acquire() as conn: 
     async with conn.cursor() as cur: 
      await cur.execute("SELECT 42;") 
      value = await cur.fetchone() 
      print(value) 

    return web.Response(body=str.encode(str(value))) 


app = web.Application(middlewares=[session_middleware(SimpleCookieStorage())]) 
app.router.add_route('GET', '/query', query) 


web.run_app(app) 

Ist es convinient Weg, dies zu tun, oder vielleicht etwas besser sein?

Answer 1

Ich schätze stark globale Variablennutzung.

Bitte schauen Sie auf aiohttp demo für kanonisch Ansatz.

SiteHandler ist eine Klasse, die Websiteansichten implementiert.

Answer 2

Aber Sie haben Demos für einen Fall gegeben, wo request Objekt in Zugriff.

Ich habe das gleiche Problem mit aiohttp. In meiner Anwendung habe ich getan, um Teile der Module:
eins ist für Server-Funktionalität, und eins für Client (Crawler).

So in Server-Teil ist es ok, kann ich Benutzer request.app['dbpool']

Aber in Raupen Teil I db wollen Verbindungen zu und ich kann nicht sehen, Gründe für eine andere Pool-Verbindung Erstellung verwenden.