NiFi使用Python ExecuteScript转JSON为XML时非英文字符乱码如何解决

数据老陈

2026-10-1

修复方案

问题根源

乱码是由三处编码处理错误共同导致的：

给Att4的text属性赋值时额外执行了encode("utf8")操作，将字符串转为字节对象，ElementTree会直接将字节的十进制值转换为XML实体，最终显示为乱码
ET.tostring()默认使用ASCII编码输出，所有非ASCII字符都会被自动转义为实体编码
输出时额外做了bytearray转换，可能引发额外的编码冲突

修正后的完整代码

import json
import xml.etree.ElementTree as ET
import java.io
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback

class ModJSON(StreamCallback):

    def __init__(self):
        pass

    def process(self, inputStream, outputStream):
        text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
        data = json.loads(text)
        root = ET.Element("headerinfo")
        entity = ET.SubElement(root, "headerfile")
        ET.SubElement(entity, "Att1").text = str(data["Header"]["Att1"])
        ET.SubElement(entity, "Att2").text = str(data["Header"]["Att2"])
        ET.SubElement(entity, "Att3").text = str(data["Header"]["Att3"])
        # 直接赋值字符串，不要提前编码
        ET.SubElement(entity, "Att4").text = data["Header"]["Att4"]
        # 指定UTF-8编码，同时添加XML声明标明编码
        xmlNew = ET.tostring(root, encoding='utf-8', xml_declaration=True)
        # 直接输出编码后的字节流
        outputStream.write(xmlNew)

flowFile = session.get()
if flowFile != None:
    try :
        flowFile = session.write(flowFile, ModJSON())
        flowFile = session.putAttribute(flowFile, "filename", 'headerfile.xml')
        session.transfer(flowFile, REL_SUCCESS)
        session.commit()
    except Exception as e:
        flowFile = session.putAttribute(flowFile,'python_error', str(e))
        session.transfer(flowFile, REL_FAILURE)