主页 / dba / 问题 / 225735
Accepted
Steve_Malcolm
Asked: 2018-12-25 10:58:30 +0800 CST

SSIS 容错数据连接

  • 772

我觉得一个人可能离这个人站得太近了。我继承了一个SSIS package有两个数据连接对象的。在OLE DB连接（执行工作）和ADO.NET连接（到不同的服务器）上进行日志记录。

ADO.NET 连接远端的服务器可能不稳定，我需要使日志记录容错。日志记录任务已经设置为在失败时不会使包失败，也不会使父包失败。然而，这个过程还没有那么远。包失败是因为连接失败，而不是因为任务失败。

这个包的逻辑路径是 Log Start > Do Stuff > Log Completion。在这个特定的例子中，Log Start 成功了，Do Stuff 也成功了。日志完成失败，因为服务器突然不可用。

SSIS 报告级别的错误消息是

日志状态完成错误：无法获取连接“Logging ADO NET”。连接可能配置不正确，或者您可能没有正确的权限来管理此连接。

欢迎所有建议。（谢谢，圣诞快乐）

ado.net sql-server-2016

1 个回答

  1. Best Answer

    不确定这是解决方案还是解决方法。无论哪种方式，它都解决了问题。我禁用了 SQL 任务并创建了一个脚本任务。连接发生在 try/catch 中。如果失败，流程将转到“不执行任何操作”的捕获块。随着成功和进展的继续，该包将完成。包含新脚本任务及其代码的屏幕图像。

    在此处输入图像描述

    #region Namespaces
using System;
using System.Data;
using System.Data.SqlClient;
using Microsoft.SqlServer.Dts.Runtime;
using System.Windows.Forms;
#endregion

namespace ST_4ddaab95fb4d46ef9521d651f5227575
{
[Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute]
    public partial class ScriptMain : 
Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
    {
    public void Main()
    {
        Package pkg = new Package();
        Variables vars = null;
        VariableDispenser vd = pkg.VariableDispenser;
        SqlConnection LoggingConn;
        SqlCommand LoggingCommand;
        vd.GetVariables(ref vars);
        try
        {
            LoggingConn = (SqlConnection)Dts.Connections["Logging ADO NET"].AcquireConnection(null);
            LoggingCommand = new SqlCommand("[etl].[usp_LogPackageStatus]", LoggingConn);
            LoggingCommand.CommandType = CommandType.StoredProcedure;
            LoggingCommand.Parameters.AddWithValue("@PackageID", vars["System::PackageID"].Value.ToString());
            LoggingCommand.Parameters.AddWithValue("@PackageName", vars["System::PackageName"].Value.ToString());
            LoggingCommand.Parameters.AddWithValue("@MasterExecutionID", vars["$Package::MasterExecutionID"].Value.ToString());
            LoggingCommand.Parameters.AddWithValue("@ExecutionID", vars["System::ExecutionInstanceGUID"].Value.ToString());
            LoggingCommand.Parameters.AddWithValue("@Status", vars["User::Status"].Value.ToString());
            LoggingCommand.Parameters.AddWithValue("@StartTime", vars["User::StartTime"].Value.ToString());
            LoggingCommand.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            //Do nothing

            //For Debugging
            //MessageBox.Show(ex.Message);
        }
        Dts.TaskResult = (int)ScriptResults.Success;
    }

    #region ScriptResults declaration
    enum ScriptResults
    {
        Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
        Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
    };
    #endregion
}

    }

    • 0

相关问题