用途:面向建筑行业数据场景,把重复的手工数据处理任务自动化,构建 ETL 管道与带任务依赖的 DAG 工作流,减少系统间数据不一致与人工出错,并提供执行记录。
主要能力:以 WorkflowAutomation 类为核心,支持创建/导出工作流定义、添加任务、设置调度(小时/日/周/月)、按依赖做拓扑排序确定执行顺序、任务重试与超时配置、执行结果统计与历史查询。内置任务处理器包括 extract_csv、extract_excel、transform_filter、transform_aggregate、transform_join、load_csv、validate_schema、notify_email,并可通过 register_handler 注册自定义处理器。可生成 Airflow DAG 代码。
使用方式:先实例化 WorkflowAutomation("项目名"),用 create_workflow 创建工作流,用 add_task 添加 WorkflowTask(指定 task_id、task_type、config、dependencies),再调用 execute_workflow 执行;可用 set_schedule 设置周期调度,用 export_workflow_definition 或 generate_airflow_dag 导出定义。
适用场景:建筑项目成本数据的定期抽取、清洗、聚合、合并与加载,以及数据校验和通知等重复性任务。
限制:资料未提供安装方式、依赖版本、部署环境、收费与价格信息;notify_email 为模拟实现,未说明真实邮件发送;调度与监控的具体运行机制、并发与持久化能力暂未提供。