c# - studio - ¿Cómo ejecutar un paquete SSIS desde.NET?

execute package from c#

Question

Tengo un paquete SSIS que eventualmente también me gustaría pasar parámetros, estos parámetros provendrán de una aplicación .NET (VB o C #), así que tenía curiosidad si alguien sabe cómo hacer esto, o mejor aún, un sitio web con consejos útiles. sobre cómo hacerlo Entonces, básicamente, quiero ejecutar un paquete SSIS desde .NET pasando los parámetros del paquete SSIS que puede usar dentro de él. Por ejemplo, el paquete SSIS utilizará la importación de archivos planos en un archivo SQL db; sin embargo, la ruta y el nombre del archivo podrían ser el parámetro que se pasa desde la aplicación .Net.

Answer 1

Aquí es cómo configurar variables en el paquete desde el código -

using Microsoft.SqlServer.Dts.Runtime;

private void Execute_Package()
    {           
        string pkgLocation = @"c:/test.dtsx";

        Package pkg;
        Application app;
        DTSExecResult pkgResults;
        Variables vars;

        app = new Application();
        pkg = app.LoadPackage(pkgLocation, null);

        vars = pkg.Variables;
        vars["A_Variable"].Value = "Some value";               

        pkgResults = pkg.Execute(null, vars, null, null, null);

        if (pkgResults == DTSExecResult.Success)
            Console.WriteLine("Package ran successfully");
        else
            Console.WriteLine("Package failed");
    }

Answer 2

Así es como hacerlo con el catálogo SSDB que se presentó con SQL Server 2012 ...

using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Data.SqlClient;

using Microsoft.SqlServer.Management.IntegrationServices;

public List<string> ExecutePackage(string folder, string project, string package)
{
    // Connection to the database server where the packages are located
    SqlConnection ssisConnection = new SqlConnection(@"Data Source=./SQL2012;Initial Catalog=master;Integrated Security=SSPI;");

    // SSIS server object with connection
    IntegrationServices ssisServer = new IntegrationServices(ssisConnection);

    // The reference to the package which you want to execute
    PackageInfo ssisPackage = ssisServer.Catalogs["SSISDB"].Folders[folder].Projects[project].Packages[package];

    // Add a parameter collection for ''system'' parameters (ObjectType = 50), package parameters (ObjectType = 30) and project parameters (ObjectType = 20)
    Collection<PackageInfo.ExecutionValueParameterSet> executionParameter = new Collection<PackageInfo.ExecutionValueParameterSet>();

    // Add execution parameter (value) to override the default asynchronized execution. If you leave this out the package is executed asynchronized
    executionParameter.Add(new PackageInfo.ExecutionValueParameterSet { ObjectType = 50, ParameterName = "SYNCHRONIZED", ParameterValue = 1 });

    // Add execution parameter (value) to override the default logging level (0=None, 1=Basic, 2=Performance, 3=Verbose)
    executionParameter.Add(new PackageInfo.ExecutionValueParameterSet { ObjectType = 50, ParameterName = "LOGGING_LEVEL", ParameterValue = 3 });

    // Add a project parameter (value) to fill a project parameter
    executionParameter.Add(new PackageInfo.ExecutionValueParameterSet { ObjectType = 20, ParameterName = "MyProjectParameter", ParameterValue = "some value" });

    // Add a project package (value) to fill a package parameter
    executionParameter.Add(new PackageInfo.ExecutionValueParameterSet { ObjectType = 30, ParameterName = "MyPackageParameter", ParameterValue = "some value" });

    // Get the identifier of the execution to get the log
    long executionIdentifier = ssisPackage.Execute(false, null, executionParameter);

    // Loop through the log and do something with it like adding to a list
    var messages = new List<string>();
    foreach (OperationMessage message in ssisServer.Catalogs["SSISDB"].Executions[executionIdentifier].Messages)
    {
        messages.Add(message.MessageType + ": " + message.Message);
    }

    return messages;
}

El código es una pequeña adaptación de http://social.technet.microsoft.com/wiki/contents/articles/21978.execute-ssis-2012-package-with-parameters-via-net.aspx?CommentPosted=true#commentmessage

También hay un artículo similar en http://domwritescode.com/2014/05/15/project-deployment-model-changes/

Answer 3

Entonces, hay otra manera en la que puedes disparar desde cualquier idioma. La mejor manera en que pienso, puede simplemente crear un archivo por lotes que llame a su paquete .dtsx.

A continuación, llama al archivo por lotes desde cualquier idioma. Al igual que en la plataforma de Windows, puede ejecutar archivos por lotes desde cualquier lugar, creo que este será el enfoque más genérico para su propósito. Sin dependencias de código

A continuación hay un blog para más detalles.

https://www.mssqltips.com/sqlservertutorial/218/command-line-tool-to-execute-ssis-packages/

Feliz codificación ... :)

Gracias, Ayan

Answer 4

Para agregar a la respuesta de @Craig Schwarze,

Aquí hay algunos enlaces relacionados con MSDN:

msdn.microsoft.com/en-us/library/ms136090.aspx

msdn.microsoft.com/en-us/library/ms403355.aspx

Captura de eventos desde un paquete en ejecución:

using System;
using Microsoft.SqlServer.Dts.Runtime;

namespace RunFromClientAppWithEventsCS
{
  class MyEventListener : DefaultEvents
  {
    public override bool OnError(DtsObject source, int errorCode, string subComponent, 
      string description, string helpFile, int helpContext, string idofInterfaceWithError)
    {
      // Add application-specific diagnostics here.
      Console.WriteLine("Error in {0}/{1} : {2}", source, subComponent, description);
      return false;
    }
  }
  class Program
  {
    static void Main(string[] args)
    {
      string pkgLocation;
      Package pkg;
      Application app;
      DTSExecResult pkgResults;

      MyEventListener eventListener = new MyEventListener();

      pkgLocation =
        @"C:/Program Files/Microsoft SQL Server/100/Samples/Integration Services" +
        @"/Package Samples/CalculatedColumns Sample/CalculatedColumns/CalculatedColumns.dtsx";
      app = new Application();
      pkg = app.LoadPackage(pkgLocation, eventListener);
      pkgResults = pkg.Execute(null, null, eventListener, null, null);

      Console.WriteLine(pkgResults.ToString());
      Console.ReadKey();
    }
  }
}