Clickhouse中的异步数据获取不起作用

Question

from datetime import datetime

import asyncio
from aiohttp import ClientSession
from aiochclient import ChClient


async def some_query(client, sql):
     print(f"Start {i} - {datetime.now()}")      
     all_rows = await client.fetch(sql, json=True)
     print(f"End {i}")
        
     return all_rows

async def compete():
    tasks = []
    async with ClientSession() as session:
        my_client = ChClient(session, url=f'http://{USER}:{PWD}@{HOST}:{PORT}/', 
                             database=DB)
        for i in range(1, 3):
            task = asyncio.create_task(self.some_query(my_client, i, "SELECT * FROM table"))
            tasks.append(task)
            
        await asyncio.gather(*tasks)

asyncio.run(compete())

该代码可以工作，但是当请求到达数据库时，它会在那里同步执行。 例如，180秒完成3个请求，无论同步还是异步都没有区别。 我是否正确地认为，如果异步运行代码，那么 3 个请求应该在大约 60 秒内完成？