智能中枢 · 组件
持久化的增量刷新与过期队列
可用 合成数据 T7 · Agent 步骤链
功能
按目标或实体合并进行中的刷新请求,把依赖的审计标记为过期,分批处理信号到商机和审计的刷新,并保留尝试次数、错误和状态摘要。
核心模式
合并重复刷新请求+标记下游过期
- 输入
- Target layer, entity identifier, trigger/reason, payload and batch limit
- 输出
- Persisted queue item, refresh-run status and per-layer counters
关键参数
| 名称 | 类型 | 默认值 | 取值 |
|---|---|---|---|
| operation | string | enqueue | enqueue · list · summary · process_opportunity · process_audit |
| target_layer | — | — | — |
| entity_type | — | — | — |
| trigger_source | — | — | — |
| reason | — | — | — |
成熟度与限制
可用
入队逻辑检查排队或处理中记录并更新或新建;工作进程按先进先出选择任务,记录处理状态和尝试次数,调用刷新服务并写入终态。此等级依据静态源码检查,不代表运行测试、真实服务接入或生产部署已通过验证。
不是分布式队列:已检查的选择与更新过程没有租约或跳过已锁记录的认领机制。并发入队或工作进程可能竞争,重新入队还可能重置处理状态。须限制为单工作进程,或增加事务认领。