go

Github: https://github.com/aceld/kis-flowDocument: https://github.com/aceld/kis-flow/wiki Part1-OverViewPart2.1-Project Construction / Basic ModulesPart2.2-Project Construction / Basic ModulesPart3-Data StreamPart4-Function SchedulingPart5-ConnectorPart6-Configuration Import and ExportPart7-KisFlow ActionPart8-Cache/Params Data Caching and Data ParametersPart9-Multiple Copies of FlowPart10-Prometheus Metrics StatisticsPart11-Adaptive Registration of FaaS Parameter Types Based on Reflection To be continued. Next, we will enhance the Function in KisFlow to better focus on processing business data. We will change the previous Function implementation: func FuncDemo3Handler(ctx context.Context, flow kis.Flow) error { fmt.Println("---> Call funcName3Handler ----") fmt.Printf("Params = %+vn", flow.GetFuncParamAll()) for _, row := range flow.Input() { str := fmt.Sprintf("In FuncName = %s, FuncId = %s, row = %s", flow.GetThisFuncConf().FName, flow.GetThisFunction().GetId(), row) fmt.Println(str) }…

Github: https://github.com/aceld/kis-flowDocument: https://github.com/aceld/kis-flow/wiki Part1-OverViewPart2.1-Project Construction / Basic ModulesPart2.2-Project Construction / Basic ModulesPart3-Data StreamPart4-Function SchedulingPart5-ConnectorPart6-Configuration Import and ExportPart7-KisFlow ActionPart8-Cache/Params Data Caching and Data Parameters To be continued. 8.1 Flow Cache - Data Stream Caching KisFlow also provides shared caching in stream computing, using a simple local cache for developers to use as needed. For third-party local cache technology dependencies, refer to: https://github.com/patrickmn/go-cache. 8.1.1 go-cache (1) Installation go get github.com/patrickmn/go-cache Enter fullscreen mode Exit fullscreen mode (2) Usage import ( "fmt" "github.com/patrickmn/go-cache" "time" ) func main() { // Create a cache with a default expiration time of 5 minutes, and which //…