Gbase8a实现python异步抽取数据

# pip install aiomysql  asyncio

import asyncio
import aiomysql
from GBaseConnector import connect, GBaseError

async def fetch_data(host, port, user, password, db, query): 
   conn = await aiomysql.connect(host=host, port=port, user=user, password=password, db=db) 
   async with conn.cursor() as cursor: 
       await cursor.execute(query) 
       return await cursor.fetchall()   
 

thedata=asyncio.run(fetch_data(
   host='192.168.56.195',
   port=5258,
   user='gbase',
   password='gbase20110531',
   db='ssbm',
   query="SELECT * FROM lineorder limit 3005")
   )