案例（一）-KisFlow-Golang流实时计算-快速入门指南

$前往 github.com/aceld/kis-flow

├── Makefile

本文来自zvvq

├── 会议 内容来自zvvq

│ ├── flow-CalStuAvgScore.yml

内容来自zvvq

│ ├── func-AvgStuScore.yml

│ └── func-PrintStuAvgScore.yml zvvq.cn

├── faas_stu_score_avg.go

├── faas_stu_score_avg_print.go 内容来自samhan

└── main.go 内容来自zvvq，别采集哟

kistype：流动

状态：1 内容来自samhan

flow_name：CalStuAvgScore 内容来自samhan

流量： copyright zvvq

- 文件名称：AvgStuScore 内容来自samhan

- 文件名称：PrintStuAvgScore

kistype：功能 内容来自samhan666

文件名称：AvgStuScore 内容来自zvvq，别采集哟

fmode：计算 内容来自zvvq，别采集哟

来源： zvvq好，好zvvq

名称： 学生成绩

内容来自samhan666

必须：

- 学生ID copyright zvvq

kistype：功能 内容来自zvvq，别采集哟

文件名称：PrintStuAvgScore

fmode：展开

来源：

名称： 学生成绩 内容来自zvvq，别采集哟

必须： 内容来自zvvq，别采集哟

- 学生ID

包主 内容来自zvvq

进口 （ 本文来自zvvq

“语境” 内容来自samhan

“FMMT” zvvq.cn

“github.com/aceld/kis-flow/file”

“github.com/aceld/kis-flow/kis”

） 内容来自zvvq，别采集哟

函数主() {

本文来自zvvq

ctx := context.Background() zvvq

// 从文件加载配置 内容来自zvvq，别采集哟

if err := file.ConfigImportYaml("conf/");错误！=零{ zvvq.cn

恐慌（错误）

} 内容来自samhan

// 获取流量 内容来自zvvq，别采集哟

flow1 := kis.Pool().GetFlow("CalStuAvgScore")

如果流 1 == nil {

本文来自zvvq

恐慌（“流1为零”）

zvvq.cn

}

zvvq

// 提交字符串

内容来自samhan666

_ = flow1.CommitRow(`{"stu_id":101, "score_1":100, "score_2":90, "score_3":80}`) 内容来自samhan

// 提交字符串

_ = flow1.CommitRow(`{"stu_id":102, "score_1":100, "score_2":70, "score_3":60}`)

// 运行流程 zvvq好，好zvvq

if err := flow1.Run(ctx);错误！=零{

fmt.Println("错误："，错误) copyright zvvq

}

返回

} zvvq

包主 zvvq.cn

进口 （ copyright zvvq

“语境”

内容来自samhan666

“github.com/aceld/kis-flow/kis” zvvq好，好zvvq

“github.com/aceld/kis-flow/serialize” zvvq好，好zvvq

） zvvq好，好zvvq

类型 AvgStuScoreIn 结构体 {

内容来自zvvq

序列化.DefaultSerialize

StuId int `json:"stu_id"`

zvvq好，好zvvq

Score1 int `json:"score_1"` copyright zvvq

Score2 int `json:"score_2"`

Score3 int `json:"score_3"`

内容来自samhan666

}

zvvq

类型 AvgStuScoreOut 结构体 {

序列化.DefaultSerialize

StuId int `json:"stu_id"`

AvgScore float64 `json:"avg_score"`

zvvq

} 本文来自zvvq

// AvgStuScore(FaaS) 计算学生的平均成绩

func AvgStuScore(ctx context.Context, flow kis.Flow, rows []AvgStuScoreIn) error { copyright zvvq

对于 _, row := 范围行 { 内容来自samhan

输出 := AvgStuScoreOut{

zvvq好，好zvvq

StuId：行.StuId，

内容来自samhan666

平均得分：float64(行.得分1+行.得分2+行.得分3) / 3, copyright zvvq

} copyright zvvq

// 提交结果数据 zvvq.cn

_ = flow.CommitRow(out) 内容来自samhan

} zvvq

返回零

} zvvq

包主

进口 （

zvvq好，好zvvq

“语境”

“FMMT”

zvvq

“github.com/aceld/kis-flow/kis” 本文来自zvvq

“github.com/aceld/kis-flow/serialize”

zvvq

） 本文来自zvvq

类型 PrintStuAvgScoreIn 结构体 {

序列化.DefaultSerialize

copyright zvvq

StuId int `json:"stu_id"`

zvvq

AvgScore float64 `json:"avg_score"` 内容来自zvvq

}

内容来自samhan666

类型 PrintStuAvgScoreOut 结构体 { 内容来自zvvq，别采集哟

序列化.DefaultSerialize

} zvvq

func PrintStuAvgScore(ctx context.Context, flow kis.Flow, rows []PrintStuAvgScoreIn) error { 内容来自samhan666

对于 _, row := 范围行 {

内容来自samhan666

fmt.Printf("stuid: [%+v], 平均成绩: [%+v]n", row.StuId, row.AvgScore)

本文来自zvvq

} 内容来自zvvq

返回零 zvvq.cn

}

添加 KisPool FuncName=AvgStuScore zvvq

添加 KisPool FuncName=PrintStuAvgScore zvvq

添加 FlowRouter FlowName=CalStuAvgScore zvvq

