在Azure Data Factory(ADF)中如何通过管道参数筛选管道运行记录
Azure Data Factory 管道运行记录按传入参数筛选方案
ADF原生可视化运行报告目前未内置管道传入参数的直接筛选维度,你可以通过以下三种方式实现该需求:
- 调用ADF监控API拉取数据后过滤
使用Pipeline Runs - Query By FactoryREST接口,接口返回的运行记录包含完整的parameters字段,你可以拉取指定时间范围的运行数据后,自行按参数值做二次过滤。 - 导出诊断日志到Log Analytics做自定义查询
提前配置ADF诊断日志同步到Log Analytics工作区,管道运行相关数据会存储在ADFPipelineRun表中,你可以通过KQL语句直接按参数筛选,参考示例:ADFPipelineRun | where TimeGenerated > ago(7d) | where PipelineName == "目标管道名称" | where parse_json(Parameters).paramName == "目标参数值" | project RunStart, RunId, Status, Parameters, DurationMs - 管道运行时打自定义标签实现原生UI筛选
在触发管道运行时,将需要筛选的参数值作为自定义标签(Tag)附加到运行实例上,后续在ADF原生运行报告中可直接通过标签维度筛选对应运行记录,该方案无需依赖额外服务,适配原生筛选逻辑,成本最低。
内容的提问来源于stack exchange,提问作者Ahmed AlZabidi
相关产品推荐
相关产品推荐

