langchain_core.callbacks.manager
.atrace_as_chain_group¶
- langchain_core.callbacks.manager.atrace_as_chain_group(group_name: str, callback_manager: Optional[AsyncCallbackManager] = None, *, inputs: Optional[Dict[str, Any]] = None, project_name: Optional[str] = None, example_id: Optional[Union[str, UUID]] = None, run_id: Optional[UUID] = None, tags: Optional[List[str]] = None, metadata: Optional[Dict[str, Any]] = None) AsyncGenerator[AsyncCallbackManagerForChainGroup, None] [source]¶
获取一个用于链式组中的上下文管理器的异步回调管理器。 用于将不同的异步调用组合在一起,即使它们并不在一个单一的链中组成。
- 参数:
group_name (str): 链式组的名称。 callback_manager (AsyncCallbackManager, 可选): 要使用的异步回调管理器,用于管理跟踪和其他回调行为。 project_name (str, 可选): 项目的名称。默认为None。 example_id (str 或 UUID, 可选): 示例的ID。默认为None。 run_id (UUID, 可选): 运行的ID。 tags (List[str], 可选): 应用于所有运行的可继承标签。默认为None。 metadata (Dict[str, Any], 可选): 应用于所有运行的元数据。默认为None。
- 返回:
AsyncCallbackManager: 用于链式组的异步回调管理器。
注意:必须将LANGCHAIN_TRACING_V2环境变量设置为true,才能在LangSmith中看到跟踪。
- 示例:
llm_input = "Foo" async with atrace_as_chain_group("group_name", inputs={"input": llm_input}) as manager: # 使用链式组的异步回调管理器 res = await llm.ainvoke(llm_input, {"callbacks": manager}) await manager.on_chain_end({"output": res})
- Parameters
group_name (str) –
callback_manager (Optional[AsyncCallbackManager]) –
inputs (Optional[Dict[str, Any]]) –
project_name (Optional[str]) –
example_id (Optional[Union[str, UUID]]) –
run_id (Optional[UUID]) –
tags (Optional[List[str]]) –
metadata (Optional[Dict[str, Any]]) –
- Return type
AsyncGenerator[AsyncCallbackManagerForChainGroup, None]