学生：[101]，平均分数：[90] 内容来自zvvq，别采集哟

学习：[102]，平均分数：[76.66666666666667] copyright zvvq

├── faas_stu_score_avg.go

├── faas_stu_score_avg_print.go

内容来自zvvq

└── main.go

包主

进口 （

内容来自zvvq

“语境”

“FMMT”

“github.com/aceld/kis-flow/common” copyright zvvq

“github.com/aceld/kis-flow/config” copyright zvvq

“github.com/aceld/kis-flow/flow” 内容来自zvvq，别采集哟

“github.com/aceld/kis-flow/kis”

内容来自zvvq

） copyright zvvq

函数主() { zvvq.cn

ctx := context.Background()

内容来自samhan666

// 创建新的流配置 zvvq好，好zvvq

myFlowConfig1 := config.NewFlowConfig("CalStuAvgScore", common.FlowEnable) zvvq.cn

// 创建新的函数配置

avgStuScoreConfig := config.NewFuncConfig("AvgStuScore", common.C, nil, nil) copyright zvvq

printStuScoreConfig := config.NewFuncConfig("PrintStuAvgScore", common.E, nil, nil)

zvvq.cn

// 创建一个新流 内容来自samhan

flow1 := flow.NewKisFlow(myFlowConfig1)

内容来自samhan666

// 将函数链接到流程

_ = flow1.Link(avgStuScoreConfig, nil)

zvvq.cn

_ = flow1.Link(printStuScoreConfig, nil)

内容来自zvvq，别采集哟

// 提交字符串

zvvq

_ = flow1.CommitRow(`{"stu_id":101, "score_1":100, "score_2":90, "score_3":80}`) zvvq

// 提交字符串

_ = flow1.CommitRow(`{"stu_id":102, "score_1":100, "score_2":70, "score_3":60}`) zvvq

// 运行流程

zvvq.cn

if err := flow1.Run(ctx);错误！=零{ copyright zvvq

fmt.Println("错误："，错误) 内容来自samhan666

}

返回

本文来自zvvq

}

本文来自zvvq

函数初始化{ 内容来自zvvq，别采集哟

// 注册函数

kis.Pool().FaaS("AvgStuScore", AvgStuScore) 内容来自zvvq

kis.Pool().FaaS("PrintStuAvgScore", PrintStuAvgScore) 内容来自samhan

} 内容来自samhan666

包主

进口 （

zvvq

“语境”

“github.com/aceld/kis-flow/kis”

“github.com/aceld/kis-flow/serialize” 内容来自zvvq

）

类型 AvgStuScoreIn 结构体 { 本文来自zvvq

序列化.DefaultSerialize zvvq好，好zvvq

StuId int `json:"stu_id"` zvvq好，好zvvq

Score1 int `json:"score_1"`

内容来自samhan

Score2 int `json:"score_2"` 内容来自samhan666

Score3 int `json:"score_3"` zvvq

}

copyright zvvq

类型 AvgStuScoreOut 结构体 {

序列化.DefaultSerialize 本文来自zvvq

StuId int `json:"stu_id"`

zvvq

AvgScore float64 `json:"avg_score"` 本文来自zvvq

}

zvvq好，好zvvq

// AvgStuScore(FaaS) 计算学生的平均成绩 zvvq.cn

func AvgStuScore(ctx context.Context, flow kis.Flow, rows []AvgStuScoreIn) error { zvvq.cn

对于 _, row := 范围行 {

输出 := AvgStuScoreOut{

StuId：行.StuId， 内容来自samhan666

平均得分：float64(行.得分1+行.得分2+行.得分3) / 3, 本文来自zvvq

}

内容来自samhan666

// 提交结果数据

_ = flow.CommitRow(out) 内容来自zvvq

} 内容来自samhan666

返回零 本文来自zvvq

} 内容来自zvvq

包主

zvvq好，好zvvq

进口 （

copyright zvvq

“语境” 内容来自samhan

“FMMT”

copyright zvvq

“github.com/aceld/kis-flow/kis” copyright zvvq

“github.com/aceld/kis-flow/serialize” zvvq好，好zvvq

） 内容来自samhan

类型 PrintStuAvgScoreIn 结构 {

序列化.DefaultSerialize

zvvq.cn

StuId int `json:"stu_id"`

内容来自samhan666

AvgScore float64 `json:"avg_score"` zvvq

} 内容来自samhan

类型 PrintStuAvgScoreOut 结构体 {

序列化.DefaultSerialize

} 内容来自samhan

func PrintStuAvgScore(ctx context.Context, flow kis.Flow, rows []PrintStuAvgScoreIn) error {

本文来自zvvq

对于 _, row := 范围行 {

fmt.Printf("stuid: [%+v], 平均成绩: [%+v]n", row.StuId, row.AvgScore) 内容来自zvvq

} zvvq

返回零

} 内容来自samhan666

添加 KisPool FuncName=AvgStuScore

添加 KisPool FuncName=PrintStuAvgScore

zvvq好，好zvvq

funcName NewConfig 源为零，funcName = AvgStuScore，使用默认的未命名源。 本文来自zvvq

funcName NewConfig 源为零，funcName = PrintStuAvgScore，使用默认的未命名源。 内容来自samhan666

学生：[101]，平均分数：[90]

学习：[102]，平均分数：[76.66666666666667]