如何在Logic App工作流中将查询结果保存为有效.PARQUET格式文件

生成的Parquet文件无法被识别的核心原因是未对查询输出的JSON结构做标准Parquet格式转换，直接将JSON写入了后缀为.parquet的文件。Parquet是列式存储的二进制格式，与JSON的文本结构化格式不兼容。
操作步骤如下：

• 提取有效查询结果
  从「Run query and list results」动作的输出中，提取value字段对应的结果数组，过滤动作返回的其他请求元数据，仅保留业务数据进入后续转换环节。
• 增加格式转换环节
  根据Logic App的层级选择适配方案：
  • 消费层（Consumption）Logic App：直接调用Data Operations分组下的「Convert to Parquet」内置动作，输入内容选择上一步提取的value数组，动作将自动输出符合规范的Parquet二进制流。
  • 标准层（Standard）Logic App：先确认工作流环境已安装Parquet转换扩展，再调用内置转换动作即可。也可对接Azure Function实现转换，函数内使用pyarrow或fastparquet库，将接收的JSON数组转换为Parquet二进制流返回。
• 存储Parquet文件
  后续的文件创建动作中，文件内容字段选择上一步转换输出的Parquet二进制流，禁止直接填入原始JSON查询结果，文件后缀设置为.parquet即可。

若结果集包含空值、datetime、decimal等特殊类型数据，需在转换环节提前指定对应的Parquet数据类型，避免出现格式兼容问题。

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