如何在Azure Data Factory中实现Oracle数据导出为指定XML文件

ADF复制活动原生不支持XML格式接收器，可通过以下三种成熟路径实现需求，可根据自身权限、数据量、后续迭代需求选择：

方案1：复制活动同步原始数据 + Azure Function后置生成XML #

• 第一步：配置ADF复制活动，源端连接Oracle数据库拉取idnt、col2、col3三个字段的全量原始数据，接收器选择JSON格式输出到ADLS Gen2/Blob存储的临时目录，这一步不需要做任何数据转换，直接同步原始表数据即可。
• 第二步：在复制活动后挂载Azure Function活动（或ADF自定义批处理活动），函数内实现两个核心逻辑：
  1. 读取临时目录下的JSON格式原始数据，按idnt字段做分组聚合，将同一个idnt对应的所有col2、col3记录归集到同一分组下
  2. 按照目标XML结构拼接内容：根节点固定为<AA_ITEMS>，每个idnt对应一个携带ID属性的<Idnt>子节点，每个idnt分组下的单条记录对应一个携带ID属性的<Col2>节点，Col2节点内部嵌套<Col3>节点存储对应col3的字段值
• 第三步：函数将拼接完成的完整XML内容写入最终目标存储路径，可配置自动清理临时目录下的中间JSON文件，减少冗余存储占用。
  该方案灵活性最高，后续如果XML结构调整仅需修改函数内的拼接规则，不需要改动ADF流水线的整体结构，适合数据量中等、XML格式后续可能迭代的场景。

方案2：Oracle源端直接生成XML内容后通过ADF导出 #

• 第一步：在Oracle源端编写查询SQL，利用Oracle原生XML函数直接将表数据聚合为符合要求的XML结构，参考SQL如下：

SELECT
  XMLELEMENT("AA_ITEMS",
    XMLAGG(
      XMLELEMENT("Idnt",
        XMLATTRIBUTES(idnt AS "ID"),
        XMLAGG(
          XMLELEMENT("Col2",
            XMLATTRIBUTES(col2 AS "ID"),
            XMLELEMENT("Col3", col3)
          )
        )
      )
    )
  ).GETCLOBVAL() AS xml_content
FROM 你的源表名
GROUP BY idnt

• 第二步：ADF复制活动源端直接使用上述SQL作为查询语句，查询返回的单字段xml_content就是完整的符合格式要求的XML内容；接收器配置为二进制格式或无分隔符文本格式（注意关闭字段引号转义规则），输出文件后缀设置为.xml即可，不需要额外做后置转换处理。
  该方案性能最优，所有格式聚合计算逻辑下推到Oracle数据库侧完成，不需要额外配置其他计算资源，适合数据量较大、XML结构固定、有Oracle端自定义查询权限的场景；如果单份XML内容超过Oracle CLOB字段长度上限，需要额外做分片拆分处理。

方案3：ADF映射数据流全链路转换输出 #

• 第一步：在ADF内新建映射数据流，源数据集配置Oracle连接器，拉取三个字段的原始数据。
• 第二步：添加聚合转换组件，分组字段选择idnt，聚合列通过collect()函数将同一个idnt下的col2、col3值收集为数组结构。
• 第三步：添加派生列转换组件，按照目标XML的节点规则拼接完整XML字符串，注意提前处理字段值中的XML预留特殊字符（&、<、>、"、'），避免生成的XML格式校验失败。
• 第四步：接收器配置为文本输出，仅保留拼接完成的XML内容列，输出文件后缀设置为.xml，直接写入目标存储路径。
  该方案不需要引入ADF之外的外部服务，全链路转换逻辑都在ADF内部完成，适合没有Oracle自定义函数/查询权限、不想额外维护函数资源的场景。

通用注意事项：所有方案都需要做XML特殊字符转义，避免字段值中包含的预留字符导致XML结构损坏。

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