4

我有一个由两个步骤组成的 Spring Batch 作业（到目前为止）。

作业的第一步是在 tasklet 中实现的。它获取需要处理的逗号分隔值 (CSV) 文件（使用大量业务逻辑来确定哪些是），并将它们复制到“放置区”目录中。

第二步配置为面向块的处理，具有读取器和写入器。阅读器是一个MultiResourceItemReader...，它在放置区目录中查找所有 CSV 文件，并将每个文件委托给“真正的”阅读器（解析 CSV）。

我的问题是，即使第一步成功，第二步也无法在放置区目录中找到任何 CSV 文件。有趣的是，如果我立即再次运行批处理作业……那么第二步确实会找到并处理文件！

我在推测，但看起来 Spring Batch 在一开始就解决了第二步的通配符模式......而不是等到第二步运行的时候。即使第一步复制了它应该复制的文件，第二步已经确定那里没有文件。

我对 Spring Batch 相当陌生，并且仍在学习我的方式。我在这里遗漏了一些明显的上下文或范围吗？我的工作定义的相关部分如下。谢谢！

...
<!-- JOB DEFINITION -->
<job id="notificationJob" xmlns="http://www.springframework.org/schema/batch">
    <step id="copyFilesToLocal">
        <tasklet transaction-manager="jobRepositoryTransactionManager" ref="getFilesTasklet" />
        <next on="COMPLETED" to="processFiles"/>
    </step>
    <step id="processFiles">
        <tasklet transaction-manager="ecommerceTransactionManager">
            <chunk reader="multiFileReader" writer="notificationEmailWriter" commit-interval="1" />
        </tasklet>
    </step>
</job>

<!-- FIRST STEP -->
<bean id="getFilesTasklet" class="com.mypackage.FileMovingTasklet">
    <property name="localDao">
        <bean class="com.mypackage.BatchLocalDao">
            <property name="dataSource" ref="jobRepositoryDataSource" />
        </bean>
    </property>
    <property name="sourceDirectory">
        <bean id="sourceDirectory" class="org.springframework.core.io.FileSystemResource">
            <constructor-arg value="/mnt/source-directory" />
        </bean>
    </property>
    <property name="destinationDirectory">
        <bean id="destinationDirectory" class="org.springframework.core.io.FileSystemResource">
            <constructor-arg value="/home/myuser/drop-zone" />
        </bean>
    </property>
</bean>


<!-- SECOND STEP -->
<bean id="multiFileReader" class="org.springframework.batch.item.file.MultiResourceItemReader">
    <property name="resources" value="file://home/myuser/drop-zone/*.csv" />
    <property name="delegate" ref="myFileReader" />
</bean>
...
4

1 回答 1

6

您的“multiFileReader”需要为 scope="step"，因此它将模式扩展（bean 属性的初始化）推迟到执行该步骤。

于 2012-11-27T22:07:55.413 回答