从ADF调用的雪花存储过程

Question

代码如下：

try {
    var xxxx = 
    INSERT INTO LOG.yyyy (            
        LOAD_SCHEMA,
        LOAD_TABLE,
        RAW_SCHEMA,
        RAW_TABLE,
        EXTRACT_ROW_COUNT,
        LOAD_ROW_COUNT,
        LOAD_LATEST_RECORD_ROW_COUNT,
        RAW_ROW_COUNT
    )
    SELECT
        '${LOG_TIMESTAMP}',
        IFF('${PHASE}' = 'undefined', CAST(NULL AS VARCHAR), '${PHASE}'),= 'undefined', CAST(NULL AS VARCHAR), '${EXTRACTfined', CAST(NULL AS VARCHAR), '${LOAD_SCHEMA}'),
        IFF('${LOAD_TABLE}' = 'undefined', CAST(NULL AS VARCHAR), '${LOAD_TABLE}'),           
        IFF('${EXTRACT_ROW_COUNT}' = 'undefined', CAST(NULL AS NUMBER), '${EXTRACT_ROW_COUNT}'),
        IFF('${LOAD_ROW_COUNT}' = 'undefined', CAST(NULL AS NUMBER), '${LOAD_ROW_COUNT}'),
        IFF('${LOAD_LATEST_RECORD_ROW_COUNT}' = 'undefined', CAST(NULL AS NUMBER), '${LOAD_LATEST_RECORD_ROW_COUNT}'),
        IFF('${RAW_ROW_COUNT}' = 'undefined', CAST(NULL AS NUMBER), '${RAW_ROW_COUNT}');`;
    snowflake.execute({sqlText: xxxx});        
    return `Succeeded`;
}
catch (err) {
    throw `Failed to insert data change to log, error: ${err}`;
};

Answer 1

Azure data Factory目前不支持活动中的抛出错误。

作为一种解决办法，您可以将查找活动的输出值（SP返回值）传递给if condition活动。

>

添加一个活动以显式使管道失败（例如：添加web活动并调用无效的REST API）。