mule中如何根据Quartz cronExpression设置文件轮询频率答案

【问题标题】：How to set the file polling frequency according to the Quartz cronExpression in mulemule中如何根据Quartz cronExpression设置文件轮询频率
【发布时间】：2023-04-07 13:11:01
【问题描述】：

我对 Mule 很陌生。

我遇到了一个问题。我有一个要求，我需要每 2 分钟从 D:\ 驱动器中的 CSV 文件读取数据并使用 Mule 将数据插入 PostgreSQL 数据库。

所以我选择了 Quartz。

这是我的代码：

<configuration>
    <expression-language autoResolveVariables="true">
        <import class="org.mule.util.StringUtils" />
        <import class="org.mule.util.ArrayUtils" />
    </expression-language>
</configuration>

<spring:beans>
    <spring:bean id="jdbcDataSource" class=" ... your data source ... " />
</spring:beans>

<jdbc:connector name="jdbcConnector" dataSource-ref="jdbcDataSource">
    <jdbc:query key="insertRow"
        value="insert into my_table(col1, col2) values(#[message.payload[0]],#[message.payload[1]])" />
</jdbc:connector>

<quartz:connector name="myQuartzConnector" validateConnections="true" doc:name="Quartz">
  <receiver-threading-profile maxThreadsActive="1"/>
</quartz:connector>

    <flow name="QuartzFlow" processingStrategy="synchronous">

        <quartz:inbound-endpoint doc:name="Quartz"
            jobName="CronJobSchedule" cronExpression="0 0/2 * * * ?"
            connector-ref="myQuartzConnector" repeatCount="1">
            <quartz:event-generator-job>
                <quartz:payload>quartzSchedular started</quartz:payload>
            </quartz:event-generator-job>
        </quartz:inbound-endpoint>


        <flow-ref name="csvFileToDatabase" doc:name="Flow Reference" />

    </flow>


<flow name="csvFileToDatabase">
    <file:inbound-endpoint path="/tmp/mule/inbox"
        pollingFrequency="5000" moveToDirectory="/tmp/mule/processed">
         <file:filename-wildcard-filter pattern="*.csv" />
    </file:inbound-endpoint>

    <!-- Load all file in RAM - won't work for big files! -->
    <file:file-to-string-transformer />
    <!-- Split each row, dropping the first one (header) -->
    <splitter
        expression="#[rows=StringUtils.split(message.payload, '\n\r');ArrayUtils.subarray(rows,1,rows.size())]" />
    <!-- Transform CSV row in array -->
    <expression-transformer expression="#[StringUtils.split(message.payload, ',')]" />
    <jdbc:outbound-endpoint queryKey="insertRow" />
</flow>

这工作正常，但在 D:\ 中，如果我保持 csv 文件 mule 读取 csv 文件并写入数据库而不等待 2 分钟（此处指的是 Quartz 调度时间）。

如果我使用 pollingfrequency="120000"（2 分钟 2*60*1000 毫秒）设置文件连接器的轮询频率，石英也不会等待 2 分钟。在 2 分钟的调度时间内，如果我将 csv 文件放在 D:\ mule 读取 csv 文件并写入数据库而不等待 2 分钟（这里指的是 Quartz 调度时间）。

即使我将 csv 文件放在 D:\ 中，mule Quartz 也必须每 2 分钟执行一次操作。仅，为此我需要在此处包含哪些更改..

谁能帮帮我..

【问题讨论】：

标签： java mule mule-studio

【解决方案1】：

这是因为流 csvFileToDatabase 有自己的入站端点，无论石英流如何，它都会执行。您将 file:inbound-enpoint 设置为每 5000 毫秒轮询一次。

不需要同时使用入站端点和石英来调度流。

要么更改文件：入站端点频率，要么如果您真的想使用石英来触发流程，请查看允许您使用入站端点中间流程的 mule 请求模块：https://github.com/mulesoft/mule-module-requester

【讨论】：