Skip to content

LangChain Runnable

TIP

Runnable 是 LangChain 的核心抽象接口,提供统一的调用、批处理、流式处理。

批处理

python
chain = prompt | llm | parser

results = chain.batch([
    {"concept": "梯度下降"},
    {"concept": "反向传播"},
    {"concept": "损失函数"}
])

流式输出

python
for chunk in chain.stream({"concept": "Transformer"}):
    print(chunk, end="", flush=True)

RunnablePassthrough

python
from langchain_core.runnables import RunnablePassthrough

chain = (
    RunnablePassthrough.assign(
        processed=lambda x: preprocess(x["input"])
    )
    | prompt | llm | parser
)