python uvloop事件循环库使用功能示例探究

pip install uvloop

import asyncio
import uvloop
from aiohttp import web

async def handle(request):
    return web.Response(text="Hello, uvloop!")

async def main():
    app = web.Application()
    app.router.add_get('/', handle)
    
    runner = web.AppRunner(app)
    await runner.setup()
    site = web.TCPSite(runner, 'localhost', 8080)
    await site.start()

    print("Server started at http://localhost:8080")
    await asyncio.Event().wait()  # 挂起服务器，直到它被关闭

# 设置uvloop为默认事件循环
uvloop.install()

# 运行我们的主函数
asyncio.run(main())

pip install aiopg

import asyncio
import uvloop
import aiopg

dsn = 'dbname=mydatabase user=myuser password=mypassword'

async def go():
    async with aiopg.create_pool(dsn) as pool:
        async with pool.acquire() as conn:
            async with conn.cursor() as cur:
                await cur.execute("SELECT * FROM users WHERE id=1")
                user = await cur.fetchone()
                print(user)

# 设置uvloop为默认事件循环
uvloop.install()

# 运行异步查询函数
asyncio.run(go())