SSIS：从文件夹中获取任何平面文件源并将名称缓存为超级全局变量

Question

我正在 SSIS 和 Visual Studio 2008 中工作。执行时，我需要让 SSIS 包执行以下任务：

• 检查文件夹中的文件
• 的源
• 如果文件存在，则获取该文件并将其用作平面文件存储 文件名放入全局变量中，我可以在包的其他部分访问

该变量该包将由其他脚本运行。因此，我们需要它在每次包运行时检查文件。我们试图防止出现这样的情况：当文件出现时，我们必须监视文件夹并手动执行包。

有什么建议吗？

Answer 1

最简单的方法是设置一个 Foreach 循环容器，其中包含包的所有“工作”（或者，您可以将其作为前导步骤并使用其中的条件表达式）。假设您有 2 个名为 FileName 的变量（您将为其分配值）和一个包含我们应该查找的“位置”的 InputFolder 变量

ForEach Loop Editor

Collection tab:  
Enumerator = Foreach File Enumerators
Expression: Directory = @[User:InputFolder]
FileSpec: "YD.*"

Retrieve file name
* Fully qualified

Variable Mappings tab:  
Variable: User::FileName 
Index:  0

您也可以通过脚本任务来执行此操作，如果您想查看，请告诉我。

编辑
该脚本再次假设您已定义变量 InputFolder 和 FileName。创建脚本任务组件并将 InputFolder 选中为只读变量，将 FileName 选中为读/写变量。

using System;
using System.Data;
using System.IO;  // this needs to be added
using Microsoft.SqlServer.Dts.Runtime;
using System.Windows.Forms;

// namespace will vary 
namespace ST_bc177fa7cb7d4faca15531cb700b7f11.csproj
{
    [System.AddIn.AddIn("ScriptMain", Version = "1.0", Publisher = "", Description = "")]
    public partial class ScriptMain : Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
    {

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

        public void Main()
        {
            string inputFolder;
            string fileName;
            inputFolder = Dts.Variables["InputFolder"].Value.ToString();

            // File, if exists will look like YD.CCYYMMDD.hhmmss.done
            string fileMask = "YD.*.done";

            // this array will catch all the files matching a given pattern
            string[] foundFiles = null;
            foundFiles = System.IO.Directory.GetFiles(inputFolder, fileMask);

            // Since there should be only one file, we will grab the zeroeth
            // element, should it exist
            if (foundFiles.Length > 0)
            {
                fileName = foundFiles[0];

                // write the value to our global SSIS variable
                Dts.Variables["FileName"].Value = fileName;
            }

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

Answer 2

这是一个可能的选择。您可以使用 Foreach Loop 容器来实现此目的。请查找我在下面提供的示例。希望这能提供一个想法。

分步过程：

1. 在 SSIS 包上，创建 3 个变量，如屏幕截图 #1 所示。范围 CheckFile 表示包名称。变量 Folder 将代表您要检查文件的文件夹。 Filename 表示要检查的文件名。变量 FilePath 将是您需要的全局变量。如果文件存在，则填写文件路径值，否则为空。

2. 在包的控制流选项卡上，放置一个 Foreach 循环容器 和一个脚本任务。脚本任务是为了展示 Foreach 循环容器执行完成后变量保留值。请参阅屏幕截图 #2。

3. 配置 ForEach 循环容器，如屏幕截图 #3 和 #4 所示。

4. 将 Script Task 中的 Main() 方法替换为 Script task code 部分中给出的代码。这是为了演示变量 FilePath 保留的值。

5. 屏幕截图#5显示路径c:\temp\中不存在文件，屏幕截图#6显示相应的包执行。< /p>

6. 屏幕截图 #7 显示文件 TestFile.txt 存在于路径 c:\temp\ 中，屏幕截图 #8< /strong> 显示相应的包执行。

7. 如果您想在文件存在时对其进行处理，可以在 Foreach 循环容器 中放置一个数据流任务 来执行此操作。

希望有帮助。

脚本任务代码：

C#代码，只能在SSIS 2008及以上版本中使用。

public void Main()
        {
            Variables varCollection = null;

            Dts.VariableDispenser.LockForRead("User::FilePath");
            Dts.VariableDispenser.GetVariables(ref varCollection);

            if (String.IsNullOrEmpty(varCollection["User::FilePath"].Value.ToString()))
            {
                MessageBox.Show("File doesn't exist.");
            }
            else
            {
                MessageBox.Show("File " + varCollection["User::FilePath"].Value.ToString() + " exists.");
            }

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

截图#1:

屏幕截图 #2:

屏幕截图 #3：

屏幕截图 #4：

屏幕截图 # 5：

屏幕截图 #6：

屏幕截图 #7：

屏幕截图 # 8：