特征配置

加载user或者item特征的配置介绍。

特征的配置对应配置总览中的 FeatureConfs,FeatureConfs 是一个 Map[string]object 结构,其中 key 为场景名,可以根据不同场景配置不同的特征

特征加载

在精排之前,需要从特征存储源里获取到 user 或者 item 的特征数据。

在某些情况下,获取到的特征数据还需要进一步做处理,比如根据已有的特征生成新的特征,根据现有特征进行组合等,都是支持的。

特征的加载支持多个数据源 hologres、redis、ots(tablestore)、PAI-FeatureStore 。

Hologres

配置示例

"FeatureConfs" :{
  "scene_name" :{
  "AsynLoadFeature" : true,
  "FeatureLoadConfs": [
    {
      "FeatureDaoConf": {
        "AdapterType": "hologres",
        "HologresName": "holo-pai",
        "FeatureKey": "user:uid",
        "UserFeatureKeyName" :"user_id",
        "HologresTableName": "recom_user_features_processed_holo_online",
        "UserSelectFields":"rids_count,sex,alladdfriendnum,allpayrosenum",
        "FeatureStore":"user"
     },
     "Features" :[]
    },
     {
      "FeatureDaoConf": {
        "AdapterType": "hologres",
        "HologresName": "holo-pai",
        "ItemFeatureKeyName" :"item_id",
        "FeatureKey": "item:id",
        "HologresTableName": "recom_user_features_processed_holo_online",
        "ItemSelectFields":"rids_count as rids2_count,sex as guestsex,alladdfriendnum as alladdfriendnum2",
        "FeatureStore":"item"
      },
     "Features" :[]
    }
   ]
  }
}

  • AsynLoadFeature: 是否异步的加载特征,当有多个 FeatureLoadConfs 时,可以异步并发的进行加载

FeatureLoadConfs/FeatureDaoConf

字段名

类型

是否必填

描述

AdapterType

string

数据源的类型,取值为 hologres

HologresName

string

在数据源配置(HologresConfs)中配置好的 holo 的自定义名称,如数据源配置中的 holo_info

FeatureKey

string

根据引擎中哪个特征,去特征表里进行查询。

FeatureKey 标明查找的值来自于 user 或者 item 的哪个字段。比如,user:uid 获取 user 的 uid 属性值,item:id 获取 item 的 id 的属性值。

UserFeatureKeyName

string

user 特征表的主键字段

ItemFeatureKeyName

string

item 特征表的主键字段

HologresTableName

string

holo 中特征表的表名

UserSelectFields

string

需要获取的 user 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

ItemSelectFields

string

需要获取的 item 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

FeatureStore

string

枚举值:user/item。表示特征获取到之后,存储到哪里

CacheSize

integer

本地缓存特征条目的数量,默认为0,说明不会缓存数据。

CacheTime

integer

本地缓存特征条目的过期时间,单位为秒。只有 CacheSize > 0 开启cache时才会有效。默认值为3600。

PAI-FeatureStore

PAI-FeatureStore 平台的使用配置参考FeatureStore概述

配置示例

{
  "FeatureConfs" :{
    "scene_name": {
      "AsynLoadFeature": true,
      "FeatureLoadConfs": [
      {
        "FeatureDaoConf": {
          "AdapterType": "featurestore",
          "FeatureStoreName": "pairec-fs",
          "FeatureKey": "user:uid",
          "FeatureStoreModelName": "rank_v1",
          "FeatureStoreEntityName": "user",
          "FeatureStore": "user"
        }
      }
     ]
    }
  }
}

FeatureLoadConfs/FeatureDaoConf

字段名

类型

是否必填

描述

AdapterType

string

数据源的类型,取值为 featurestore

FeatureStoreName

string

在数据源配置(FeatureStoreConfs)中配置好的 featurestore 的自定义名称,如数据源配置中的 pairec-fs

FeatureKey

string

根据引擎中哪个特征,去特征表里进行查询。

FeatureKey 标明查找的值来自于 user 或者 item 的哪个字段。比如,user:uid 获取 user 的 uid 属性值,item:id 获取 item 的 id 的属性值。

FeatureStoreModelName

string

特征平台(feature store)中的 modelfeature name

FeatureStoreEntityName

string

特征平台(feature store)中的 entity name

FeatureStore

string

枚举值:user/item。表示特征获取到之后,存储到哪里

CacheSize

integer

本地缓存特征条目的数量,默认为0,说明不会缓存数据。

CacheTime

integer

本地缓存特征条目的过期时间,单位为秒。只有 CacheSize > 0 开启cache时才会有效。默认值为3600。

上述配置是从模型特征 rank_v1 获取 user entity 的全部特征。如果要获取 item entity 的特征,可以配置如下:

