Streamis
流式应用开发与管理的开源解决方案
Streamis是一个开源的流式应用开发和管理系统，基于DataSphere Studio和Linkis构建。它提供FlinkSQL实时开发调试、多版本管理、全生命周期管理等功能，并集成DSS开发流程和Linkis的高并发管理能力。作为开源项目，Streamis整合了DataSphere Studio和Linkis的优势，为流式应用提供全面的开发和管理功能。它支持FlinkSQL实时调试、版本控制、生命周期管理等特性，同时利用DSS和Linkis实现高效开发和稳定运行。Streamis致力于简化流式应用的开发和管理流程，提高开发效率，降低开发门槛，提升管理效率。
Streamis
[English] | 中文
简介
Streamis是由WeBank、CtYun、Samoyed Financial Cloud和XianWeng Technology联合开发的流式应用开发和管理的项目。
基于DataSphere Studio的框架能力和底层对接Linkis的Flink引擎,让用户能以低成本完成流式应用的开发、调试、发布和生产管理。
未来还计划采用类工作流式的图形化拖拽开发体验,流式应用将基于Source节点、维度节点、Transform节点、Sink节点和Visualis节点串联形成流式工作流,让用户以更低的学习成本完成流式应用的开发、调试和发布。
核心功能
1. 基于DSS和DSS-Scriptis,打造领先的流式应用开发管理体系。
以Flink作为底层计算引擎,基于开发中心和生产中心隔离的架构设计模式,完全隔离开发权限和发布权限,隔离开发环境和生产环境,确保流式应用的高稳定性和高安全性。
应用开发层与DSS的数据应用开发全流程有机融合,提供更简单的用户体验。
应用执行层集成Linkis,提供金融级的流式应用管理能力,具有高并发、高可用、多租户隔离和资源管理等特点。
2. 强大的流式应用开发和调试能力。
基于DSS-Scriptis,提供流式应用开发和调试功能,支持FlinkSQL的实时调试和结果集展示。
3. 强大的流 式应用生产中心能力。
支持流式任务的多版本管理、全生命周期管理、监控告警、checkpoint和savepoint管理能力。
运行信息页面:
配置页面：
更多功能请参考: 用户手册。
依赖生态
| 依赖组件 | 描述 | Streamis兼容性 |
|---|---|---|
| DataSphereStudio | 数据应用开发管理框架。提供统一的UI,满足数据导入、脱敏清洗、数据分析、数据挖掘、质量检查、可视化、调度到数据输出应用等数据应用开发全生命周期的类工作流式图形化拖拽开发体验。 | >= DSS1.1.2 (已发布) |
| Linkis | Apache Linkis,构建计算中间件层,通过Linkis提供的REST/WS/JDBC等标准接口,上层应用可以轻松访问MySQL/Spark/Hive/Presto/Flink等底层引擎。 | >= Linkis1.4.0 (已发布) |
演示试用环境
正在建设中,敬请期待!
下载
请前往Streamis Releases页面下载编译好的版本或源码包。
编译安装部署
请参考Streamis安装 和部署文档进行Streamis的安装部署。
示例和使用指引
请访问用户文档,快速学习如何使用Streamis。
功能特性
| 功能模块 | 描述 | Streamis |
|---|---|---|
| 界面UI | 集成便捷的管理界面和监控窗口 | 已集成 |
| 安装部署 | 部署难度和第三方依赖 | 一键部署,依赖Linkis Flink引擎 |
| 开发中心 | FlinkSQL流式应用实时开发和调试 | 支持,需集成DSS |
| 生产中心 | 流式应用管理运维能力 | 支持 |
| 复用Linkis计算治理能力 | 支持 | |
| 支持FlinkSQL和FlinkJar包发布 | 支持 | |
| 多版本管理能力 | 支持 | |
| 配置和告警管理能力 | 支持 | |
| 服务高可用 | 多服务、状态快照容错,故障不影响使用 | 应用高可用 |
| 系统管理 | 节点和资源管理 | 支持 |
| 权限管理 | 任务操作权限控制 | 支持 |
架构
贡献
欢迎各种形式的贡献,我们需要更多的贡献者一起共建Streamis。无论是代码、文档还是其他有助于社区的支持都是非常欢迎的。
交流贡献
对于任何问题或建议,欢迎提交issue。
您可以扫描下方二维码加入我们的微信群和QQ群,获取更及时的响应。
许可
Streamis采用Apache 2.0开源协议。详见LICENSE文件。
编辑推荐精选
TRAE编程
AI辅助编程，代码自动修复
Trae是一种自适应的集成开发环境（IDE），通过自动化和多元协作改变开发流程。利用Trae，团队能够更快速、精确地编写和部署代码，从而提高编程效率和项目交付速度。Trae具备上下文感知和代码自动完成功能，是提升开发效率的理想工具。
蛙蛙写作
AI小说写作助手，一站式润色、改写、扩写
蛙蛙写作—国内先进的AI写作平台，涵盖小说、学术、社交媒体等多场景。提供续写、改写、润色等功能，助力创作者高效优化写作流程。界面简洁,功能全面,适合各类写作者提升内容品质和工作效率。
问小白
全能AI智能助手，随时解答生活与工作的多样问题
问小白，由元石科技研发的AI智能助手，快速准确地解答各种生活和工作问题，包括但不限于搜索、规划和社交互动，帮助用户在日常生活中提高效率，轻松管理个人事务。
Transly
实时语音翻译/同声传译工具
Transly是一个多场景的AI大语言模型驱动的同声传译、专业翻译助手，它拥有超精准的音频识别翻译能力，几乎零延迟的使用体验和支持多国语言可以让你带它走遍全球，无论你是留学生、商务人士、韩剧美剧爱好者，还是出国游玩、多国会议、跨国追星等等，都可以满足你所有需要同传的场景需求，线上线下通用，扫除语言障碍，让全世界的语言交流不再有国界。
讯飞智文
一键生成PPT和Word，让学习生活更轻松
讯飞智文是一个利用 AI 技术的项目，能够帮助用户生成 PPT 以及各类文档。无论是商业领域的市场分析报告、年度目标制定，还是学生群体的职业生涯规划、实习避坑指南，亦或是活动策划、旅游攻略等内容，它都能提供支持，帮助用户精准表达，轻松呈现各种信息。
讯飞星火
深度推理能力全新升级，全面对标OpenAI o1
科大讯飞的星火大模型，支持语言理解、知识问答和文本创作等多功能，适用于多种文件和业务场景，提升办公和日常生活的效率。讯飞星火是一个提供丰富智能服务的平台，涵盖科技资讯、图像创作、写作辅助、编程解答、科研文献解读等功能，能为不同需求的用户提供便捷高效的帮助，助力用户轻松获取信息、解决问题，满足多样化使用场景。
Spark-TTS
一种基于大语言模型的高效单流解耦语音令牌文本到语音合成模型
Spark-TTS 是一个基于 PyTorch 的开源文本到语音合成项目，由多个知名机构联合参与。该项目提供了高效的 LLM（大语言模型）驱动的语音合成方案，支持语音克隆和语音创建功能，可通过命令行界面（CLI）和 Web UI 两种方式使用。用户可以根据需求调整语音的性别、音高、速度等参数，生成高质量的语音。该项目适用于多种场景，如有声读物制作、智能语音助手开发等。
咔片PPT
AI助力，做PPT更简单！
咔片是一款轻量化在线演示设计工具，借助 AI 技术，实现从内容生成到智能设计的一站式 PPT 制作服务。支持多种文档格式导入生成 PPT，提供海量模板、智能美化、素材替换等功能，适用于销售、教师、学生等各类人群，能高效制作出高品质 PPT，满足不同场景演示需求。
讯飞绘文
选题、配图、成文，一站式创作，让内容运营更高效
讯飞绘文，一个AI集成平台，支持写作、选题、配图、排版和发布。高效生成适用于各类媒体的定制内容，加速品牌传播，提升内容营销效果。
材料星
专业的AI公文写作平台，公文写作神器
AI 材料星，专业的 AI 公文写作辅助平台，为体制内工作人员提供高效的公文写作解决方案。拥有海量公文文库、9 大核心 AI 功能，支持 30 + 文稿类型生成，助力快速完成领导讲话、工作总结、述职报告等材料，提升办公效率，是体制打工人的得力写作神器。
推荐工具精选
AI云服务特惠
懂AI专属折扣关注微信公众号
最新AI工具、AI资讯
独家AI资源、AI项目落地
微信扫一扫关注公众号