Copy Data活动中动态生成Blob Sink路径与文件名的实现方案咨询

一、管道表达式实现方式 #

直接用ADF内置表达式函数拼接并处理文件名，无需额外活动：

假设你已获取到完整源文件名（比如存储在SourceFileName变量中），构建sinkFilePath变量的表达式如下：

@concat(
    # 根据前缀匹配目标文件夹
    if(contains(variables('SourceFileName'), 'sales'), '/salesfolder/', '/ordersfolder/'),
    # 移除final/edited后缀，保留核心文件名格式
    replace(replace(variables('SourceFileName'), 'final', ''), 'edited', '')
)

逻辑说明： #

• 用contains判断文件名前缀，自动匹配salesfolder或ordersfolder
• 两次replace分别移除final和edited后缀，自动得到salesYYYYMMDD.txt或ordersYYYYMMDD.txt格式的文件名
• 最后用concat拼接文件夹路径和处理后的文件名，得到完整目标路径

如果你的管道中已单独维护Prefix（sales/orders）和File（YYYYMMDD）变量，表达式可简化为：

@concat(
    if(equals(variables('Prefix'), 'sales'), '/salesfolder/', '/ordersfolder/'),
    variables('Prefix'),
    variables('File'),
    '.txt'
)

二、其他实现方式 #

1. Data Flow处理 #

通过Data Flow的派生列直接处理文件名，适合批量转换场景：

1. 源数据集启用“获取文件名”选项，用@filename()函数获取源文件名
2. 添加派生列转换，生成三个字段：
   • Folder: iif(contains(filename(), 'sales'), '/salesfolder/', '/ordersfolder/')
   • CleanFileName: replace(replace(filename(), 'final', ''), 'edited', '')
   • FullSinkPath: concat(Folder, CleanFileName)
3. 接收器中启用“文件路径列”，将输出路径绑定到FullSinkPath字段

2. Azure Function调用 #

编写轻量函数处理文件名逻辑，适合复杂规则扩展：
示例C#函数代码：

public static string Run(string sourceFileName, ILogger log)
{
    var targetFolder = sourceFileName.Contains("sales") ? "/salesfolder/" : "/ordersfolder/";
    var cleanedFileName = sourceFileName.Replace("final", "").Replace("edited", "");
    return $"{targetFolder}{cleanedFileName}";
}

在ADF管道中添加Azure Function活动，传入源文件名参数，将返回结果赋值给sinkFilePath变量。

3. Lookup+ForEach分步处理 #

适合批量遍历文件场景：

1. 用Lookup活动读取Blob存储中的目标文件列表
2. 在ForEach循环中遍历Lookup结果，依次执行Set Variable活动：
   • 第一步：设置Folder变量为@if(contains(item().name, 'sales'), '/salesfolder/', '/ordersfolder/')
   • 第二步：设置CleanName变量为@replace(replace(item().name, 'final', ''), 'edited', '')
   • 第三步：设置sinkFilePath变量为@concat(variables('Folder'), variables('CleanName'))
3. 在循环内的Copy Data活动中引用sinkFilePath作为目标路径

内容的提问来源于stack exchange，提问作者user1932675