Azure Data Factory V2自动读取Blob容器名称并同步至SQL/CSV的方法

当然可以实现！在Azure Data Factory V2里，你可以通过系统变量、动态内容或者参数化配置自动获取Blob容器名称，轻松把它传递到SQL Server或者添加到CSV数据流中。下面分几种常见场景详细说明：

场景1：把容器名作为额外字段添加到CSV数据流中 #

如果想让每条CSV数据都带上所属的容器名称，用数据流的派生列活动就能搞定：

• 先配置好你的Blob存储数据集，确保链接服务正确，容器名称可以是固定值，也可以设为参数（方便后续处理多容器）。
• 在数据流中添加「派生列」活动，连接到你的Blob源。
• 在派生列的表达式框里，输入 @dataset().container，给这个新字段起个名字（比如ContainerName）。这样数据流里的每一条数据都会自动带上当前读取的容器名称。
• 之后不管是把数据写入SQL Server，还是输出到新的CSV文件，这个ContainerName字段都会包含在内。

场景2：将容器名传递到Microsoft SQL Server #

如果要把容器名直接传到SQL Server（比如写入日志表、作为存储过程参数），可以按以下方式操作：

复制活动中传递容器名 #

• 配置好Blob源和SQL目标数据集后，进入复制活动的「映射」tab。
• 点击「添加派生列」，设置列名（比如ContainerName），值用动态内容 @dataset().container，然后把这个列映射到SQL表的对应字段即可。
• 要是需要在SQL的预/后处理脚本里用容器名（比如记录加载日志），可以在SQL目标的「预复制脚本」或「后复制脚本」中这样写：

  INSERT INTO LoadLog (ContainerName, LoadTimestamp) VALUES ('@{dataset().container}', GETDATE())
  

通过存储过程传递容器名 #

• 如果是用存储过程来处理数据，先在SQL Server里创建带容器名参数的存储过程（比如CREATE PROCEDURE ProcessData @ContainerName VARCHAR(100)）。
• 在ADF中添加「存储过程活动」，选择对应的SQL链接服务和存储过程。
• 在「参数」配置里，添加一个输入参数，值设为 @dataset().container，和存储过程的参数对应上就行。

进阶：处理多个容器的情况 #

如果需要遍历多个Blob容器并分别处理，结合「Get Metadata」和「ForEach」活动就能实现：

• 添加「Get Metadata」活动，链接到你的Blob存储，设置「字段列表」为Child Items，「子项类型」选择Container，这样就能获取所有容器的列表。
• 添加「ForEach」活动，把「Get Metadata」输出的childItems作为遍历对象（表达式写@activity('Get Metadata活动名称').output.childItems）。
• 在ForEach循环内部，先创建一个变量来存储当前容器名（值为@item().name），然后把数据集的容器名称参数设为这个变量。
• 后续的数据流、复制活动等都可以引用这个变量来获取当前处理的容器名，传递到SQL或者添加到数据中。

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