AsyncDeepModel¶

class deepfos.element.deepmodel.AsyncDeepModel(direct_access: bool = True, pg_dsn: str = None, **kwargs)¶

DeepModel元素

参数

direct_access – 是否使用直连模式，默认为True 会结合OPTION.edgedb.dsn是否有值决定是否使用直连模式，如无值，则仍为非直连模式直连模式下，会使用edgedb-python库直连edgedb server，否则会使用DeepModel组件API进行操作
pg_dsn – PG连接信息

方法

`async_check_exist`(ele_name[, ele_type, …])	异步查询元素是否存在
`check_exist`(ele_name[, ele_type, folder, …])	查询元素是否存在
`execute`(qls, **kwargs)	以事务执行多句ql
`get_object`(object_name[, raw])	获取指定对象名的对象
`insert_df`(object_name, data[, relation, …])	以事务执行基于DataFrame字段信息的批量插入数据
`insert_df_pg`(object_name, data[, …])	以事务直连pg执行基于DataFrame字段信息的批量插入数据
`query`(ql, **kwargs)	执行ql查询语句，得到序列化后的结果
`query_df`(ql, **kwargs)	执行ql查询语句
`query_object`(ql, **kwargs)	执行ql查询语句，得到原始结果返回
`start_transaction`([flatten])	开启事务
`update_df`(object_name, data[, relation, …])	以事务执行基于DataFrame字段信息的批量更新数据
`wait_for`(attr)	异步等待成员变量
`with_globals`(globals_)
`without_globals`(*global_names)

属性