workflow字段映射
// 假设节点A输出类型为 SourceOutput { TaskID string; Query string }
// 假设节点B输入类型为 DestInput { JobID string; Question string }
wf.AddLambdaNode("nodeB", processor).
AddInput("nodeA", compose.MapFields("TaskID", "JobID"),
compose.MapFields("Query", "Question"))
// 这会将 nodeA 输出的 TaskID 映射到 nodeB 输入的 JobID,Query 映射到 Question。// 假设我们需要组合来自不同节点的数据
// 节点A输出:用户资料 UserProfile { Name string }
// 节点B输出:当前时间 CurrentTime { Timestamp string }
// 节点C输入:需要组合信息 FullInput { UserInfo UserProfile; Context string; TimeInfo string }
wf.AddLambdaNode("nodeC", complexProcessor).
AddInput("nodeA", compose.ToField("UserInfo")). // 将整个UserProfile对象放入UserInfo字段
AddInput("nodeB", compose.ToField("TimeInfo")) // 将整个CurrentTime对象放入TimeInfo字段
// 至于 Context 字段,可以从START节点或其他节点映射,或使用默认值。映射目标
核心 API
功能描述
适用场景举例
最后更新于