AsyncReconciliationEngine

class deepfos.element.reconciliation.AsyncReconciliationEngine(element_name: str, folder_id: str = None, path: str = None, server_name: str = None)

对账引擎—数据集

用于对账场景下抽取业务数据、确认/取消对账结果以及删除数据集记录。

快速开始

from deepfos.element.reconciliation import ReconciliationEngine

engine = ReconciliationEngine('ds_bank')

# 抽取数据（以默认参数执行）
engine.extract_data()

# 抽取并自动确认
engine.extract_data(auto_confirm=True)

# 确认指定 ID 的对账记录
engine.confirm('id_001', 'id_002')

# 删除数据集记录
engine.delete('id_001')

参数

• element_name – 元素名

• folder_id – 元素所在的文件夹id

• path – 元素所在的文件夹绝对路径

提示

如果不提供folder_id和path，将会使用元素名和元素类型进行全局搜索。 如果找到 唯一匹配 的元素，那么一切正常，否则将会报错。

方法

async_check_exist(ele_name[, ele_type, …])	异步查询元素是否存在
cancel(*ids)	取消批次
check_exist(ele_name[, ele_type, folder, …])	查询元素是否存在
confirm(*ids)	确认批次
delete(*ids)	删除批次
extract_data([param, cleanup, auto_confirm, …])	抽取业务数据
wait_for(attr)	异步等待成员变量

属性

api	同步 API 对象
async_api	异步 API 对象
element_info	元素信息
element_type	元素类型