一种实时数据流处理系统

本发明揭示了一种实时数据流处理系统和方法，系统由组件工厂、画布编排、调度执行器构成单机版部署结构或集群版部署结构；所述组件工厂，用于生产、构建、发布组件；本发明的优点在于支持复杂大规模并行任务，有效地管理资源，适用于嵌入式边缘计算设备，支持硬件水平横向扩展，集群化部署，多语言插件化扩展，支持任意语言编写自定义节点组件，内存DAG模型，打通C++/Python算法生态，面向实时流处理，低代码可视化编程拖拽。