Ошибка при асинхронном запросе MYSQL?

Question

[pphhpphh]

При быстрых, постоянных запросах получаю ошибку
RuntimeError: read() called while another coroutine is already waiting for incoming data

await self.cursor.execute(*args)
q = await self.cursor.fetchone()

Подключение к базе данных

async def register_base(host, port, user, password, db):
    db = await connect(user=user, password=password, host=host, port=port, database=db, use_pure=True)
    cursor = await db.cursor()
    return db, cursor

class Base():
    def __init__(self, host, port, user, password, db, run_func=None):
        loop = asyncio.get_event_loop()
        self.db, self.cursor = loop.run_until_complete(register_base(host, port, user, password, db))

        if run_func is not None: loop.run_until_complete(run_func(self))
    async def __get_dict_from_request(self, *args, q):
        args = str(args[0])
        s = {}
        splits = args.split('SELECT')[1].split('FROM')[0].split(',')
        for c in range(len(splits)):
            j = splits[c].replace(' ', '').replace(".", "_").replace('`', '')
            if len(j.split('(')) >= 2: j = j.split('(')[1].replace(')', '')
            s[j] = q[c]
        return s

    async def fetchone(self, *args, dict=False):
        await self.cursor.execute(*args)
        q = await self.cursor.fetchone()

        if dict is True and q is not None:
            s = await self.__get_dict_from_request(*args, q=q)
            return s
        return q

    async def fetchall(self, *args, dict=False):
        await self.cursor.execute(*args)
        q = await self.cursor.fetchall()
        if dict is True:
            s = []
            for j in q:
                s_ = await self.__get_dict_from_request(*args, q=j)
                s.append(s_)
            return s
        return q

    async def execute(self, *args):
        await self.cursor.execute(*args)
        return True

    async def commit(self):
        await self.conn.commit()
        return True

Comments

[d'Ivan]

Покажи лог с ошибкой read()

Answer 1

[Vindicar]

Попробуй создавать курсор на каждый запрос, а не переиспользовать один и тот же.

Comments

[Everything_is_bad]

еще напрягает loop.run_until_complete в init, лучше уж явно, после создания экземпляра класса, вызвать отдельный async метод или обернуть всё это в classmethod, чем делать такое, большая вероятность какие-то побочные эффекты получить.

[pphhpphh]

Пробовал, не помогло

[pphhpphh]

Everything_is_bad, Возможно это не правильно, но я не знаю как сделать лучше, можете пожалуйста показать как правильно? Это просто работало раньше с aiosqlite, поэтому вопросами не задавался