关于“批处理”样本

此样本演示了如何使用 FileInput 和 FileOutput 节点,将文件追加到单个输出文件。

此样本演示了以下任务:

样本基于以下场景:

每个分公司都在工作站上的文本文件中记录其邮政使用。此文本文件传输至总公司输入目录,它每天追加到主文件。每天主文件都会传输到总公司输出目录一次。

通过使用以下部分中描述的消息流实施方案。

FileBatchProcessingFlowSample_Branch 消息流

FileInput 节点监视一个目录,每个分公司都发送包含每日邮政使用的记录的文本文件。FileOutput 节点将每个分公司记录追加到总公司输入目录中保留的主文件。此文件保留在 mqsitransit 子目录中,直到 FileOutput 节点收到“数据结束”消息。FileInput 节点的 End of Data 终端连接到 Compute 节点。三个分公司发送邮政数据,且 Compute 节点计算通过流的消息数量。Compute 节点读取第三个记录时,将“数据结束”消息传播到 FileOutput 节点上的 Finish File 终端。

下图显示了 FileBatchProcessingFlowSample_Branch 消息流:

FileBatchProcessingFlowSample_Branch 消息流的截屏。

FileBatchProcessingFlowSample_HOffice 消息流

FileInput 节点监视总公司输入目录。FileInput 节点连接到 FileOutput 节点,并将主文件写入总公司输出目录。

下图显示了 FileBatchProcessingFlowSample_HOffice 消息流:

FileBatchProcessingFlowSample_HOffice 消息流的截屏。

返回到样本主页