在管道中包括数据转换存储过程

  • 3 分钟

在存储过程中封装 CREATE EXTERNAL TABLE AS SELECT (CETAS) 语句，可以更轻松地操作可能需要重复执行的数据转换。 在 Azure Synapse Analytics 和 Azure 数据工厂中，可以创建连接到链接服务的管道，包括托管数据湖文件的 Azure Data Lake Store Gen2 存储帐户和无服务器 SQL 池；这样你可以在整体数据提取、转换和加载 (ETL) 管道的过程中调用存储过程。

例如，可以创建包含以下活动的管道：

  • 删除活动，用于删除数据湖中已转换数据的目标文件夹（如果已存在）。
  • 存储过程活动，用于连接到无服务器 SQL 池，并运行封装 CETAS 操作的存储过程。

A screenshot of a pipeline containing a Delete activity and a Stored procedure activity.

通过为数据转换创建管道，可以计划在特定时间或基于特定事件（例如将新文件添加到源存储位置）运行操作。

提示

有关在管道中使用存储过程活动的详细信息，请参阅 Azure 数据工厂文档中的使用 Azure 数据工厂或 Synapse Analytics 中的 SQL Server 存储过程活动转换数据。