TrainingRouter
public class TrainingRouter implements Hook
io/agentscope/core/training/runner/TrainingRouter.java:69–351Training 路由器,对智能体行为进行评测、追踪与可观测性分析。位于 io.agentscope.core.training.runner 包,实现 Hook。核心成员包括 onEvent、priority、TrainingRouter。
Training Router Hook
Core training router Hook implementing shadow traffic training architecture with fully automated Task/Run ID management
Automation Flow:
-
PreCallEvent: No modifications, let request execute normally
-
PostCallEvent: Filter and judge, run shadow Agent asynchronously
-
Auto-generate Task ID: Independent task identifier for each request
-
Auto-allocate Run ID: Execution count for the same Task
-
Shadow Agent: Replace model with TrinityModelAdapter
-
Auto-collect msg_ids: Extract from Trinity API responses
-
Calculate Reward: Based on shadow Agent execution results
-
Submit Feedback: Batch submit all training data
Key Design:
-
100% requests use production model, ensuring service quality
-
Sample portion of requests run shadow Agent asynchronously, no user impact
-
Shadow Agent uses training model, collects training data
-
Completely transparent to users: All IDs managed automatically
构造器摘要Constructor Summary
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public T extends HookEvent Mono<T> onEvent(T event) | 处理事件事件。 Performs the on event operation. |
public int priority() | 返回优先级。 Returns the priority. |
构造器详情Constructor Detail
TrainingRouter
public TrainingRouter(TrainingConfig config, TrinityClient trinityClient, RewardCalculator rewardCalculator, TrainingSelectionStrategy selectionStrategy)
初始化 TrainingRouter 实例。
Creates a new instance.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
config | TrainingConfig | 配置对象(类型 `TrainingConfig`)。The config. |
trinityClient | TrinityClient | trinity 客户端(类型 `TrinityClient`)。The trinity client. |
rewardCalculator | RewardCalculator | reward Calculator(类型 `RewardCalculator`)。The reward calculator. |
selectionStrategy | TrainingSelectionStrategy | selection Strategy(类型 `TrainingSelectionStrategy`)。The selection strategy. |
io/agentscope/core/training/runner/TrainingRouter.java:81–95方法详情Method Detail
onEvent
public T extends HookEvent Mono<T> onEvent(T event)
处理事件事件。
Performs the on event operation.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
event | T | 事件(类型 `T`)。The event. |
Mono<T>io/agentscope/core/training/runner/TrainingRouter.java:97–109priority
public int priority()
返回优先级。
Returns the priority.
intio/agentscope/core/training/runner/TrainingRouter.java:111–114