以编程方式添加数据流任务
适用于：
Azure 数据工厂中的 SQL Server SSIS Integration Runtime
SQL Server Data Tools (SSDT) 包含了一个称为数据流任务的任务，由对象模型中的 Microsoft.SqlServer.Dts.Pipeline.Wrapper 命名空间表示。 数据流任务是一个专门用于在包执行期间转换和移动数据的专用高性能任务。 与其他任务相似，数据流任务由 TaskHost 对象包装，从运行时引擎的角度出发，此任务只是该包中的另一个任务。 但是，数据流包含称为数据流组件的其他对象。 这些组件将数据从源移到目标，有时候还会经过转换。 这些组件定义数据的移动方向和转换数据的方式。 配置数据流任务涉及向任务添加组件，然后连接这些组件以便建立数据流并完成所需的转换。
数据流中有三种类型的组件：“数据流源”、“数据流转换”和“数据流目标”，它们以该顺序显示在 SSIS 设计器的工具箱中。 这些类型又简称为源、转换和目标。 顾名思义，数据流从源到转换，然后到达目标。 这是简化的数据流说明，只为说明概念，但是数据流任务却很灵活很强大，足以处理多个源以及将许多向多个目标发送输出的转换连接在一起。
将数据流任务添加到包的方法与添加其他任务相同。 添加该任务后，可配置该任务，方法是向数据流任务添加组件，然后配置并连接任务中的组件。
示例
下面的代码示例演示如何向包添加数据流任务。 此示例需要引用程序集 Microsoft.SqlServer.PipelineHost、Microsoft.SqlServer.DTSPipelineWrap 和 Microsoft.SqlServer.ManagedDTS。
using System;
using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Pipeline;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
namespace Microsoft.SqlServer.Dts.Samples
{
class Program
{
static void Main(string[] args)
{
Package p = new Package();
Executable e = p.Executables.Add("STOCK:PipelineTask");
TaskHost thMainPipe = e as TaskHost;
MainPipe dataFlowTask = thMainPipe.InnerObject as MainPipe;
}
}
}
Imports System.IO
Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Dts.Pipeline
Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper
Module Module1
Sub Main()
Dim p As Package = New Package()
Dim e As Executable = p.Executables.Add("STOCK:PipelineTask")
Dim thMainPipe As TaskHost = CType(e, TaskHost)
Dim dataFlowTask As MainPipe = CType(thMainPipe.InnerObject, MainPipe)
End Sub
End Module
外部资源
blogs.msdn.com 上的博客文章 EzAPI - 为 SQL Server 2012 更新。