在运行aiohttp循环之前创建数据库连接

import aiohttp
import asyncio
import aiomysql

# 配置数据库连接参数
db_config = {
    'host': 'localhost',
    'port': 3306,
    'user': 'username',
    'password': 'password',
    'db': 'database_name',
}

# 创建数据库连接池
async def create_pool():
    pool = await aiomysql.create_pool(**db_config)
    return pool

# 创建数据库连接
async def create_connection():
    pool = await create_pool()
    conn = await pool.acquire()
    return conn

# 将数据库连接设置为全局变量
async def init_db():
    global db_conn
    db_conn = await create_connection()

# 运行aiohttp循环
async def main():
    app = aiohttp.web.Application()
    app.router.add_get('/', handle_request)
    runner = aiohttp.web.AppRunner(app)
    await runner.setup()
    site = aiohttp.web.TCPSite(runner, 'localhost', 8080)
    await site.start()

async def handle_request(request):
    # 在处理请求时可以使用全局的db_conn进行数据库操作
    # ...

# 启动系统
async def start():
    await init_db()
    await main()

loop = asyncio.get_event_loop()
loop.run_until_complete(start())