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]