{
  "FeatureConfs" :{
    "scene_name": {
      "AsynLoadFeature": true,
      "FeatureLoadConfs": [{
        "FeatureDaoConf": {
          "AdapterType": "featurestore",
          "FeatureStoreName": "pairec-fs",
          "FeatureKey": "item:id",
          "FeatureStoreModelName": "rank_v1",
          "FeatureStoreEntityName": "item",
          "FeatureStore": "item"
        }
      }]
    }
  }
}

但很多时候,我们只是需要获取某个 featureview 下的部分特征。比如获取 featureview 名为 user_table_preprocess_all_feature_v1 下的所有特征,放入 user 属性里。可以如下配置:

{
  "FeatureConfs" :{
    "scene_name": {
      "AsynLoadFeature": true,
      "FeatureLoadConfs": [{
        "FeatureDaoConf": {
          "AdapterType": "featurestore",
          "FeatureStoreName": "pairec-fs",
          "FeatureKey": "user:uid",
          "FeatureStoreViewName": "user_table_preprocess_all_feature_v1",
          "UserSelectFields": "*",
          "FeatureStore": "user"
        }
      },
      {
        "FeatureDaoConf": {
          "AdapterType": "featurestore",
          "FeatureStoreName": "pairec-fs",
          "FeatureKey": "item:id",
          "FeatureStoreViewName": "item_table_preprocess_all_feature_v1",
          "ItemSelectFields": "author,duration,category",
          "FeatureStore": "item"
        }
      }]
    }
  }
}

字段名

类型

是否必填

描述

FeatureStoreViewName

string

featureview 名称

UserSelectFields

string

需要获取的 user 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

ItemSelectFields

string

需要获取的 item 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

TableStore(OTS)

配置示例

"FeatureConfs" :{
  "scene_name" :{
    "AsynLoadFeature" : true,
    "FeatureLoadConfs": [{
      "FeatureDaoConf": {
        "AdapterType": "tablestore",
        "TableStoreName": "tablestore_info",
        "FeatureKey": "user:uid",
        "UserFeatureKeyName" :"uid",
        "TableStoreTableName" : "",
        "UserSelectFields":"*",
        "FeatureStore":"user"
      },
      "Features" :[]
    },
    {
      "FeatureDaoConf": {
        "AdapterType": "tablestore",
        "TableStoreName": "tablestore_info",
        "FeatureKey": "item:id",
        "ItemFeatureKeyName" :"item_id",
        "TableStoreTableName" : "",
        "ItemSelectFields":"*",
        "FeatureStore":"item"
       },
       "Features" :[]
     }]
  }
}

FeatureLoadConfs/FeatureDaoConf

字段名

类型

是否必填

描述

AdapterType

string

数据源的类型,取值为 tablestore

TableStoreName

string

在数据源配置(TableStoreConfs)中配置好的 tablestore 的自定义名称,如数据源配置中的 tablestore_info

FeatureKey

string

根据引擎中哪个特征,去特征表里进行查询。

FeatureKey 标明查找的值来自于 user 或者 item 的哪个字段。比如,user:uid 获取 user 的 uid 属性值,item:pair_id 获取 item 的 pair_id 的属性值。

UserFeatureKeyName

string

user 特征表的主键字段

ItemFeatureKeyName

string

item 特征表的主键字段

TableStoreTableName

string

tablestore 中特征表的表名

UserSelectFields

string

需要获取的 user 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

ItemSelectFields

string

需要获取的 item 特征,支持"*",表明获取所有,也可以 "feature1,feature2"

FeatureStore

string

枚举值:user/item。表示特征获取到之后,存储到哪里

CacheSize

integer

本地缓存特征条目的数量,默认为0,说明不会缓存数据。

CacheTime

integer

本地缓存特征条目的过期时间,单位为秒。只有 CacheSize > 0 开启cache时才会有效。默认值为3600。

Redis

Redis中存储数据比较灵活,可以通过KV形式的存储,V 可以是CSV格式,也可以是JSON格式。也可以通过HASH的方式存储,可以通过指定字段名称获取全部或者部分数据。

配置示例

"FeatureConfs" :{
  "scene_name" :{
  "AsynLoadFeature" : true,
  "FeatureLoadConfs": [{
    "FeatureDaoConf": {
      "AdapterType": "redis",
      "RedisName": "user_redis",
      "RedisPrefix": "UF_V2_",
      "FeatureKey": "user:uid",
      "FeatureStore":"user",
      "RedisDataType":"string",
      "RedisFieldType":"csv",
      "RedisValueDelimeter":","
    },
    "Features" :[]
  },
  {
    "FeatureDaoConf": {
      "AdapterType": "redis",
      "RedisName": "item_redis",
      "RedisPrefix": "IF_V2_FM_",
      "FeatureKey": "item:id",
      "FeatureStore":"item",
      "RedisDataType":"string",
      "RedisFieldType":"json"
     },
    "Features" :[]
   }]
  }
}

