![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260204022455-6982adf789bdd.png\")
<\/p>\n\u5728AI\u5e94\u7528\u5feb\u901f\u5de5\u7a0b\u5316\u7684\u4eca\u5929\uff0cPython\u751f\u6001\u51ed\u501fLangChain\u3001LlamaIndex\u7b49\u6846\u67b6\u5360\u636e\u4e86\u7edd\u5bf9\u4e3b\u5bfc\u5730\u4f4d\u3002\u7136\u800c\uff0c\u968f\u7740AI\u5e94\u7528\u4ece\u5b9e\u9a8c\u539f\u578b\u8d70\u5411\u5927\u89c4\u6a21\u751f\u4ea7\u90e8\u7f72\uff0cPython\u52a8\u6001\u7c7b\u578b\u7684\u77ed\u677f\u9010\u6e10\u51f8\u663e\uff1a\u7c7b\u578b\u5b89\u5168\u7f3a\u5931\u3001\u8fd0\u884c\u65f6\u9519\u8bef\u9891\u53d1\u3001\u957f\u671f\u7ef4\u62a4\u6210\u672c\u9ad8\u6602\uff0c\u8fd9\u4e9b\u95ee\u9898\u5728\u4f01\u4e1a\u7ea7\u573a\u666f\u4e2d\u5c24\u4e3a\u7a81\u51fa\u3002<\/p>\n
\u6b63\u662f\u5728\u8fd9\u4e00\u80cc\u666f\u4e0b\uff0c\u5b57\u8282\u8df3\u52a8CloudWeGo\u56e2\u961f\u4e8e2025\u5e74\u6b63\u5f0f\u5f00\u6e90\u4e86Eino\u6846\u67b6\u2014\u2014\u4e00\u4e2a\u57fa\u4e8eGo\u8bed\u8a00\u7684\u7ec8\u6781\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u6846\u67b6\u3002Eino\u4e0d\u4ec5\u586b\u8865\u4e86Go\u751f\u6001\u5728AI\u7f16\u6392\u9886\u57df\u7684\u7a7a\u767d\uff0c\u66f4\u5c06\u5b57\u8282\u5185\u90e8\u5728\u8c46\u5305\u3001\u6296\u97f3\u7b49\u6d77\u91cf\u4e1a\u52a1\u4e2d\u79ef\u7d2f\u7684AI\u5de5\u7a0b\u5316\u6700\u4f73\u5b9e\u8df5\u5e26\u7ed9\u4e86\u6574\u4e2a\u5f00\u6e90\u793e\u533a\u3002<\/p>\n
\u672c\u6587\u5c06\u6df1\u5ea6\u89e3\u6790Eino\u6846\u67b6\u7684\u67b6\u6784\u8bbe\u8ba1\u3001\u6838\u5fc3\u6a21\u5757\u5b9e\u73b0\uff0c\u5e76\u901a\u8fc7\u4e00\u4e2a\u5b8c\u6574\u7684\u4f01\u4e1a\u7ea7RAG\u7cfb\u7edf\u5b9e\u6218\u6848\u4f8b\uff0c\u5c55\u793a\u5982\u4f55\u5229\u7528Eino\u6784\u5efa\u9ad8\u6027\u80fd\u3001\u9ad8\u53ef\u9760\u7684\u591a\u667a\u80fd\u4f53\u5de5\u4f5c\u6d41\u3002<\/p>\n
Eino\u91c7\u7528\u5206\u5c42\u67b6\u6784\u8bbe\u8ba1\uff0c\u4ece\u4e0b\u5230\u4e0a\u5206\u4e3a\u56db\u4e2a\u6838\u5fc3\u5c42\u6b21\uff0c\u6bcf\u5c42\u804c\u8d23\u6e05\u6670\u3001\u89e3\u8026\u6027\u5f3a\uff0c\u540c\u65f6\u652f\u6301\u5355\u673a\u6a21\u5f0f\uff08\u6240\u6709\u7ec4\u4ef6\u5185\u5d4c\uff09\u548c\u96c6\u7fa4\u6a21\u5f0f\uff08\u7ec4\u4ef6\u72ec\u7acb\u90e8\u7f72\uff09\u3002<\/p>\n
<\/p>\n
\u56fe\uff1aEino\u6846\u67b6\u4f01\u4e1a\u7ea7\u56db\u5c42\u67b6\u6784\u8bbe\u8ba1\uff0c\u4ece\u4e0a\u5230\u4e0b\u4f9d\u6b21\u4e3a\u5e94\u7528\u5c42\u3001\u7f16\u6392\u6846\u67b6\u5c42\u3001\u7ec4\u4ef6\u5b9e\u73b0\u5c42\u548c\u57fa\u7840\u8bbe\u65bd\u5c42<\/p>\n
Eino\u7684Graph\u7f16\u6392\u5f15\u64ce\u662f\u5176\u6700\u6838\u5fc3\u7684\u7ade\u4e89\u529b\uff0c\u901a\u8fc7\u6709\u5411\u56fe\u7ed3\u6784\u5b9e\u73b0\u590d\u6742\u7684\u4e1a\u52a1\u903b\u8f91\u7f16\u6392\u3002\u4ee5\u4e0b\u662fGraph\u5f15\u64ce\u7684\u6838\u5fc3\u5b9e\u73b0\uff1a<\/p>\n
\/\/ src\/eino_agent\/graph_engine.go<\/p>\n
package main<\/p>\n
import (
\n \\”context\\”
\n \\”fmt\\”
\n \\”log\\”<\/p>\n
\\”github.com\/cloudwego\/eino\/compose\\”
\n \\”github.com\/cloudwego\/eino\/schema\\”
\n)<\/p>\n
\/\/ Graph\u7f16\u6392\u5f15\u64ce\u6838\u5fc3\u7ed3\u6784\u4f53
\ntype GraphOrchestrationEngine struct {
\n ctx context.Context
\n graph *compose.Graph
\n components map[string]interface{}
\n}<\/p>\n
\/\/ \u521b\u5efaGraph\u7f16\u6392\u5f15\u64ce\u5b9e\u4f8b
\nfunc NewGraphOrchestrationEngine(ctx context.Context) *GraphOrchestrationEngine {
\n return &GraphOrchestrationEngine{
\n ctx: ctx,
\n components: make(map[string]interface{}),
\n }
\n}<\/p>\n
\/\/ \u6784\u5efa\u4f01\u4e1a\u7ea7RAG\u5de5\u4f5c\u6d41
\nfunc (engine *GraphOrchestrationEngine) BuildEnterpriseRAGWorkflow() (*compose.CompiledGraph, error) {
\n \/\/ \u521d\u59cb\u5316Graph\u5b9e\u4f8b
\n engine.graph = compose.NewGraph[*schema.Message, *schema.Message](
\n \/\/ \u751f\u6210\u5c40\u90e8\u72b6\u6001\u7ba1\u7406\u51fd\u6570
\n compose.WithGenLocalState(func(ctx context.Context) *RAGState {
\n return &RAGState{
\n Query: \\”\\”,
\n RetrievedDocs: make([]*Document, 0),
\n Context: \\”\\”,
\n FinalAnswer: \\”\\”,
\n StepCount: 0,
\n }
\n }),
\n )<\/p>\n
\/\/ \u6dfb\u52a0\u667a\u80fd\u4f53\u7f16\u6392\u8282\u70b9
\n nodes := []struct {
\n key string
\n node compose.AnyNode
\n label string
\n }{
\n {\\”query_parser\\”, engine.buildQueryParserNode(), \\”\u67e5\u8be2\u89e3\u6790\u8282\u70b9\\”},
\n {\\”vector_retriever\\”, engine.buildVectorRetrieverNode(), \\”\u5411\u91cf\u68c0\u7d22\u8282\u70b9\\”},
\n {\\”reranker\\”, engine.buildRerankerNode(), \\”\u91cd\u6392\u5e8f\u8282\u70b9\\”},
\n {\\”context_builder\\”, engine.buildContextBuilderNode(), \\”\u4e0a\u4e0b\u6587\u6784\u5efa\u8282\u70b9\\”},
\n {\\”llm_generator\\”, engine.buildLLMGeneratorNode(), \\”\u5927\u6a21\u578b\u751f\u6210\u8282\u70b9\\”},
\n {\\”answer_validator\\”, engine.buildAnswerValidatorNode(), \\”\u7b54\u6848\u9a8c\u8bc1\u8282\u70b9\\”},
\n }<\/p>\n
\/\/ \u6279\u91cf\u6dfb\u52a0\u8282\u70b9\u5230Graph
\n for _, n := range nodes {
\n if err := engine.graph.AddNode(n.key, n.node, compose.WithNodeName(n.label)); err != nil {
\n return nil, fmt.Errorf(\\”\u6dfb\u52a0\u8282\u70b9 %s \u5931\u8d25: %v\\”, n.key, err)
\n }
\n engine.components[n.key] = n.node
\n }<\/p>\n
\/\/ \u5b9a\u4e49\u8282\u70b9\u95f4\u8fde\u63a5\u5173\u7cfb
\n connections := []struct {
\n from string
\n to string
\n cond func(*schema.Message) bool
\n }{
\n {\\”query_parser\\”, \\”vector_retriever\\”, nil},
\n {\\”vector_retriever\\”, \\”reranker\\”, nil},
\n {\\”reranker\\”, \\”context_builder\\”, nil},
\n {\\”context_builder\\”, \\”llm_generator\\”, nil},
\n {\\”llm_generator\\”, \\”answer_validator\\”, nil},
\n }<\/p>\n
\/\/ \u6279\u91cf\u6dfb\u52a0\u8fb9\u548c\u5206\u652f\u903b\u8f91
\n for _, conn := range connections {
\n if conn.cond != nil {
\n \/\/ \u6dfb\u52a0\u6761\u4ef6\u5206\u652f
\n branch := compose.NewGraphBranch(
\n func(ctx context.Context, msg *schema.Message) (string, error) {
\n if conn.cond(msg) {
\n return conn.to, nil
\n }
\n return compose.END, nil
\n },
\n map[string]bool{conn.to: true, compose.END: true},
\n )
\n if err := engine.graph.AddBranch(conn.from, branch); err != nil {
\n return nil, fmt.Errorf(\\”\u6dfb\u52a0\u5206\u652f %s->%s \u5931\u8d25: %v\\”, conn.from, conn.to, err)
\n }
\n } else {
\n \/\/ \u6dfb\u52a0\u76f4\u63a5\u8fb9
\n if err := engine.graph.AddEdge(conn.from, conn.to); err != nil {
\n return nil, fmt.Errorf(\\”\u6dfb\u52a0\u8fb9 %s->%s \u5931\u8d25: %v\\”, conn.from, conn.to, err)
\n }
\n }
\n }<\/p>\n
\/\/ \u6dfb\u52a0\u8d77\u59cb\u548c\u7ed3\u675f\u8fde\u63a5
\n if err := engine.graph.AddEdge(compose.START, \\”query_parser\\”); err != nil {
\n return nil, fmt.Errorf(\\”\u6dfb\u52a0\u8d77\u59cb\u8fb9\u5931\u8d25: %v\\”, err)
\n }<\/p>\n
\/\/ \u7f16\u8bd1Graph\u4e3a\u53ef\u6267\u884c\u5b9e\u4f8b
\n compiledGraph, err := engine.graph.Compile(engine.ctx,
\n compose.WithGraphName(\\”Enterprise_RAG_Workflow\\”),
\n compose.WithMaxRunSteps(10),
\n compose.WithCheckpointStore(engine.checkpointStore),
\n )<\/p>\n
if err != nil {
\n return nil, fmt.Errorf(\\”\u7f16\u8bd1Graph\u5931\u8d25: %v\\”, err)
\n }<\/p>\n
return compiledGraph, nil
\n}<\/p>\n
\/\/ RAG\u5de5\u4f5c\u6d41\u72b6\u6001\u7ba1\u7406\u7ed3\u6784\u4f53
\ntype RAGState struct {
\n Query string `json:\\”query\\”`
\n RetrievedDocs []*Document `json:\\”retrieved_docs\\”`
\n Context string `json:\\”context\\”`
\n FinalAnswer string `json:\\”final_answer\\”`
\n StepCount int `json:\\”step_count\\”`
\n}<\/p>\n
\/\/ \u6587\u6863\u7ed3\u6784\u4f53
\ntyp<\/p>\n","protected":false},"excerpt":{"rendered":"
\u5f15\u8a00\uff1a\u4e3a\u4ec0\u4e48Go\u751f\u6001\u9700\u8981\u81ea\u5df1\u7684AI\u7f16\u6392\u6846\u67b6\uff1f
\n\u5728AI\u5e94\u7528\u5feb\u901f\u5de5\u7a0b\u5316\u7684\u4eca\u5929\uff0cPython\u751f\u6001\u51ed\u501fLangChain\u3001LlamaIndex\u7b49\u6846\u67b6\u5360\u636e\u4e86\u7edd\u5bf9\u4e3b\u5bfc\u5730\u4f4d\u3002\u7136\u800c\uff0c\u968f\u7740AI\u5e94\u7528\u4ece\u5b9e\u9a8c\u539f\u578b\u8d70\u5411\u5927\u89c4\u6a21\u751f\u4ea7\u90e8\u7f72\uff0cPython\u52a8\u6001\u7c7b\u578b\u7684\u77ed\u677f\u9010\u6e10\u51f8\u663e\uff1a\u7c7b\u578b\u5b89\u5168\u7f3a\u5931\u3001\u8fd0\u884c\u65f6\u9519\u8bef\u9891\u53d1\u3001\u957f\u671f\u7ef4\u62a4\u6210\u672c\u9ad8\u6602\uff0c\u8fd9\u4e9b\u95ee\u9898\u5728\u4f01\u4e1a\u7ea7\u573a\u666f\u4e2d\u5c24\u4e3a\u7a81\u51fa\u3002
\n\u6b63\u662f\u5728\u8fd9\u4e00\u80cc\u666f\u4e0b\uff0c\u5b57\u8282\u8df3\u52a8CloudWeGo\u56e2\u961f\u4e8e2025\u5e74\u6b63\u5f0f\u5f00\u6e90\u4e86Eino\u6846\u67b6\u2014\u2014\u4e00\u4e2a\u57fa\u4e8eGo\u8bed\u8a00\u7684\u7ec8\u6781\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u6846\u67b6\u3002Eino\u4e0d\u4ec5\u586b\u8865\u4e86Go<\/p>\n","protected":false},"author":2,"featured_media":71770,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[746,292,190],"topic":[],"class_list":["post-71771","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-golang","tag-292","tag-190"],"yoast_head":"\n