PAI-Rec的RealTimeU2IRecall 如何使用内置的i2i 缓存功能

概述

RealTimeU2IRecall 内置了 I2I（物品到物品）缓存功能，可以对 trigger item 的相似 item 列表进行本地内存缓存，在保留用户行为实时性的同时，减少 FeatureStore 的查询压力。

配置方式

在 RecallConfs 的 RealTimeUser2ItemDaoConf 中添加 I2ICacheSize 和 I2ICacheTime：

{
   
  "RecallConfs": [
    {
   
      "Name": "realtime_u2i",
      "RecallType": "RealTimeU2IRecall",
      "RecallCount": 200,
      "RealTimeUser2ItemDaoConf": {
   
        "UserTriggerDaoConf": {
   
          "FeatureStoreName": "fs_pairec",
          "FeatureStoreViewName": "user_behavior_seq",
          "ItemCount": 20,
          "TriggerCount": 10,
          "EventWeight": "click:1.0;buy:3.0",
          "WeightExpression": "1.0 / (1.0 + (currentTime - eventTime) / 3600.0)"
        },
        "Item2ItemFeatureViewName": "item_i2i_table",
        "I2ICacheSize": 100000,
        "I2ICacheTime": 3600
      }
    }
  ]
}

配置字段说明

缓存工作原理

执行流程

用户请求
  ↓
1. 从 FeatureStore 读取用户行为序列
   → 得到 trigger item 列表（如 [itemA, itemB, itemC]）
  ↓
2. 对每个 trigger item，查 I2I 缓存：
   - cache.GetIfPresent("itemA") → 命中：直接用缓存的相似 item 列表
   - cache.GetIfPresent("itemB") → 未命中：加入待查询列表
  ↓
3. 对未命中缓存的 trigger item，批量查 FeatureStore 的 I2I 表
  ↓
4. 查到的结果写入缓存：
   cache.Put("itemB", "sim_item1:0.9,sim_item2:0.8,...")
  ↓
5. 如果某个 trigger item 在 I2I 表中无数据，写入空值（负缓存）：
   cache.Put("itemX", "")

核心逻辑说明

• Cache Key：trigger item 的 item_id
• Cache Value：该 item 的相似 item 列表，格式为 item_id1:score1,item_id2:score2,...
• 负缓存：如果某个 trigger item 在 I2I 表中查不到数据，会写入空字符串，避免每次都去查 FeatureStore
• 缓存类型：本地内存 LRU 缓存（基于 cache.New），不依赖外部 Redis

与 BaseRecall 用户级缓存的对比

RealTimeU2IRecall 支持两层缓存，它们作用在不同层级：

两层缓存配置示例

如果同时启用两层缓存：

{
   
  "RecallConfs": [
    {
   
      "Name": "realtime_u2i",
      "RecallType": "RealTimeU2IRecall",
      "RecallCount": 200,
      "CacheAdapter": "redis",
      "CacheConfig": "{\"redisName\": \"your_redis_name\"}",
      "CachePrefix": "rt_u2i_",
      "CacheTime": 60,
      "RealTimeUser2ItemDaoConf": {
   
        "UserTriggerDaoConf": {
    ... },
        "Item2ItemFeatureViewName": "item_i2i_table",
        "I2ICacheSize": 100000,
        "I2ICacheTime": 3600
      }
    }
  ]
}

执行顺序：

1. 先查 用户级缓存（Redis），命中则直接返回
2. 未命中 → 实时获取用户 trigger → 对每个 trigger 查 I2I 缓存（本地内存）
3. I2I 缓存未命中的 → 查 FeatureStore → 写回 I2I 缓存
4. 最终结果写回用户级缓存（Redis）

推荐配置

注意事项

1. 内存占用：I2I 缓存是本地内存缓存，I2ICacheSize 设置过大会增加内存占用。每个缓存条目大约占用几百字节到几 KB（取决于相似 item 数量）
2. 多实例不共享：本地缓存在每个引擎实例独立维护，不同实例的缓存不共享，冷启动时各实例需要独立预热
3. 负缓存：I2I 表中查不到数据的 item 也会被缓存（空字符串），避免重复查询。如果 I2I 数据后续补充了，需等缓存过期后才能生效
4. 与用户级缓存的关系：建议只启用 I2I 缓存，不启用用户级缓存，这样可以保留用户行为的实时性