0

我有一个使用 Informatica BDM 自动生成的 XML 文件，编辑值对我来说非常复杂，我用 xml.etree.ElementTree 进行了几次尝试，但没有得到结果。这是文件的摘录：

<?xml version="1.0" encoding="UTF-8"?>
<root xmlns="http://www.informatica.com/Parameterization/1.0"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema"
      version="2.0"><!--Specify deployed application specific parameters here.--><!--
    <application name="app_2">
   <mapping name="M_kafka_hdfs"/>
</application>--><project name="V2">
      <folder name="Streaming">
         <mapping name="M_kafka_hdfs">
            <parameter name="P_s_spark_executor_cores">4</parameter>
            <parameter name="P_s_spark_executor_memory">8G</parameter>
            <parameter name="P_s_spark_sql_shuffle_partitions">108</parameter>
            <parameter name="P_s_spark_network_timeout">180000</parameter>
            <parameter name="P_s_spark_executor_heartbeatInterval">6000</parameter>
            <parameter name="P_i_maximum_rows_read">0</parameter>
            <parameter name="P_s_checkpoint_directory">checkpoint</parameter>
         </mapping>
      </folder>
   </project>
</root>

我的想法是能够更改参数，例如<parameter name="P_s_spark_executor_memory">8G</parameter>：<parameter name="P_s_spark_executor_memory">16G</parameter>

我只能访问这些值，但不能访问它们的内容，我也不能编辑它们：

import xml.etree.ElementTree as ET

treexml = ET.parse('autogenerated.xml')
for element in treexml.iter():
    dict_keys={}
    if element.keys():
        for name, value in element.items():
            dict_keys[name]=value
            print(dict_keys[name])

这个想法是能够覆盖任何参数：

xml["parameter"]["P_s_spark_sql_shuffle_partitions"] = 64

并且它在文件中由<parameter name="P_s_spark_sql_shuffle_partitions">64</parameter>

4

1 回答 1

1

试试这个代码：

import xml.etree.ElementTree as ET

name_space = 'http://www.informatica.com/Parameterization/1.0'
ET.register_namespace('', name_space)
treexml = ET.parse(r'c:\test\test.xml')
# get all elements with 'parameter' tags (it is necessary to specify the namespace prefix)
params = treexml.getroot().findall(f'.//{{{name_space}}}parameter')

# make the dict with names as keys and previously found elements as value
xml = {el.attrib['name']: el for el in params}
# set the text of the "P_s_spark_sql_shuffle_partitions"
xml["P_s_spark_sql_shuffle_partitions"].text = str(64)
# write out the xml
treexml.write(r'c:\test\testOut.xml')

输出c:\test\testOut.xml

<root xmlns="http://www.informatica.com/Parameterization/1.0" version="2.0"><project name="V2">
      <folder name="Streaming">
         <mapping name="M_kafka_hdfs">
            <parameter name="P_s_spark_executor_cores">4</parameter>
            <parameter name="P_s_spark_executor_memory">8G</parameter>
            <parameter name="P_s_spark_sql_shuffle_partitions">64</parameter>
            <parameter name="P_s_spark_network_timeout">180000</parameter>
            <parameter name="P_s_spark_executor_heartbeatInterval">6000</parameter>
            <parameter name="P_i_maximum_rows_read">0</parameter>
            <parameter name="P_s_checkpoint_directory">checkpoint</parameter>
         </mapping>
      </folder>
   </project>
</root>
于 2021-07-03T13:37:50.117 回答