接口地址 请求方式
https://beibei.dataoke.com/api/recommend/sendAction POST

背景说明

由贝贝公司回传用户行为数据，大淘客接收并进行流批一体的数据处理。

技术架构

核心服务

  1. openresty：
  • 基于 NGINX 的可伸缩的 Web 平台。
  1. lua
  • 轻量小巧的脚本语言。
  1. kafka-product
  • 消息队列
  • topic: client_recommend

单条回传数据格式

列名 类型 案例 说明
product_id string 432542 商品ID
user_id string 1343 用户ID
action_time string 1602739498 时间戳(秒)
event string expose 事件名称
location string 首页 页面模块名称
is_wifi string wifi 是否使用wifi
position string 四川-成都 位置(省-市)
app_version string 1.2.1 app的版本号
device string Xiaomi MIX 2S 设备型号
device_id string D23ED830268543269E75C52C25C8416E 设备ID号
sys_version string 13.6 操作系统版本号
ip string 171.88.41.123 客户端ip地址
event_value 1 事件的行为类型

json数据格式

  1. * 通过POST请求回传数据，BODY格式为JSON ARRAY，可以多条或单条回传。
  3. [
  4.     {
  5.         "product_id":"42421",
  6.         "user_id":"432421",
  7.         "action_time":"1602739498",
  8.         /* expose:曝光, click:点击, collect:收藏, purchase:购买, share:分享, hate:讨厌, digg:点赞:, comment:评论, search:搜索 */
  9.         "event":"expose",
  10.         /* home:首页, detail:详情页, search:收藏页 (模块页面需产品定义) */
  11.         "location":"home",
  12.         /* 1:使用wifi, 2:不使用wifi */
  13.         "is_wifi":"1",
  14.         "position":"四川-成都",
  15.         "app_version":"1.2.1",
  16.         "device":"Xiaomi MIX 2S",
  17.         /* 设备uuid */
  18.         "device_id":"D23ED830268543269E75C52C25C8416E",
  19.         "sys_version":"13.6",
  20.         "ip":"171.88.41.123",
  21.         /** 
  22.         * 正数: 事件的行为类型 1为正向行为，例如点赞成功。
  23.         * 0: 为无效行为，例如取消点赞。
  24.         * 负数: 为负向行为，例如-1不感兴趣，-2标题夸张，-3价格不符，-4内容质量差
  25.         **/
  26.         "event_value":"1"
  27.     },
  28.     {
  29.         "product_id":"42422",
  30.         "user_id":"432421",
  31.         "action_time":"1602739498",
  32.         "event":"click",
  33.         "location":"detail",
  34.         "is_wifi":"1",
  35.         "position":"四川-成都",
  36.         "app_version":"1.2.1",
  37.         "device":"Xiaomi MIX 2S",
  38.         "device_id":"D23ED830268543269E75C52C25C8416E",
  39.         "sys_version":"13.6",
  40.         "ip":"171.88.41.123",
  41.         "event_value":"0"
  42.     },
  43.     {
  44.         "product_id":"42421",
  45.         "user_id":"432421",
  46.         "action_time":"1602739498",
  47.         /* expose:曝光, click:点击, collect:收藏, purchase:购买, share:分享, hate:讨厌, digg:点赞:, comment:评论, search:搜索 */
  48.         "event":"hate",
  49.         /* home:首页, detail:详情页, search:收藏页 (模块页面需产品定义) */
  50.         "location":"home",
  51.         /* 1:使用wifi, 2:不使用wifi */
  52.         "is_wifi":"1",
  53.         "position":"四川-成都",
  54.         "app_version":"1.2.1",
  55.         "device":"Xiaomi MIX 2S",
  56.         /* 设备uuid */
  57.         "device_id":"D23ED830268543269E75C52C25C8416E",
  58.         "sys_version":"13.6",
  59.         "ip":"171.88.41.123",
  60.         /** 
  61.         * 正数: 事件的行为类型 1为正向行为，例如点赞成功。
  62.         * 0: 为无效行为，例如取消点赞。
  63.         * 负数: 为负向行为，例如-1不感兴趣，-2标题夸张，-3价格不符，-4内容质量差
  64.         **/
  65.         "event_value":"-1"
  66.     }
  67. ]

接口返回示例：

  1. * code:0代表成功,code:-1代表失败。
  2.   中间有几个判断:
  3.   1.是否是POST请求
  4.   2.是否json格式
  5.   3.是否写入kafka。
  6.   任意一个失败返回是-1。
  7. ------------------------------
  8. {
  9.   "code":0
  10. }