ReconciliationMsEngine

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

对账任务引擎

用于对账任务的全生命周期管理，包括任务创建、执行、关闭、手动打标以及 取消匹配等操作，适合在复杂对账场景中精细控制每个任务的状态流转。

快速开始

from deepfos.element.reconciliation import ReconciliationMsEngine

ms_engine = ReconciliationMsEngine('my_recon_task')

# 按 POV 执行对账
ms_engine.execute(pov={"year": "2024", "period": "3"})

# 手动创建任务后再执行
task_id = ms_engine.create_task(pov={"year": "2024", "period": "3"})
ms_engine.exec_task(task_id=task_id)

参数

• element_name – 元素名

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

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

提示

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

方法

async_check_exist(ele_name[, ele_type, …])	异步查询元素是否存在
cancel_by_hand(task_id, type[, …])	手工取消暂挂或者不参与匹配
cancel_matched(task_id, match_ids)	取消匹配
check_exist(ele_name[, ele_type, folder, …])	查询元素是否存在
close_task(*task_ids)	关闭对账任务
create_task([pov, auto_run, params, …])	创建对账任务
delete_task(*task_ids)	删除对账任务
exec_task(task_id[, pov, params, task_name])	执行对账
execute(pov[, params, task_id, task_name])	创建对账任务并执行
mark_by_hand(task_id, type, reason[, …])	手工标记对账集
open_task(task_id)	打开对账任务
wait_for(attr)	异步等待成员变量

属性

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