如何通过Azure Data Factory调用执行Azure Blob中存储的.sql脚本

前置准备 #

• 提前配好对应权限：给ADF的系统托管身份（或管道使用的服务主体账号）配置两类基础权限，一是对存储.sql文件的Azure Blob容器的读取权限，二是对最终执行SQL的目标数据库（Azure SQL、Synapse等）的对应库表操作权限。
• 配置双端链接服务：
  • 创建指向Azure Blob Storage的链接服务，完成认证参数配置，后续直接用来定位目标.sql文件。
  • 创建指向目标执行数据库的链接服务，确保连接串、认证方式和数据库实际要求匹配。

核心管道配置 #

• 第一步：用查找活动读取Blob内的SQL脚本
  • 新建查找活动，绑定之前创建的Blob链接服务，数据集直接定位到容器内具体的.sql脚本文件，文件格式选择纯文本/Binary模式，关闭结构化解析配置，确保能拿到完整的脚本原文，不会被自动拆分成行列数据。
  • 如果脚本内容超过1MB的查找活动单文件读取上限，调整查找活动的返回配置，直接读取全量文件内容存入管道输出变量。
• 第二步：透传脚本内容到执行活动
  • 新建与目标数据库匹配的执行SQL活动，关联对应的数据库链接服务。
  • 在SQL命令输入位置不要硬编码查询语句，直接写入动态表达式：@activity('你的查找活动名称').output.value[0].content
  • 配置完成后，ADF会直接把从Blob读到的脚本原文传给数据库执行，不需要在管道内重复编写、修改SQL逻辑。

避坑提示 #

• 执行SQL活动本身不支持直接传入Blob文件路径定位脚本，必须通过前置的读取活动把文件内容转为字符串，才能作为执行命令透传。
• 可以在查找活动前加一个文件存在验证活动，提前检查目标.sql文件是否存在、内容是否为空，避免因文件被误删、清空导致的管道执行报错。
• 如果.sql脚本内带动态参数，可以在透传脚本前，在管道内用字符串替换的动态表达式，把脚本内的占位符替换为管道传入的参数值，不需要修改Blob里的原脚本。

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