图文个性化推荐案例

更新时间：2023-11-16

一、业务背景

某生活APP是以提供本地生活服务为主的一站式本地生活服务平台，覆盖餐饮、出行、公共服务、娱乐、购物、健康等生态，提供点餐、买单、外卖、等服务，以美食餐饮为主场景，为了提高APP商业转化和用户活跃率，需要以种草内容推荐带动各个板块业务目标。本案例主要介绍了使用智能推荐引擎实现图文类物料的个性化场景推荐。

二、数据准备

1、物料数据schema规范数据样例：144 rows × 9 columns 家居40条、科技40条、美食60

2、行为数据schema规范数据样例：155条

3、用户数据schema规范（非必传）样例数据：18条

三、创建应用

在应用管理页，单击顶部【创建应用】按钮，进入创建应用页面，依次填写应用各项参数，选择图文推荐。点击【创建】按钮，进入创建应用提示页面，进入应用配置页面。

四、接入数据

进入应用配置页面，在数据接入选项卡下点击数据API卡片右上角的【启用服务】按钮一键开启3个数据接入服务。点击【刷新状态】按钮，直到三个服务的状态都显示为“服务中”时，即可根据生成的请求地址接入数据了。

1、了解使用SDK方式接入数据的流程：

第1步：下载代码模版，下载并解压代码模版（python文件），请仔细阅读readme.md文件。

第2步：下载并替换鉴权信息，点击下载鉴权信息，并参考代码模板中readme.md文件进行修改。

第3步：接入数据，返回'success':true即表明接入成功，刷新数据状态，接入必传数据即可。

2、分别接入三类数据

第一步：接入csv中的物料数据

注意：本案例脚本代码与sdk提供的存在差异仅供参考，您需要根据实际业务使用sdk中的代码或者开发代码。

"""
从csv中发送物料数据给cms
"""
import os
import time
import requests
import json
import pandas as pd

def post_m(dic):
    ctx = json.dumps(dic, ensure_ascii=False)
    ctx = ctx.encode("utf-8")
    rex = requests.post(url, ctx, headers=headers)
    return rex

url = "http://airec.baidu.com/airec/api/1-s6r5gitg/omni/cms/batch-sync"
ak = "f5695cc1c9544ccd9088b29b417d395b"

headers = {"Content-Type": "application/json", "X-Gw-Ak": ak}
cmsdata = pd.read_csv('/Users/wangxuecong01/Desktop/1产品管理/1智能推荐引擎/演示数据/CMSdemo.csv')

for idx, data in cmsdata.iterrows():
    demo_cms= [{
    "nid": str(data['nid']),
    "site_name":data['site_name'],
    "title":data['title'],
    "content":data['content'],
    "mthid":str(data['mthid']),
    "publish_time":data['publish_time'],
    "att":[data['att']],
    "status":data['status'],
    "ts":data['ts']
    }]

    begin = time.time()
    rex = post_m(demo_cms)
    end = time.time()
    print("using time: {}, status {}, ret content: {}".format(round(end - begin, 6), rex.status_code, rex.text))

第二步：接入csv中的用户数据

"""
发送用户数据给ums
"""

import os
import time
import requests
import json
import pandas as pd

def post_m(dic):
    ctx = json.dumps(dic, ensure_ascii=False)
    ctx = ctx.encode("utf-8")
    rex = requests.post(url, ctx, headers=headers)
    return rex

url = "http://airec.baidu.com/airec/api/1-fd8wpxd0/omni/ums/batch-sync"
ak = "f5695cc1c9544ccd9088b29b417d395b"

headers = {"Content-Type": "application/json", "X-Gw-Ak": ak}

umsdata = pd.read_csv('/Users/文件路径/演示数据/UMSdemo.csv')
for idx, data in umsdata.iterrows():
    demo_ums = [{
    "uid":str(data['uid'])
    }]
    begin = time.time()
    rex = post_m(demo_ums)
    end = time.time()
    print("using time: {}, status {}, ret content: {}".format(round(end - begin, 6), rex.status_code, rex.text))

第三步：接入csv中的用户数据

"""
发送用户数据给ums
"""

import os
import time
import requests
import json
import pandas as pd

def post_m(dic):
    ctx = json.dumps(dic, ensure_ascii=False)
    ctx = ctx.encode("utf-8")
    rex = requests.post(url, ctx, headers=headers)
    return rex

url = "http://airec.baidu.com/airec/api/1-fd8wpxd0/omni/ims/batch-sync"
ak = "f5695cc1c9544ccd9088b29b417d395b"

headers = {"Content-Type": "application/json", "X-Gw-Ak": ak}

imsdata = pd.read_csv('/文件路径演示数据/IMSdemo.csv')
for idx, data in imsdata.iterrows():
    demo_ims = [{
    "nid":str(data['nid']),    
    "uid":str(data['uid']),
    "event":data['event'],
    "ts":data['ts']
    }]

    begin = time.time()
    rex = post_m(demo_ims)
    end = time.time()
    print("using time: {}, status {}, ret content: {}".format(round(end - begin, 6), rex.status_code, rex.text)

3、验证是否成功接入数据

在配置应用页面基础信息卡片查看数据接入条数是否符合预期。

五、服务调用

1、启用服务

进入智能推荐引擎配置页面，在服务调用选项卡下点击推荐API卡片【启用】按钮开启需要调用的服务。

点击【刷新状态】按钮，直到服务的状态都显示为“服务中”时，即可根据生成的请求地址调用接口。

2、了解调用流程

第1步：下载代码模版，下载并解压代码模版（python文件），请仔细阅读readme.md文件。第2步：下载并替换鉴权信息，点击下载鉴权信息，并参考代码模板中readme.md文件进行修改。第3步：调用服务，获取返回的推荐结果。第4步：验证结果，正确返回值类似, status值应为 200。

3、开始调用接口

调用个性化接口

 """
个性化推荐接口
"""

import os

import time
import requests
import json


def post_m(dic):
    rex = requests.get(url, dic, headers=headers)
    return rex


url = "http://10.137.16.168:8081/airec/api/3-zo179t-l/rec/p_rec"
ak = "f5695cc1c9544ccd9088b29b417d395b"

headers = {"Content-Type": "application/json", "X-Gw-Ak": ak}

body = {
    "uid": "uid_1",
    "req_cnt": 20
}

begin = time.time()
rex = post_m(body)
end = time.time()
print("using time: {}, status {}, ret content: {}".format(round(end - begin, 6), rex.status_code, rex.text))