langchain的runnables相关学习

处理链(Pipeline)详细解释

• 它就是一个工具，用于把组件按顺序连接起来，让数据依次通过这些组件的处理,使用管道符|来连接各个部件。

RunnablePassthrough

基本介绍

• RunnablePassthrough 是 LangChain 里的一个基础组件，它的主要作用是在处理链中传递数据，并且可以给数据添加额外的信息。简单来说，它能让数据原封不动地通过，同时可以在这个过程中对数据进行一些修改或者补充。

RunnablePassthrough.assign 详细解释

• 功能:

• RunnablePassthrough.assign 方法的作用是给输入的数据添加新的键值对。在处理链里，它可以用来为后续的组件提供必要的参数。

• 比如:

• from langchain_core.runnables import RunnablePassthrough
  
  # 创建一个简单的字典作为输入数据
  input_data = {"name": "Alice"}
  
  # 使用 RunnablePassthrough.assign 添加新的键值对
  new_data = RunnablePassthrough.assign(
      age=lambda _: 25,
      city=lambda _: "New York"
  ).invoke(input_data)
  
  print(new_data)
  

• 代码解释:

• RunnablePassthrough.assign 接收多个关键字参数，每个参数的值是一个函数。这些函数会接收输入数据作为参数，然后返回一个值。

• 在这个例子中，age=lambda _: 25 和 city=lambda _: "New York" 分别为输入数据添加了 age 和 city 这两个键值对。

• invoke 方法用于执行处理链，把输入数据传入并得到处理后的结果。