c# - 调用目标抛出异常 - 在 Visual Studio 中执行 .dtsx 文件时

Question

我开发了一个 ssis 包，我有一个脚本，它从 .txt 文件中获取一些文本命令，将它们存储在变量中，我使用这些变量来查看下一步要做什么以及要执行哪个 dft。

当我转到 .dtsx 文件时 --> 右键单击​​ --> 执行 --> 我收到错误消息“调用的目标已抛出异常。”

然而，当我停止运行包并尝试重新执行它时，它运行成功。

我尝试将它部署到 Integration Services Catalogs，它抛出了我在报告文件中看到的相同错误

Script task error: exception has been thrown by the target of an invocation

varERMLoadTxt 保存流读取器读取的文本文件路径

public void Main()
        {
            // TODO: Add your code here
            string path = Dts.Variables["User::varERMLoadTxt"].Value.ToString();
            using (StreamReader sr = File.OpenText(path))
            {
                string line = File.ReadAllText(path);
                string[] lines = line.Split(',');
                if(lines[0].Equals("load", StringComparison.CurrentCultureIgnoreCase))
                Dts.Variables["User::varIsLoad"].Value = true;
                else if (lines[0].Equals("update", StringComparison.CurrentCultureIgnoreCase))
                    Dts.Variables["User::varIsUpdate"].Value = true;
                Dts.Variables["User::varCommand"].Value = lines[0].ToString();
                Dts.Variables["User::varAnalysisDate"].Value = lines[1].ToString();
                sr.Close();



            }
            Dts.TaskResult = (int)ScriptResults.Success;
        }

enum ScriptResults
{
    Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
    Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
};

Answer 1

我有3个建议:

1. 使用 try ... catch block 和 Dts.FireError 方法读取真正的异常:

• Error: 0x1 at XX: Exception has been thrown by the target of an invocation

1. 打开文件前检查文件是否存在
2. 检查变量名是否正确(注意变量名区分大小写)

整个代码应该是这样的

public void Main()
        {
        try{    

                string path = Dts.Variables["User::varERMLoadTxt"].Value.ToString();
            
        if (File.Exists(path))
        {
            using (StreamReader sr = File.OpenText(path))
                {
                string line = File.ReadAllText(path);
                    string[] lines = line.Split(',');
    
                    if(lines[0].Equals("load", StringComparison.CurrentCultureIgnoreCase))
                        Dts.Variables["User::varIsLoad"].Value = true;
                else if (lines[0].Equals("update", StringComparison.CurrentCultureIgnoreCase))
                    Dts.Variables["User::varIsUpdate"].Value = true;
                
            Dts.Variables["User::varCommand"].Value = lines[0].ToString();
                    Dts.Variables["User::varAnalysisDate"].Value = lines[1].ToString();
                    sr.Close();
                     }
            }   

            Dts.TaskResult = (int)ScriptResults.Success;    

        }catch(Exception ex){

            Dts.FireError(0,"An error occured", ex.Message,String.Empty, 0);
                Dts.TaskResult = (int)ScriptResults.Failure;
 
            }

        }

enum ScriptResults
{
    Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
    Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
};