【LangChain 】RunnablePassthrough 两种写法对比：`.assign()` 的参数到底要不要包 `RunnableLambda`？
RunnablePassthrough 两种写法对比：.assign()的参数到底要不要包RunnableLambda？
一、两种调用方式对比
LangChain 提供了两种调用assign的方式，功能等价但写法不同。
1.1 写法一：实例方法.assign()
fromlangchain_core.runnablesimportRunnableParallel,RunnablePassthrough chain=RunnableParallel(passed=RunnablePassthrough().assign(modified=lambdax:x["k1"]+"!!!"),)1.2 写法二：类方法assign()
fromlangchain_core.runnablesimportRunnablePassthroughdefget_user_age(data):return25chain=RunnablePassthrough.assign(age=get_user_age)二、核心对比
| 对比项 | 写法一：RunnablePassthrough().assign(...) | 写法二：RunnablePassthrough.assign(...) |
|---|---|---|
| 调用方式 | 实例方法（先创建实例再调用） | 类方法（直接通过类调用） |
| 返回值 | Runnable实例 | Runnable实例 |
| 功能效果 | 保留原字段 + 添加新字段 | 保留原字段 + 添加新字段 |
| 使用场景 | 通常配合RunnableParallel使用 | 通常作为独立步骤使用 |
| 本质区别 | 先实例化再配置 | 类级别的工厂方法 |
结论：两种写法功能完全等价，选择取决于代码上下文和个人习惯。
三、参数要不要包RunnableLambda？
这是最容易混淆的地方。答案是：在.assign()里不需要，在管道运算符\|里需要。
3.1 不需要包的场景
以下方法内部会自动把函数或 Lambda 包装成RunnableLambda：
fromlangchain_core.runnablesimportRunnablePassthrough,RunnableParalleldefget_user_age(data):return25# ✅ RunnablePassthrough.assign() —— 自动转换chain1=RunnablePassthrough.assign(age=get_user_age)# ✅ RunnableParallel() —— 自动转换chain2=RunnableParallel({"result":lambdax:x["name"].upper()})# ✅ 直接传 lambda —— 自动转换chain3=RunnablePassthrough().assign(modified=lambdax:x["k1"]+"!!!")3.2 需要包的场景
管道运算符\|只接受Runnable对象，不会自动转换：
fromlangchain_core.runnablesimportRunnableLambda# ❌ 错误：普通函数不能直接接在管道里chain_bad=step1|get_user_age|step2# ✅ 正确：必须手动包一层 RunnableLambdachain_good=step1|RunnableLambda(get_user_age)|step2四、四种等价写法实测
fromlangchain_core.runnablesimportRunnablePassthrough,RunnableLambdadefget_user_age(data):return25# 写法1：直接传函数（最简洁，推荐）r1=RunnablePassthrough.assign(age=get_user_age)# 写法2：传 lambda（也简洁）r2=RunnablePassthrough.assign(age=lambdax:25)# 写法3：手动包 RunnableLambda（啰嗦，但效果一样）r3=RunnablePassthrough.assign(age=RunnableLambda(get_user_age))# 写法4：实例方式调用r4=RunnablePassthrough().assign(age=get_user_age)# 测试forrin[r1,r2,r3,r4]:result=r.invoke({"name":"Alice"})print(result)输出：
{'name':'Alice','age':25}{'name':'Alice','age':25}{'name':'Alice','age':25}{'name':'Alice','age':25}五、自动转换方法汇总
| 方法/类 | 自动转换函数为 RunnableLambda？ |
|---|---|
RunnablePassthrough.assign() | ✅ 是 |
RunnableParallel() | ✅ 是 |
RunnableLambda()构造函数 | ✅ 是（当然） |
管道运算符| | ❌ 否 |
RunnableSequence() | ❌ 否 |
六、最佳实践建议
| 场景 | 推荐写法 | 原因 |
|---|---|---|
.assign()里传函数 | age=get_user_age | 最简洁，可读性最好 |
.assign()里简单逻辑 | age=lambda x: ... | 无需定义额外函数 |
管道|里传函数 | RunnableLambda(func) | 必须手动包，否则报错 |
配合RunnableParallel | RunnablePassthrough().assign(...) | 实例方式更自然 |
七、一句话总结
.assign()和RunnableParallel是"友好"的 API，看到函数会自动帮你包成RunnableLambda；但管道运算符\|是"严格"的，只接受 Runnable 对象，不会自动转换。在
.assign()里直接写函数或 Lambda 就行，别画蛇添足包RunnableLambda。