异步工具运行回调管理器#

class langchain_core.callbacks.manager.AsyncCallbackManagerForToolRun(*, 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)[source]#

工具运行的异步回调管理器。

初始化运行管理器。

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。

方法

__init__(*, run_id, handlers, ...[, ...])

初始化运行管理器。

get_child([tag])

获取一个子回调管理器。

get_noop_manager()

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

get_sync()

获取等效的同步 RunManager。

on_custom_event(name, data, *, run_id[, ...])

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

on_retry(retry_state, **kwargs)

当接收到重试时异步运行。

on_text(text, **kwargs)

当接收到文本时运行。

on_tool_end(output, **kwargs)

工具结束运行时异步执行。

on_tool_error(error, **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() → CallbackManagerForToolRun[来源]#

获取等效的同步RunManager。

Returns:

同步运行管理器。

Return type:

CallbackManagerForToolRun

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:

任何

async on_tool_end(output: Any, **kwargs: Any) → None[source]#

当工具结束运行时异步运行。

Parameters:

  • output (Any) – 工具的输出。

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

Return type:

无

async on_tool_error(error: BaseException, **kwargs: Any) → None[source]#

当工具出错时运行。

Parameters:

  • error (Exception 或 KeyboardInterrupt) – 错误。

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

Return type:

无

使用 AsyncCallbackManagerForToolRun 的示例