上面的例子中,user特征是通过KV的形式获取,并且使用csv的方式进行存储,存储用的分隔符是由RedisValueDelimeter指定的。item的特征也是KV的形式,不过使用json方式进程存储的。

再来看下如何用HASH的方式进行获取特征数据。

"FeatureConfs" :{
  "scene_name" :{
  "AsynLoadFeature" : true,
  "FeatureLoadConfs": [{
    "FeatureDaoConf": {
      "AdapterType": "redis",
      "RedisName": "user_redis",
      "RedisPrefix": "UF_V2_",
      "FeatureKey": "user:uid",
      "FeatureStore":"user",
      "RedisDataType":"hash",
      "UserSelectFields":"*"
    },
    "Features" :[]
  },
  {
    "FeatureDaoConf": {
      "AdapterType": "redis",
      "RedisName": "item_redis",
      "RedisPrefix": "IF_V2_FM_",
      "FeatureKey": "item:id",
      "FeatureStore":"item",
      "RedisDataType":"hash",
      "ItemSelectFields":"city,author,duration"
     },
    "Features" :[]
   }]
  }
}

FeatureLoadConfs/FeatureDaoConf

字段名

类型

是否必填

描述

AdapterType

string

数据源的类型,取值为 redis

RedisName

string

在数据源配置(RedisConfs)中配置好的 redis 的自定义名称,如数据源配置中的 redis_info

RedisPrefix

string

key 前缀

FeatureKey

string

根据引擎中哪个特征,去特征表里进行查询。

FeatureKey 标明查找的值来自于 user 或者 item 的哪个字段。比如,user:uid 获取 user 的 uid 属性值,item:pair_id 获取 item 的 pair_id 的属性值。

UserSelectFields

string

需要获取的 user 特征,支持"*",表明获取所有,也可以 "feature1,feature2"。当RedisDataType=hash时有效。

ItemSelectFields

string

需要获取的 item 特征,支持"*",表明获取所有,也可以 "feature1,feature2"。当RedisDataType=hash时有效。

FeatureStore

string

枚举值:user/item。表示特征获取到之后,存储到哪里

RedisDataType

string

数据的存储形式,1. string 代表KV

2. hash 代表 HASH

RedisFieldType

string

有效值为csv或者json。当RedisDataType=string时有效。

RedisValueDelimeter

string

数据的分隔符,当RedisFieldType=csv时有效。

CacheSize

integer

本地缓存特征条目的数量,默认为0,说明不会缓存数据。

CacheTime

integer

本地缓存特征条目的过期时间,单位为秒。只有 CacheSize > 0 开启cache时才会有效。默认值为3600。

特征转化

上面提到 , Features 可以做些特征转化的工作。 来看下常用到的具体几个例子

经常会用到 day_h,week_day 两个特征, 这两个特征是实时生成的。

{
    "FeatureType": "new_feature",
    "FeatureName": "day_h",
    "Normalizer": "hour_in_day",
    "FeatureStore": "user"
}

{
    "FeatureType": "new_feature",
    "FeatureName": "week_day",
    "Normalizer": "weekday",
    "FeatureStore": "user"
}
  • FeatureType = new_feature 新生成特征

  • FeatureName 特征名称

生成随机数, 有些时候会用到随机数进行概率判断。 下面会生成 rand_int_v 特征,区间在 [0 - 100)

{
    "FeatureType": "new_feature",
    "FeatureName": "rand_int_v",
    "Normalizer": "random",
    "FeatureStore": "user"
}

生成固定值, 生成  alg 特征名称,值为 ALRC

{
    "FeatureType": "new_feature",
    "FeatureStore": "user",
    "Normalizer": "const_value",
    "FeatureValue": "ALRC",
    "FeatureName": "alg"
}

根据表达式生成特征, 下面生成了 bool 的特征, is_retarget, 通过判断 recall_name 是否在数组中。 bool 的特征的值,实际用 1 or 0 表示。

{
    "FeatureType": "new_feature",
    "FeatureStore": "item",
    "FeatureSource": "item:recall_name",
    "Normalizer": "expression",
    "Expression": "recall_name in ('retarget_u2i','realtime_retarget_click')",
    "FeatureName": "is_retarget"
}

  • Expression 表达式, 表达式规则,可以参考 https://github.com/Knetic/govaluate

  • FeatureSource 表示特征值来源于哪里, item:recall_name, 说明来源于 item 的 recall_name 特征。如果 Expression 中有多个 item 的属性值,FeatureSource 可以不设置,会把 item 的所有属性值传入到 Expression 进行计算。

根据已有特征进行转化

{
    "FeatureType": "raw_feature",
    "FeatureStore": "user",
    "FeatureSource": "user:age",
    "RemoveFeatureSource": true,
    "FeatureName": "age_v2"
}
  • 这里代表根据 user 中的 age 特征,生成一个 age_v2 的特征,把 age 的特征值赋予给 age_v2,RemoveFeatureSource 参数决定要不要将源特征(age)删除掉