AsyncMySQLClient

class deepfos.db.AsyncMySQLClient(*args, **kwargs)

异步 MySQL 客户端

适用于需要在协程中执行 SQL、查询 DataFrame 或把 DataFrame 批量写入数据表的场景。

方法

exec_sqls(sqls[, table_info])

以事务执行多句sql

insert_df(dataframe[, element_name, …])

DataFrame 的插入数据表

query_dfs(sqls[, table_info])

执行sql查询语句

属性

convertor