如何在Azure Data Factory管道中创建存储过程?
Azure Data Factory 存储过程创建集成方案解答
问题1:创建存储过程需使用的ADF活动
优先推荐使用*脚本活动(Script Activity)*完成存储过程创建操作,适配性更强:
- 若使用ADF V2及以上版本,
脚本活动原生支持执行DDL类语句,可直接对接SQL Server、Azure SQL DB、Azure Synapse等目标数据库执行CREATE PROCEDURE相关代码 - 若使用旧版本ADF,也可选择
查找活动实现,需关闭查找活动的「仅返回第一行」配置,确保无结果集返回的DDL语句可正常执行
问题2:现有管道改造实现自动创建存储过程的步骤
你可以按照以下步骤调整现有流程,无需提前手动创建存储过程:
步骤1:新增存储过程创建前置活动
在原有调用存储过程的活动之前,新增一个脚本活动,完成对应配置:
- 链接服务选择存储过程归属的目标数据库链接服务,需确保链接服务使用的账号具备CREATE PROCEDURE权限
- 在脚本输入框中写入存储过程创建代码,建议使用
CREATE OR ALTER PROCEDURE语法,避免管道重复运行时出现存储过程已存在的报错
示例语法参考:
CREATE OR ALTER PROCEDURE [dbo].[自定义存储过程名] -- 此处写存储过程参数定义 AS BEGIN -- 此处写存储过程业务逻辑 END
步骤2:配置活动依赖关系
将脚本活动的「执行成功」输出节点,连接到原有调用存储过程的活动上,确保只有存储过程创建/更新成功后,才会执行后续的存储过程调用、数据导出至Azure Storage的流程
步骤3:验证流程有效性
可先单独运行脚本活动验证存储过程创建逻辑正常,再执行全链路管道验证完整流程符合预期即可
内容的提问来源于stack exchange,提问作者Anthony Quartz
相关产品推荐
相关产品推荐

