DownLoad kis-flow source $go get github.com/aceld/kis-flow 《KisFlow开发者文档》 1. KisFlow快速开始(使用配置文件) 案例源代码： kis-flow-usage/2-quick_start_w...

接下来我们来增强KisFlow中Function对业务数据处理的聚焦，将之前Function的写法： func FuncDemo3Handler(ctx context.Context, flow kis.Flow) error { fmt.Printl...

在介绍本章之前，我们先普及一下Prometheus Metrics的服务启动办法。 有关Prometheus是个什么东东，希望大家可以去额外补充下知识，我用一句大白话来解释就是，系统的监...

9.1 多副本能力 KisFlow如果在执行流体中，需要被多个Goroutine来并发使用，可能需要同一个配置的创建多个Flow来匹配多个并发的计算流，所以Flow需要一个创建副本的能力...

8.1 Flow Cache 数据流缓存 KisFlow也提供流式计算中的共享缓存，采用简单的本地缓存供开发者按需使用，有关本地缓存的第三方技术依赖选型： github.com/patrickmn/go-c...

7.1 Action Abort（终止流程） KisFlow Action 是指在执行Function的时候，同时可以控制Flow的调度逻辑，KisFlow提供一些Action动作让开发者做选择，本节先介绍最简单的A...

6.1 配置的导入 现在每次建立Flow和Function等，都需要一系列繁琐的添加，不是很方便，接下来，我们可以通过批量读写配置文件，构建KisFlow中的结构关系，并且也可以将Ki...

本章将设计KisFlow的Connector模块，期功能及作用主要为挂载在某个Function下，执行第三方存储引擎的逻辑。 5.1 Connector定义 KisFlow中提供Connector，来给开发者定义...

4.1 Router 现在，将KisFlow提供对外Function开放注册能力，首先我们要定义一些注册函数原型，和管理这些Function的Router映射关系类型。 创建kis-flow/kis/router.go，...

3.1 数据类型定义 KisFlow中可以传递任意类型数据作为Flow的数据源。而且KisFlow支持批量数据的流逝计算处理。 首先需要对KisFlow中内部支持的数据类型做一个基本的定义...

首先我们要先定义KisFlow的核心结构体，KisFlow结构体，通过上述的设计理念，我们得知，KisFlow表示整个一条数据计算流的结构。其中每次数据在一个Flow上，依次执行挂载...

2. V0.1-项目构建及基础模块定义 首先我们创建我们的项目，项目的主文件目录就叫KisFlow，且在Github上创建对应的仓库： github.com/aceld/kis-flow 然后将项目代码clo...

1.1 为什么需要KisFlow 一些大型toB企业级的项目，需要大量的业务数据，多数的数据需要流式实时计算的能力，但是很多公司还不足以承担一个数仓类似，Flink + Hadoop/HBas...

人生无常，唯有文字的灵魂才能在这世上永驻。感谢关注我的伙伴一路对我的支持，这也是我这些年坚持下来的动力。 在这里，我正式宣布出版个人原创纸质书籍《深入理解Go语...

人生无常，唯有文字的灵魂才能在这世上永驻。感谢关注我的伙伴一路对我的支持，这也是我这些年坚持下来的动力。 在这里，我正式宣布出版个人原创纸质书籍《深入理解Go语...