时间戳

首页 > 解决方案 > wso2 sp - 两个文件源

wso2 - wso2 sp - 两个文件源

问题描述

你能帮我吗？我正在尝试在 wso2 sp 4.4.0 上创建一个简单的 siddhi 应用程序。我正在尝试从两个文件夹加载两个文件，加载数据后，该文件将被删除。但只加载了一个文件夹。没有加载第二个文件夹。你知道我如何处理两个文件吗？

我的悉地应用程序

@App:name("SiddhiApp")
@App:description("SiddhiApp / test")


@source(type='file', mode='LINE',
    dir.uri='file://C:\Users\john\wso2sp-test\firstFolder',
    tailing='false',
        action.after.process='delete',
    @map(type='csv',delimiter=";"))
define stream filestream (name string, surname string);

@source(type='file', mode='LINE',
    dir.uri='file://C:\Users\john\wso2sp-test\secondFolder',
    tailing='false',    
    action.after.process='delete',
    @map(type='csv',delimiter=";"))
define stream filestreamSec (id string, name string);

@sink(type='log')
define stream logStream(id string, name string); 

from filestreamSec
select *
insert into logStream;   

from filestream
select *
insert into logStream;

标签： wso2wso2sp

解决方案

在我们随 wso2sp-4.4.0 发布的 siddhi-io-file-1.1.1.jar 之后，我们修复了几个错误。当前的稳定版本是 siddhi-io-file-2.0.10。

我确实检查了您的方案，它适用于最新的 siddhi-io-file-2.0.10 版本。

这可以与 wso2si-1.0.0 一起使用。此 io-file 版本不能与 wso2sp-4.4.0 一起使用，因为与 io-file-2.0.10 一起使用的 siddhi 版本存在重大 API 更改，并且打包在分发中。

仅供参考：WSO2 Streaming Integrator是 WSO2 流处理器的继任者。

如果您需要更多信息/指导，请告诉我们。

最好的问候，拉明杜。

推荐阅读