aiomysql连接池实现大批量数据插入

可以使用 aiomysql 的连接池来实现大批量数据插入。首先，需要创建一个连接池对象，然后在需要插入数据的时候，从连接池中获取一个连接，执行插入操作，最后释放连接。这样可以避免频繁地创建和销毁连接，提高插入数据的效率。

以下是一个简单的示例代码：

import asyncio
import aiomysql

async def insert_data(conn, data):
    async with conn.cursor() as cur:
        await cur.execute("INSERT INTO table_name (column1, column2) VALUES (%s, %s)", data)

async def main():
    pool = await aiomysql.create_pool(host='localhost', port=3306,
                                      user='user', password='password',
                                      db='database', maxsize=10)
    data_list = [(1, 'data1'), (2, 'data2'), (3, 'data3')] # 数据列表
    async with pool.acquire() as conn:
        tasks = [insert_data(conn, data) for data in data_list]
        await asyncio.gather(*tasks)

    pool.close()
    await pool.wait_closed()

if __name__ == '__main__':
    asyncio.run(main())

在这个示例中，我们首先创建了一个连接池对象，然后定义了一个插入数据的函数 insert_data，该函数接受一个连接对象和数据作为参数，执行插入操作。在主函数中，我们创建了一个数据列表，然后使用 asyncio.gather 并发执行多个插入任务，最后关闭连接池。

注意，这只是一个简单的示例代码，实际应用中还需要考虑异常处理、连接池的配置等问题。