Golang框架实战-KisFlow流式计算框架专栏Golang框架实战-KisFlow流式计算框架(1)-概述Golang框架实战-KisFlow流式计算框架(2)-项目构建/基础模块-(上)Golang框架实战-KisFlow流式计算框架(3)-项目构建/基础模块-(下)Golang框架实战-KisFlow流式计算框架(4)-数据流Golang框架实战-KisFlow流式计算框架(5)-Function调度Gol...

是从flow.Input()中 获取到原始数据，改成可以直接获取到业务想要的具体数据结构类型，而无需断言等类型判断和转换。改成的Function扩展参数用法大致如下：

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

KisFlow如果在执行流体中，需要被多个Goroutine来并发使用，可能需要同一个配置的创建多个Flow来匹配多个并发的计算流，所以Flow需要一个创建副本的能力。本章将实现这部分的能力。

Golang框架实战-KisFlow流式计算框架专栏Golang框架实战-KisFlow流式计算框架(1)-概述Golang框架实战-KisFlow流式计算框架(2)-项目构建/基础模块-(上)Golang框架实战-KisFlow流式计算框架(3)-项目构建/基础模块-(下)Golang框架实战-KisFlow流式计算框架(4)-数据流Golang框架实战-KisFlow流式计算框架(5)-Function调度Gol...

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

现在每次建立Flow和Function等，都需要一系列繁琐的添加，不是很方便，接下来，我们可以通过批量读写配置文件，构建KisFlow中的结构关系，并且也可以将KisFlow的结构导出到本地文件中。目前我们先用文件的形式做配置的持久化，开发者也可以今后做数据库或者远程配置的持久化均可。

KisFlow中提供Connector，来给开发者定义第三方存储引擎的自定义读写插件模式。如果数据流的数据需要临时从某引擎去读或者需要存储到某个存储引擎中，可以通过Connector来编写相对应的读写逻辑，并且通过配置，自定义挂载在Flow中的某个Function中。Connector也是灵活配置的。这样具有相同逻辑的存储算法可以在多个Funct...

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