本文檔為您展示一個示例，在本例中，我們將準備一份U2I召回數據（假設數據表的表名為aime_example_u2i），一份I2I召回數據（假設數據表的表名為aime_example_i2i），然后在智能召回引擎控制臺上注冊數據，最后用這兩份數據拉起一個U2I2I召回服務。

數據準備

準備U2I召回表

在MaxCompute客戶端中準備離線數據

-- 創建數據表
CREATE TABLE IF NOT EXISTS aime_example_u2i (
  user_id STRING COMMENT "用戶ID",
  item_id STRING COMMENT "物品ID",
  logtime BIGINT COMMENT "時間"
) PARTITIONED BY (
  ds STRING COMMENT "分區字段"
);

-- 寫入U2I數據，實際業務場景下，具體的寫入數據由您的算法邏輯產出
INSERT OVERWRITE TABLE aime_example_u2i PARTITION (ds = '20230101')
SELECT 'A' AS user_id, '10001' AS item_id, 1672502401  AS logtime UNION
SELECT 'A' AS user_id, '10002' AS item_id, 1672502402  AS logtime UNION
SELECT 'B' AS user_id, '10001' AS item_id, 1672502403  AS logtime UNION
SELECT 'C' AS user_id, '10003' AS item_id, 1672502404  AS logtime;

-- 寫入標識分區
INSERT OVERWRITE TABLE aime_example_u2i PARTITION (ds = '20230101.done')
SELECT NULL, NULL, NULL UNION;

在智能召回引擎控制臺上注冊數據

進入實例詳情-數據管理頁面，點擊“注冊數據”。

配置基礎信息：

點擊“保存并上線”，完成注冊并發布。

準備I2I召回表

在MaxCompute客戶端中準備離線數據

-- 創建數據表
CREATE TABLE IF NOT EXISTS aime_example_i2i (
  trigger_id STRING COMMENT "召回字段",
  item_id STRING COMMENT "物品ID",
  score DOUBLE COMMENT "召回分"
) PARTITIONED BY (
  ds STRING COMMENT "分區字段"
);

-- 寫入I2I數據，實際業務場景下，具體的寫入數據由您的算法邏輯產出
INSERT OVERWRITE TABLE aime_example_i2i PARTITION (ds = '20230101')
SELECT '10001' AS trigger_id, '10004' AS item_id, 1.12 AS score UNION
SELECT '10001' AS trigger_id, '10005' AS item_id, 1.07 AS score UNION
SELECT '10002' AS trigger_id, '10006' AS item_id, 0.98 AS score UNION
SELECT '10003' AS trigger_id, '10007' AS item_id, 0.87 AS score;

-- 寫入標識分區
INSERT OVERWRITE TABLE aime_example_i2i PARTITION (ds = '20230101.done')
SELECT NULL, NULL, NULL UNION;

在智能召回引擎控制臺上注冊數據

進入實例詳情-數據管理頁面，點擊“注冊數據”。

配置基礎信息：

點擊“保存并上線”，完成注冊并發布。

?

服務注冊

在實例詳情-服務管理中，點擊“創建召回服務”按鈕，開始創建召回服務。

配置服務基礎信息

配置數據，選擇我們剛才準備好的數據，U2I2I召回服務是根據user查找item1，再根據item1查找item2，因此“Recall”召回這里選擇u2i召回表，同時，需要join關聯 i2i召回表。

新增算子類型“Join關聯”

增加算子“Sorter排序”，可根據i2i召回表中score召回分對返回物品排序（可選）。

可根據業務情況自行選擇新增或刪除算子。

此時U2I2I召回鏈路配置完成，由于BE召回引擎支持多路召回，因此需要設置歸并結果的去重字段（字段自選）。

點擊“保存并上線”，完成注冊并發布。

進入服務管理，可以看到我們剛才創建的召回服務，等待其發布完成，就可以使用了。