AsyncCallbackManagerForChainRun

class langchain_core.callbacks.manager.AsyncCallbackManagerForChainRun(*, run_id: UUID, handlers: list[BaseCallbackHandler], inheritable_handlers: list[BaseCallbackHandler], parent_run_id: UUID | None = None, tags: list[str] | None = None, inheritable_tags: list[str] | None = None, metadata: dict[str, Any] | None = None, inheritable_metadata: dict[str, Any] | None = None)

用于链运行的异步回调管理器。

初始化运行管理器。

Parameters:

• run_id (UUID) – 运行的ID。

• handlers (List[BaseCallbackHandler]) – 处理程序列表。

• inheritable_handlers (List[BaseCallbackHandler]) – 可继承的处理程序列表。

• parent_run_id (UUID, optional) – 父运行的ID。默认为None。

• tags (可选[列表[str]]) – 标签列表。默认为 None。

• inheritable_tags (Optional[List[str]]) – 可继承标签的列表。 默认为 None。

• metadata (可选[字典[字符串, 任意类型]]) – 元数据。 默认为 None。

• inheritable_metadata (Optional[Dict[str, Any]]) – 可继承的元数据。 默认为 None。

方法

__init__(*, run_id, handlers, ...[, ...])	初始化运行管理器。
get_child([tag])	获取一个子回调管理器。
get_noop_manager()	返回一个不执行任何操作的管理器。
get_sync()	获取等效的同步 RunManager。
on_agent_action(action, **kwargs)	当接收到代理动作时运行。
on_agent_finish(finish, **kwargs)	当接收到代理完成时运行。
on_chain_end(outputs, **kwargs)	当链结束时运行。
on_chain_error(error, **kwargs)	当链发生错误时运行。
on_custom_event(name, data, *, run_id[, ...])	重写以定义自定义事件的处理程序。
on_retry(retry_state, **kwargs)	异步运行当接收到重试时。
on_text(text, **kwargs)	当接收到文本时运行。

__init__(*, run_id: UUID, handlers: list[BaseCallbackHandler], inheritable_handlers: list[BaseCallbackHandler], parent_run_id: UUID | None = None, tags: list[str] | None = None, inheritable_tags: list[str] | None = None, metadata: dict[str, Any] | None = None, inheritable_metadata: dict[str, Any] | None = None) → None

初始化运行管理器。

Parameters:

• run_id (UUID) – 运行的ID。

• handlers (List[BaseCallbackHandler]) – 处理程序列表。

• inheritable_handlers (List[BaseCallbackHandler]) – 可继承的处理程序列表。

• parent_run_id (UUID, optional) – 父运行的ID。默认为None。

• tags (可选[列表[字符串]]) – 标签列表。默认为 None。

• inheritable_tags (Optional[List[str]]) – 可继承标签的列表。 默认为 None。

• metadata (可选[字典[字符串, 任意类型]]) – 元数据。 默认为 None。

• inheritable_metadata (Optional[Dict[str, Any]]) – 可继承的元数据。 默认为 None。

Return type:

无

get_child(tag: str | None = None) → AsyncCallbackManager

获取一个子回调管理器。

Parameters:

tag (str, optional) – 子回调管理器的标签。 默认为 None。

Returns:

子回调管理器。

Return type:

AsyncCallbackManager

classmethod get_noop_manager() → BRM

返回一个不执行任何操作的管理器。

Returns:

无操作管理器。

Return type:

BaseRunManager

get_sync() → CallbackManagerForChainRun

获取等效的同步RunManager。

Returns:

同步运行管理器。

Return type:

CallbackManagerForChainRun

async on_agent_action(action: AgentAction, **kwargs: Any) → Any

当接收到代理操作时运行。

Parameters:

• action (AgentAction) – 代理动作。

• **kwargs (Any) – 额外的关键字参数。

Returns:

回调的结果。

Return type:

任何

async on_agent_finish(finish: AgentFinish, **kwargs: Any) → Any

当接收到代理完成时运行。

Parameters:

• finish (AgentFinish) – 代理完成。

• **kwargs (Any) – 额外的关键字参数。

Returns:

回调的结果。

Return type:

任何

async on_chain_end(outputs: dict[str, Any] | Any, **kwargs: Any) → None

当链结束运行时执行。

Parameters:

• outputs (Union[Dict[str, Any], Any]) – 链的输出。

• **kwargs (Any) – 额外的关键字参数。

Return type:

无

async on_chain_error(error: BaseException, **kwargs: Any) → None

当链发生错误时运行。

Parameters:

• error (Exception 或 KeyboardInterrupt) – 错误。

• **kwargs (Any) – 额外的关键字参数。

Return type:

无

on_custom_event(name: str, data: Any, *, run_id: UUID, tags: list[str] | None = None, metadata: dict[str, Any] | None = None, **kwargs: Any) → Any

重写以定义自定义事件的处理程序。

Parameters:

• name (str) – 自定义事件的名称。

• data (Any) – 自定义事件的数据。格式将与用户指定的格式匹配。

• run_id (UUID) – 运行的ID。

• tags (list[str] | None) – 与自定义事件关联的标签（包括继承的标签）。

• metadata (dict[str, Any] | None) – 与自定义事件关联的元数据 （包括继承的元数据）。

• kwargs (Any)

Return type:

任何

在版本0.2.15中添加。

async on_retry(retry_state: RetryCallState, **kwargs: Any) → None

当收到重试时异步运行。

Parameters:

• retry_state (RetryCallState) – 重试状态。

• **kwargs (Any) – 额外的关键字参数。

Return type:

无

async on_text(text: str, **kwargs: Any) → Any

当接收到文本时运行。

Parameters:

• text (str) – 接收到的文本。

• **kwargs (Any) – 额外的关键字参数。

Returns:

回调的结果。

Return type:

任何