Spring 批处理 - StaxEventItemReader 处理 xml 中的无效行

Question

我正在使用 Spring 批处理读取 XML 个文件。我想使用 XSD 验证记录。我可以使用 setSchema 运行验证，但它会抛出异常并终止整个作业。我的目标是处理这些无效记录，将它们保存到日志中并跳过它们以进行最终处理。

我的 StaxEcentItemReader

    @Bean
    @JobScope
    public StaxEventItemReader<?> reader() throws Exception {
        Jaxb2Marshaller jaxb2Marshaller = new Jaxb2Marshaller();
        jaxb2Marshaller.setClassesToBeBound(BookDto.class);
        jaxb2Marshaller.setSchema(new ClassPathResource("book.xsd"));
        jaxb2Marshaller.afterPropertiesSet();

        return new StaxEventItemReaderBuilder<>()
                .name("xmlReader")
                .resource(new ClassPathResource("books.xml"))
                .addFragmentRootElements("book")
                .unmarshaller(jaxb2Marshaller)
                .build();
    }

XSD

<?xml version="1.0" encoding="UTF-8"?>
<xs:schema attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="http://www.test.com/xsd"
  xmlns="http://www.test.com/xsd"
  xmlns:xs="http://www.w3.org/2001/XMLSchema">
  <xs:element name="book" type="bookDto"/>
  <xs:simpleType name="simAuthor">
    <xs:restriction base="xs:string">
      <xs:maxLength value="10"/>
    </xs:restriction>
  </xs:simpleType>
  <xs:complexType name="bookDto">
    <xs:sequence>
      <xs:element name="author" type="simAuthor" minOccurs="0"/>
      <xs:element type="xs:float" name="price"/>
    </xs:sequence>
    <xs:attribute type="xs:string" name="id" use="required"/>
  </xs:complexType>
</xs:schema>

项目

<?xml version="1.0"?>
<catalog>
  <book xmlns="http://www.test.com/xsd"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.test.com/xsd" id="bk101">
    <author>Gambardella, MatthewMatthewMatthewMatthewMatthewMatthewMatthewMatthew</author>
    <price>44.95s</price>
  </book>
  <book xmlns="http://www.test.com/xsd"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.test.com/xsd" id="bk102">
    <author>Ralls, Kim</author>
    <price>5.95</price>
  </book>
</catalog>

Answer 1

I'm able to run validations using setSchema but it will throw exception and kill whole job.

您可以使用容错步骤并将异常声明为可跳过。有了这个，无效的项目将被跳过，作业将继续处理下一个项目，而不是在第一个无效的项目上失败。有关详细信息，请参阅参考文档的 Configuring Skip Logic 部分。

My goal is to handle these invalid records, save them to log and skip them for final process.

为此，您需要注册 SkipListener 并在需要时记录无效项目。

Spring 批处理 - StaxEventItemReader 处理 xml 中的无效行

Spring Batch - StaxEventItemReader handle invalid rows in xml

java

spring

spring-batch