script inserir async python

insert_async_python.py

from aiofile import AIOFile, LineReader
import pymysql.cursors
import asyncio

conn = pymysql.connect(
    host="localhost",
    user="root",
    password="A1c2!!1aaa2",
    db="dbl_matriz",
    charset="utf8",
    cursorclass=pymysql.cursors.DictCursor,
)

file_path = input("Digite o caminho do arquivo: ")

async def main():
    with conn.cursor() as cursor:
        async with AIOFile(file_path, "r") as f:
            async for line in LineReader(f):
                data = line.split("    ")
                data[2] = data[2].replace("\r", "")
                data[2] = data[2].replace("\n", "")
                data[2] = data[2].strip()
                print(f"Inserindo registro {data[0]}")
                sql = "INSERT INTO `mt` (`numero`, `combinacao`, `quina`) VALUES (%s, %s, %s)"
                try:
                    cursor.execute(sql, (data[0], data[1], data[2]))
                    conn.commit()

                except Exception as e:
                    print(f"Erro: ocorreu um erro ao inserir linha {data[0]} erro: {e}")


loop = asyncio.get_event_loop()
loop.run_until_complete(main())
conn.close()