如何用WSO2 Integration Studio通过代理服务实现CSV转XML？

核心配置步骤 #

• 配置文件入站监听：给代理服务添加VFS类型的入站端点，指定CSV文件所在目录，设置PollInterval（轮询间隔，单位毫秒）和FileNamePattern为*.csv，确保能捕获目标目录下所有CSV文件。
• 启用CSV转XML转换：在代理服务的inSequence中添加CSV to XML中介组件（已导入csvmodule可直接调用）：
  • 若CSV包含表头，勾选Header present，设置分隔符（默认逗号，按需调整），自定义XML根节点名（如Records）和行节点名（如Record）；
  • 若无表头，将Header present设为false，列名将默认用column1、column2命名。
• 配置XML输出端点：在转换组件后添加VFS出站端点，指定XML文件输出目录，设置文件名规则（如output-{timestamp}.xml避免重名）。
• 完善代理服务参数：设置ActionAfterProcess为MOVE，指定已处理CSV的归档目录，防止重复读取；同时配置ContentType为text/csv。

完整代理服务配置示例 #

<proxy name="CSVtoXMLProxy" startOnLoad="true" transports="vfs" xmlns="http://ws.apache.org/ns/synapse">
    <target>
        <inSequence>
            <!-- CSV转XML转换 -->
            <csv xmlns="http://ws.apache.org/ns/synapse" separator="," header-present="true" rootName="Records" rowName="Record"/>
            <!-- 可选：打印日志验证转换结果 -->
            <log level="full"/>
            <!-- 发送转换后的XML到输出目录 -->
            <send>
                <endpoint>
                    <address uri="vfs:file:///your/output/xml/dir?transport.vfs.FileNamePattern=output-{timestamp}.xml"/>
                </endpoint>
            </send>
        </inSequence>
        <outSequence/>
        <faultSequence/>
    </target>
    <!-- 入站CSV目录配置 -->
    <parameter name="transport.vfs.FileURI">file:///your/input/csv/dir</parameter>
    <parameter name="transport.vfs.ContentType">text/csv</parameter>
    <!-- 处理后文件归档 -->
    <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
    <parameter name="transport.vfs.MoveAfterProcess">file:///your/processed/csv/dir</parameter>
    <!-- 失败文件归档 -->
    <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
    <parameter name="transport.vfs.MoveAfterFailure">file:///your/failed/csv/dir</parameter>
    <!-- 轮询间隔5秒 -->
    <parameter name="transport.vfs.PollInterval">5000</parameter>
    <!-- 监听所有CSV文件 -->
    <parameter name="transport.vfs.FileNamePattern">*.csv</parameter>
    <!-- 启用文件锁防止并发读取 -->
    <parameter name="transport.vfs.Locking">enable</parameter>
</proxy>

注意事项 #

• 替换示例中所有路径为你的实际目录，确保WSO2运行用户对这些目录有读写权限。
• 测试时可先放入单个CSV文件，查看输出目录是否生成对应XML，同时检查日志排查问题。

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