首页 文章

Azure Data Factory v2如果活动始终失败

提问于
浏览
0

我目前正在努力使用Azure数据工厂v2 If活动始终失败,并显示以下错误消息:enter image description here

我设计了两个独立的管道,一个从本地SQL Server获取数据的完整快照(1333条记录),然后将数据加载到Azure SQL数据库中,另一条只从同一源获取delta .

两个管道独立执行时工作正常 .

然后我决定将这两个管道包装到一个父管道中,它将执行此操作:1 . 执行LookUp活动以检查Azure SQL数据库中的目标表是否有任何记录,基本选择计数(Request_ID)作为record_count来自target_table - 活动工作好的,我可以预览返回的记录数 .

2.将LookUp活动的输出传递给If活动,条件是如果record_count = 0,则父管道将调用完全加载管道,否则父管道将调用delta加载管道 .

这是实际的表达方式:
{@activity('lookup_sites_record_count').output.firstRow.record_count} == 0“

每当我尝试执行此父管道时,它都会失败并显示“活动失败:活动失败,因为内部活动失败”的上述消息 .

内部活动(即满载和增量负载管道)在独立触发时工作正常 .

我错过了什么?

提前谢谢了 :) .

mikhailg

Pipeline的JSON定义如下:

{
"name": "pl_remedyreports_load_rs_sites",
"properties": {
    "activities": [
        {
            "name": "lookup_sites_record_count",
            "type": "Lookup",
            "policy": {
                "timeout": "7.00:00:00",
                "retry": 0,
                "retryIntervalInSeconds": 30,
                "secureOutput": false
            },
            "typeProperties": {
                "source": {
                    "type": "SqlSource",
                    "sqlReaderQuery": "Select Count(Request_ID) As record_count From mdp.RS_Sites;"
                },
                "dataset": {
                    "referenceName": "ds_azure_sql_db_sites",
                    "type": "DatasetReference"
                }
            }
        },
        {
            "name": "If_check_site_record_count",
            "type": "IfCondition",
            "dependsOn": [
                {
                    "activity": "lookup_sites_record_count",
                    "dependencyConditions": [
                        "Succeeded"
                    ]
                }
            ],
            "typeProperties": {
                "expression": {
                    "value": "{@activity('lookup_sites_record_count').output.firstRow.record_count}==0",
                    "type": "Expression"
                },
                "ifFalseActivities": [
                    {
                        "name": "pl_remedyreports_invoke_load_sites_inc",
                        "type": "ExecutePipeline",
                        "typeProperties": {
                            "pipeline": {
                                "referenceName": "pl_remedyreports_load_sites_inc",
                                "type": "PipelineReference"
                            }
                        }
                    }
                ],
                "ifTrueActivities": [
                    {
                        "name": "pl_remedyreports_invoke_load_sites_full",
                        "type": "ExecutePipeline",
                        "typeProperties": {
                            "pipeline": {
                                "referenceName": "pl_remedyreports_load_sites_full",
                                "type": "PipelineReference"
                            }
                        }
                    }
                ]
            }
        }
    ],
    "folder": {
        "name": "Load Remedy Reference Data"
    }
}

}

1 回答

  • 1

    你的表达应该是:

    @equals(activity('lookup_sites_record_count').output.firstRow.record_count,0)
    

相关问题