- 快速搭建数据处理流程,框架负责解决业务无关逻辑,例如切面日志记录,流程监控报警等
- 业务逻辑插件化:不同业务通过插件解耦,数据在插件中处理,在插件间传递流转,提高业务代码可读性
- 配置化流程编排:用户通过配置文件编排数据接收器及插件,构建数据处理流程,支持多流程、多分支拓扑,灵活方便
- 重复利用:框架实现通用数据接收器、插件及资源,用户不用重复实现,利用已有实现配置即用
-
stream应用搭建示例参见:链接
-
依赖JAR包选择
工件 | 分组 | 最新版本 | 是否必须 | 说明 |
---|---|---|---|---|
stream-sdk | xin.manong | 0.1.2 | 是 | 开发SDK,定义数据接收器、插件和资源 |
stream-framework | xin.manong | 0.1.2 | 是 | stream运行框架及环境 |
stream-resource | xin.manong | 0.1.2 | 否 | 通用资源组件实现,按需引入 |
stream-receiver | xin.manong | 0.1.2 | 否 | 通用数据接收器实现,按需引入 |
stream-plugin | xin.manong | 0.1.2 | 否 | 通用插件实现,按需引入 |
工件 | 分组 | 版本 | optional |
---|---|---|---|
aliyun-log | com.aliyun.openservices | 0.6.82 | true |
aliyun-log-producer | com.aliyun.openservices | 0.3.12 | true |
aliyun-sdk-datahub | com.aliyun.datahub | 2.3.0-public | true |
aliyun-sdk-oss | com.aliyun.oss | 3.15.0 | true |
commons-cli | commons-cli | 1.3 | false |
commons-pool2 | org.apache.commons | 2.11.1 | false |
guava | com.google.guava | 33.3.1-jre | true |
kafka-clients | org.apache.kafka | 3.9.0 | true |
ons-client | com.aliyun.openservices | 1.8.0.Final | true |
redisson | org.redisson | 3.38.1 | true |
slf4j-reload4j | org.slf4j | 2.0.16 | true |
tablestore | com.aliyun.openservices | 5.13.10 | true |
weapon-alarm | xin.manong | 0.2.0 | false |
weapon-aliyun | xin.manong | 0.2.0 | false |
weapon-base | xin.manong | 0.2.0 | false |