지능형 워크플로 만들기: Golang 기술 적용 실습

package main

import "fmt"

type Workflow struct {
    Nodes map[string]func(input interface{}) (output interface{})
    Connections map[string][]string
}

func (w *Workflow) Execute(nodeName string, input interface{}) interface{} {
    node := w.Nodes[nodeName]
    return node(input)
}

func main() {
    // 定义工作流节点
    nodes := map[string]func(input interface{}) (output interface{}){
        "node1": func(input interface{}) (output interface{}) {
            fmt.Println("Node 1 executed")
            return "Result from Node 1"
        },
        "node2": func(input interface{}) (output interface{}) {
            fmt.Println("Node 2 executed with input:", input)
            return "Result from Node 2"
        },
        "node3": func(input interface{}) (output interface{}) {
            fmt.Println("Node 3 executed with input:", input)
            return "Result from Node 3"
        },
    }

    // 定义工作流连接规则
    connections := map[string][]string{
        "node1": {"node2"},
        "node2": {"node3"},
    }

    // 创建工作流实例
    workflow := Workflow{
        Nodes: nodes,
        Connections: connections,
    }

    // 执行工作流
    input := "Initial input"
    currentNode := "node1"
    for currentNode != "" {
        input = workflow.Execute(currentNode, input)
        connectedNodes := connections[currentNode]
        if len(connectedNodes) > 0 {
            currentNode = connectedNodes[0]
        } else {
            currentNode = ""
        }
    }
}