如何从Azure Logic Apps查询Azure Synapse表并获取全部行

核心步骤 #

• 创建/打开Logic Apps工作流：选择合适触发方式（比如「手动触发」），进入工作流设计界面。
• 添加Azure Synapse查询操作：
  1. 点击「新建步骤」，搜索并添加「Execute SQL query」操作（可使用Azure SQL Database连接器，Synapse SQL池兼容该协议；或直接选择Synapse专用连接器）。
  2. 配置连接：输入Synapse SQL池的服务器地址、数据库名称，选择认证方式（如SQL账户认证或托管身份MSI），完成连接创建。
• 编写全量查询语句：在「查询」输入框中写入提取所有行的SQL语句，例如：

  SELECT * FROM [dbo].[YourTargetTable]
  

  （若表位于自定义schema下，需替换dbo为实际schema名称）
• 处理查询结果：
  1. 执行查询后，结果默认存储在@body('Execute_SQL_query')?['resultsets']?['Table1']路径中。
  2. 如需结构化处理数据，可添加「Parse JSON」操作，将返回的结果集JSON结构解析为可操作字段；若需遍历每一行，可添加「Apply to each」循环，绑定上述结果集路径。
• 测试验证：手动触发工作流，检查运行日志，确认是否成功获取所有行数据。

注意事项 #

• 权限配置：确保Logic Apps使用的身份（如MSI或SQL账户）拥有Synapse SQL池的db_datareader角色权限，避免访问被拒。
• 大数量场景：若表数据量过大（超过单次查询返回限制），需采用分页查询+循环的方式：
  1. 先查询总行数：SELECT COUNT(*) FROM [dbo].[YourTargetTable]
  2. 循环执行分页查询，示例语句：

     SELECT * FROM [dbo].[YourTargetTable] ORDER BY [PrimaryKeyColumn] OFFSET @offset ROWS FETCH NEXT 1000 ROWS ONLY
     

     每次循环递增@offset的值，直到返回行数为0，实现全量数据提取。

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