SuperAPI AI 工具集

airflow-dag

数据与分析

查看项目

更新于 10-15 20:33

技能介绍

用途:为建筑行业数据管道生成 Apache Airflow DAG,编排 ETL、数据校验与报表工作流,覆盖从 BIM 提取到成本报告的流程。

主要能力:提供 ConstructionDAGBuilder 构建器,可添加 Bash 任务、Python 可调用任务、文件传感器任务和分支任务,并通过 upstream/downstream 维护依赖;generate_dag_code 生成 Airflow DAG 的 Python 代码,save_dag 将代码写入指定路径。内置 ConstructionPipelineTemplates,包含三类模板:BIM 校验(等待模型文件、IFC 转换、规则校验、分支后生成报告或发送告警)、成本估算(提取 BIM、生成工程量、匹配成本库、计算估算、生成报告)、批量 CAD 转换(扫描文件后分别转换 RVT/IFC/DWG,汇总结果并归档输入文件)。

使用方式:以 Python 调用构建器或模板,例如 ConstructionDAGBuilder('my_pipeline', schedule='@daily') 添加任务后 generate_dag_code() 或 save_dag('/airflow/dags/my_pipeline.py');模板可通过 bim_validation_pipeline()、cost_estimation_pipeline()、batch_conversion_pipeline() 获取。默认参数包含 owner、retries=2、retry_delay 5 分钟、execution_timeout 2 小时等。

适用场景:建筑项目中的 BIM 模型校验、成本估算、多种 CAD 格式批量转换与报表生成等周期性数据管道。

限制:资料中未提供安装命令、具体依赖版本、平台支持范围与收费信息;示例中的外部可执行文件(如 RvtExporter.exe、IfcExporter.exe、DwgExporter.exe)与回调函数需按实际环境另行实现或配置,部分数据路径为示例值。