import asyncio from sqlor.dbpools import DBPools dbs={ "tasks":{ "driver":"aiomysql", "async_mode":True, "coding":"utf8", "dbname":"tasks", "kwargs":{ "user":"test", "db":"tasks", "password":"test123", "host":"localhost" } }, "aiocfae":{ "driver":"aiomysql", "async_mode":True, "coding":"utf8", "dbname":"cfae", "kwargs":{ "user":"test", "db":"cfae", "password":"test123", "host":"localhost" } }, "cfae":{ "driver":"mysql.connector", "coding":"utf8", "dbname":"cfae", "kwargs":{ "user":"test", "db":"cfae", "password":"test123", "host":"localhost" } } } loop = asyncio.get_event_loop() pool = DBPools(dbs,loop=loop) async def testfunc(): @pool.runSQL def sql(db,ns,callback): return { "sql_string":"select * from product", } x = await sql('cfae',{},print) async def testfunc1(): @pool.runSQL def sql(db,ns,callback): return { "sql_string":"select * from timeobjects", } print('testfunc1(),test tasks database select') x = await sql('tasks',{},print) loop.run_until_complete(testfunc()) loop.run_until_complete(testfunc1())