从入门到冠军 中国移动人群画像赛TOP1经验分享

本次提供数据主要包含用户几个方面信息：身份特征、消费能力、人脉关系、位置轨迹、应用行为偏好。字段说明如下：字段列表  字段说明用户编码  数值 唯一性用户实名制是否通过核实  1为是0为否用户年龄  数值是否大学生客户  1为是0为否是否黑名单客户  1为是0为否是否4G不健康客户  1为是0为否用户网龄（月）  数值用户最近一次缴费距今时长（月）  数值缴费用户最近一次缴费金额（元）  数值用户近6个月平均消费话费（元）  数值用户账单当月总费用（元）  数值用户当月账户余额（元）  数值缴费用户当前是否欠费缴费  1为是0为否用户话费敏感度  用户话费敏感度一级表示敏感等级最大。根据极值计算法、叶指标权重后得出的结果，根据规则，生成敏感度用户的敏感级别：先将敏感度用户按中间分值按降序进行排序，前5%的用户对应的敏感级别为一级：接下来的15%的用户对应的敏感级别为二级；接下来的15%的用户对应的敏感级别为三级；接下来的25%的用户对应的敏感级别为四级；最后40%的用户对应的敏感度级别为五级。当月通话交往圈人数  数值是否经常逛商场的人  1为是0为否近三个月月均商场出现次数  数值当月是否逛过福州仓山万达  1为是0为否当月是否到过福州山姆会员店  1为是0为否当月是否看电影  1为是0为否当月是否景点游览  1为是0为否当月是否体育场馆消费  1为是0为否当月网购类应用使用次数  数值当月物流快递类应用使用次数  数值当月金融理财类应用使用总次数  数值当月视频播放类应用使用次数  数值当月飞机类应用使用次数  数值当月火车类应用使用次数  数值当月旅游资讯类应用使用次数  数值

""" 导入基本库 """import numpy as npimport pandas as pdimport seaborn as snsimport matplotlib.pyplot as pltimport warningswarnings.filterwarnings('ignore')
%matplotlib inline
plt.style.use("bmh")plt.rc('font', family='SimHei', size=13)pd.set_option('display.max_columns',1000)pd.set_option('display.width', 1000)pd.set_option('display.max_colwidth',1000)

""" 导入数据 """data_path = '../'
test_data = pd.read_csv(data_path + 'test_dataset.csv')train_data = pd.read_csv(data_path + 'train_dataset.csv')
df_data = pd.concat([train_data, test_data], ignore_index=True)df_data.head()

""" 数据属性 """df_data.info()
print()print("共有数据集：", df_data.shape[0])print("共有测试集：", test_data.shape[0])print("共有训练集：", train_data.shape[0])

""" 数据类别 """for i,name in enumerate(df_data.columns):    name_sum = df_data[name].value_counts().shape[0]    print("{:2}、{:15}      The number of types of features is：{}".format(i + 1, name, name_sum))

""" 数据统计 """df_data.describe()

""" 观察训练/测试集数据同分布状况 """df_data[df_data['信用分'].isnull()].describe()

df_data[df_data['信用分'].notnull()].describe()

""" 拖尾/顺序特征分析 """f, ax = plt.subplots(figsize=(20, 6))
sns.scatterplot(data=df_data, x='当月通话交往圈人数', y='信用分', color='k', ax=ax)plt.show()

name_list = ['当月旅游资讯类应用使用次数', '当月火车类应用使用次数', '当月物流快递类应用使用次数', '当月网购类应用使用次数',             '当月视频播放类应用使用次数', '当月金融理财类应用使用总次数', '当月飞机类应用使用次数', '用户年龄',             '用户当月账户余额（元）', '用户账单当月总费用（元）', '用户近6个月平均消费值（元）', '缴费用户最近一次缴费金额（元）']
f, ax = plt.subplots(3, 4, figsize=(20, 20))
for i,name in enumerate(name_list):         sns.scatterplot(data=df_data, x=name, y='信用分', color='b', ax=ax[i // 4][i % 4])plt.show()

f, ax = plt.subplots(1, 3, figsize=(20, 6))
sns.kdeplot(data=df['当月飞机类应用使用次数'], color='r', shade=True, ax=ax[0])sns.kdeplot(data=df['当月火车类应用使用次数'], color='c', shade=True, ax=ax[1])sns.kdeplot(data=df['当月旅游资讯类应用使用次数'], color='b', shade=True, ax=ax[2])plt.show()

""" 离散特征分析 """f, ax = plt.subplots(1, 2, figsize=(20, 6))
sns.boxplot(data=df_data, x='用户最近一次缴费距今时长（月）', y='信用分', ax=ax[0])sns.boxplot(data=df_data, x='缴费用户当前是否欠费缴费', y='信用分', ax=ax[1])plt.show()

name_list = ['当月是否体育场馆消费', '当月是否到过福州山姆会员店', '当月是否景点游览', '当月是否看电影', '当月是否逛过福州仓山万达',              '是否4G不健康客户', '是否大学生客户', '是否经常逛商场的人', '是否黑名单客户', '用户实名制是否通过核实']
f, ax = plt.subplots(2, 5, figsize=(20, 12))
for i,name in enumerate(name_list):    sns.boxplot(data=df_data, x=name, y='信用分', ax=ax[i //  // 5][i % 5])plt.show()

f, ax = plt.subplots(figsize=(10, 6))sns.boxplot(data=df_data, x='用户话费敏感度', y='信用分', ax=ax)plt.show()

""" 为什么只取消一个特征的拖尾，其它特征拖尾为什么保留，即使线下提高分数也要保留，这是因为在线下中比如逛商场拖尾的数据真实场景下可能为保安，在训练集中可能只有一个保安，所以去掉以后线下验证会提高，但是在测试集中也存在一个保安，如果失去拖尾最终会导致测试集保安信用分精度下降 """    df_data.drop(df_data[df_data['当月通话交往圈人数'] > 1750].index, inplace=True)df_data.reset_index(drop=True, inplace=True)
""" 0替换np.nan，通过线下验证发现数据实际情况缺失值数量大于0值数量，np.nan能更好的还原数据真实性 """na_list = ['用户年龄', '缴费用户最近一次缴费金额（元）', '用户近6个月平均消费值（元）','用户账单当月总费用（元）']for na_fea in na_list:    df_data[na_fea].replace(0, np.nan, inplace=True)
""" 话费敏感度0替换，通过线下验证发现替换为中位数能比np.nan更好的还原数据真实性 """df_data['用户话费敏感度'].replace(0, df_data['用户话费敏感度'].mode()[0], inplace=True)

f, ax = plt.subplots(figsize=(20, 6))sns.boxenplot(data=df_data, x='当月是否逛过福州仓山万达', y='信用分', hue='当月是否到过福州山姆会员店', ax=ax)plt.show()

""" 离散型探索 """f, [ax0, ax1, ax2, ax3, ax4] = plt.subplots(1, 5, figsize=(20, 6))
sns.boxplot(data=df_data, x='当月是否逛过福州仓山万达', y='信用分', hue='是否经常逛商场的人', ax=ax0)sns.boxplot(data=df_data, x='当月是否到过福州山姆会员店', y='信用分', hue='是否经常逛商场的人', ax=ax1)sns.boxplot(data=df_data, x='当月是否看电影', y='信用分', hue='是否经常逛商场的人', ax=ax2)sns.boxplot(data=df_data, x='当月是否景点游览', y='信用分', hue='是否经常逛商场的人', ax=ax3)sns.boxplot(data=df_data, x='当月是否体育场馆消费', y='信用分', hue='是否经常逛商场的人', ax=ax4)plt.show()

""" 连续型探索 """f, ax = plt.subplots(1, 2, figsize=(20, 6))
sns.scatterplot(data=df_data, x='用户账单当月总费用（元）', y='信用分', color='b', ax=ax[0])sns.scatterplot(data=df_data, x='用户当月账户余额（元）', y='信用分', color='r', ax=ax[1])plt.show()

f, ax = plt.subplots(1, 2, figsize=(20, 6))
sns.scatterplot(data=df_data, x='用户账单当月总费用（元）', y='信用分', color='b', ax=ax[0])sns.scatterplot(data=df_data, x='用户近6个月平均消费值（元）', y='信用分', color='r', ax=ax[1])plt.show()

f, [ax0, ax1, ax2, ax3] = plt.subplots(1, 4, figsize=(20, 6))sns.scatterplot(data=df_data, x='当月网购类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax0)sns.scatterplot(data=df_data, x='当月物流快递类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax1)sns.scatterplot(data=df_data, x='当月金融理财类应用使用总次数', y='信用分', hue='是否经常逛商场的人', ax=ax2)sns.scatterplot(data=df_data, x='当月视频播放类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax3)plt.show()
f, [ax0, ax1, ax2, ax3] = plt.subplots(1, 4, figsize=(20, 6))sns.scatterplot(data=df_data, x='当月飞机类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax0)sns.scatterplot(data=df_data, x='当月火车类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax1)sns.scatterplot(data=df_data, x='当月旅游资讯类应用使用次数', y='信用分', hue='是否经常逛商场的人', ax=ax2)sns.scatterplot(data=df_data, x='上网次数', y='信用分', hue='是否经常逛商场的人', ax=ax3)plt.show()

""" x / (y + 1) 避免无穷值Inf，采用高斯平滑 + 1 """df_data['话费稳定'] = df_data['用户账单当月总费用（元）'] / (df_data['用户当月账户余额（元）'] + 1)df_data['相比稳定'] = df_data['用户账单当月总费用（元）'] / (df_data['用户近6个月平均消费值（元）'] + 1)df_data['缴费稳定'] = df_data['缴费用户最近一次缴费金额（元）'] / (df_data['用户近6个月平均消费值（元）'] + 1)
df_data['当月是否去过豪华商场'] = (df_data['当月是否逛过福州仓山万达'] + df_data['当月是否到过福州山姆会员店']).map(lambda x: 1 if x > 0 else 0)df_data['应用总使用次数'] = df_data['当月网购类应用使用次数'] + df_data['当月物流快递类应用使用次数'] + df_data['当月金融理财类应用使用总次数'] + df_data['当月视频播放类应用使用次数'] + df_data['当月飞机类应用使用次数'] + df_data['当月火车类应用使用次数'] + df_data['当月旅游资讯类应用使用次数']

df_data['缴费方式'] = 0df_data.loc[(df_data['缴费用户最近一次缴费金额（元）'] != 0) & (df_data['缴费用户最近一次缴费金额（元）'] % 10 == 0), '缴费方式'] = 1df_dataf.loc[(df_data['缴费用户最近一次缴费金额（元）'] != 0) & (df_data['缴费用户最近一次缴费金额（元）'] % 10 > 0), '缴费方式'] = 2
f, ax = plt.subplots(figsize=(20, 6))sns.boxplot(data=df_data, x='缴费方式', y='信用分', ax=ax)plt.show()

2、充分利用外部信息，让特征具有实际场景意义通过对大量的中国移动星级信用分资料浏览，根据中国移动官网的套餐信息，我们对用户年龄特征进行了提取分类。df['信用资格'] = df['用户网龄（月）'].apply(lambda x: 1 if x > 12 else 0)
f, ax = plt.subplots(figsize=(10, 6))sns.boxenplot(data=df, x='信用资格', y='信用分', ax=ax)plt.show()3、充分利用官网信息，数据业务上的问题积极和主办方联系在多次详细解读比赛官网题目，根据比赛官网提供的特征信息，我们对用户敏感度进行了用户敏感度占比提取。
data['敏度占比'] = data['用户话费敏感度'].map({1:1, 2:3, 3:3, 4:4, 5:8})
f, ax = plt.subplots(1, 2, figsize=(20, 6))
sns.boxenplot(data=df_data, x='敏度占比', y='信用分', ax=ax[0])sns.boxenplot(data=df_data, x='用户话费敏感度', y='信用分', ax=ax[1])plt.show()结论：在高级探索阶段，工程师总是会比学生更为敏感，当然天赋也是会在此展现，在数据竞赛中最重要的是要有希望的努力！算法模型在结构化竞赛中，机器学习常用的模型有LGB、XGB、CAT等模型，算法速度快并且能够容纳缺失值，由于之前我们已经提取出缺失值，并且明确了缺失值的业务意义，所以我们采用LGB来作为训练模型。模型数据lab = '信用分'X = df.loc[df[lab].notnull(), (df.columns != lab) & (df.columns != '用户编码')]y = df.loc[df[lab].notnull()][lab]
X_pred = df.loc[df[lab].isnull(), (df.columns != lab) & (df.columns != '用户编码')]模型参数""" 模型参数为作者祖传参数 """lgb_param_l1 = {    'learning_rate': 0.01,    'boosting_type': 'gbdt',    'objective': 'regression_l1',    'metric': 'mae',    'min_child_samples': 46,    'min_child_weight': 0.01,    'feature_fraction': 0.6,    'bagging_fraction': 0.8,    'bagging_freq': 2,    'num_leaves': 31,    'max_depth': 5,    'lambda_l2': 1,    'lambda_l1': 0,    'n_jobs': -1,    'seed': 4590,}模型框架在实际激烈竞赛中线上提交次数总是有限，所以选手必须构建一个合理的线下验证框架。在本赛题中，为了保证线下验证的准确性，我选择五折交叉验证，能够很好的避免过拟合情况。n_fold = 5y_counts = 0y_scores = np.zeros(5)y_pred_l1 = np.zeros([5, X_pred.shape[0]])y_pred_all_l1 = np.zeros(X_pred.shape[0])
for n in range(1):     kfold = KFold(n_splits=n_fold, shuffle=True, random_state=2019 + n)    kf = kfold.split(X, y)
    for i, (train_iloc, test_iloc) in enumerate(kf):        print("{}、".format(i + 1), end='')        X_train, X_test, y_train, y_test = X.iloc[train_iloc, :], X.iloc[test_iloc, :], y[train_iloc], y[test_iloc]
        lgb_train = lgb.Dataset(X_train, y_train)        lgb_valid = lgb.Dataset(X_test, y_test, reference=lgb_train)        lgb_model = lgb.train(train_set=lgb_train, valid_sets=lgb_valid, fev                              params=lgb_param_l1, num_boost_round=6000, verbose_eval=-1, early_stopping_rounds=100)
        y_scores[y_counts] = lgb_model.best_score['valid_0']['acc_score']        y_pred_l1[y_counts] = lgb_model.predict(X_pred, num_iteration=lgb_model.best_iteration)        y_pred_all_l1 += y_pred_l1[y_counts]        y_counts += 1
y_pred_all_l1 /= y_countsprint(y_scores, y_scores.mean())在该线下验证函数下我们不能够很好的观察与榜单上的分数对比状况，在这里高手通常在比赛中都会写一个验证函数插入参数。def feval_lgb(y_pred, train_data):    y_true = train_data.get_label()    y_pred = np.argmax(y_pred.reshape(7, -1), axis=0)        score = 1 / (1 + mean_absolute_error(y_true, y_pred))    return 'acc_score', score, True  lgb_param_l1 = {    'learning_rate': 0.01,    'boosting_type': 'gbdt',    'objective': 'regression_l1',    'metric': 'None',    'min_child_samples': 46,    'min_child_weight': 0.01,    'feature_fraction': 0.6,    'bagging_fraction': 0.8,    'bagging_freq': 2,    'num_leaves': 31,    'max_depth': 5,    'lambda_l2': 1,    'lambda_l1': 0,    'n_jobs': -1,    'seed': 4590,}n_fold = 5y_counts = 0y_scores = np.zeros(5)y_pred_l1 = np.zeros([5, X_pred.shape[0]])y_pred_all_l1 = np.zeros(X_pred.shape[0])
for n in range(1):     kfold = KFold(n_splits=n_fold, shuffle=True, random_state=2019 + n)    kf = kfold.split(X, y)
    for i, (train_iloc, test_iloc) in enumerate(kf):        print("{}、".format(i + 1), end='')        X_train, X_test, y_train, y_test = X.iloc[train_iloc, :], X.iloc[test_iloc, :], y[train_iloc], y[test_iloc]
        lgb_train = lgb.Dataset(X_train, y_train)        lgb_valid = lgb.Dataset(X_test, y_test, reference=lgb_train)        lgb_model = lgb.train(train_set=lgb_train, valid_sets=lgb_valid, feval=feval_lgb,                               params=lgb_param_l1, num_boost_round=6000, verbose_eval=-1, early_stopping_rounds=100)                y_scores[y_counts] = lgb_model.best_score['valid_0']['acc_score']        y_pred_l1[y_counts] = lgb_model.predict(X_pred, num_iteration=lgb_model.best_iteration)        y_pred_all_l1 += y_pred_l1[y_counts]        y_counts += 1
y_pred_all_l1 /= y_countsprint(y_scores, y_scores.mean()) 现在，我们来对比没有采用特征工程之前的裸跑分数：模型融合在竞赛中采用了取整提交，能够获得线上前排的成绩。那么，如何能够达到TOP1~10呢？事实上，在任何竞赛中，模型融合都是冲顶必备，我们对模型采用了双损失分层加权的方案，经过几次线下验证，让队伍直接进入第一梯队。使用不同的损失函数（MSE与MAE）得到多个模型。MSE损失函数能够加大对异常值的惩罚，在高分段(例如650分以上)和低分段（例如525以下）获得更好的表现。使用MAE误差的模型在中分段获得更好的表现，且更贴近指标。lgb_param_l1 = {
    'learning_rate': 0.01,    'boosting_type': 'gbdt',    'objective': 'regression_l1',    'metric': 'None',    'min_child_samples': 46,    'min_child_weight': 0.01,    'feature_fraction': 0.6,    'bagging_fraction': 0.8,    'bagging_freq': 2,    'num_leaves': 31,    'max_depth': 5,    'lambda_l2': 1,    'lambda_l1': 0,    'n_jobs': -1,    'seed': 4590,}
lgb_param_l2 = {    'learning_rate': 0.01,    'boosting_type': 'gbdt',    'objective': 'regression_l2',    'metric': 'None',    'feature_fraction': 0.6,    'bagging_fraction': 0.8,    'bagging_freq': 2,    'num_leaves': 40,    'max_depth': 7,    'lambda_l2': 1,    'lambda_l1': 0,    'n_jobs': -1,}将以上双损失参数对模型框架进行替换，对得到的结果进行融合。submit = pd.DataFrame()submit['id'] = data[data['信用分'].isnull()]['用户编码']
submit['score1'] = y_pred_all_l1submit['score2'] = y_pred_all_l2
submit = submit.sort_values('score1')submit['rank'] = np.arange(submit.shape[0])
min_rank = 100max_rank = 50000 - min_rank
l1_ext_rate = 1l2_ext_rate = 1 - l1_ext_rateil_ext = (submit['rank'] <= min_rank) | (submit['rank'] >= max_rank)
l1_not_ext_rate = 0.5l2_not_ext_rate = 1 - l1_not_ext_rateil_not_ext = (submit['rank'] > min_rank) & (submit['rank'] < max_rank)
submit['score'] = 0submit.loc[il_ext, 'score'] = (submit[il_ext]['score1'] * l1_ext_rate + submit[il_ext]['score2'] * l2_ext_rate + 1 + 0.25)submit.loc[il_not_ext, 'score'] = submit[il_not_ext]['score1'] * l1_not_ext_rate + submit[il_not_ext]['score2'] * l2_not_ext_rate + 0.25""" 输出文件 """submit[['id', 'score']].to_csv('submit.csv')
结论：采用分段式融合后，提升效果显著，超越了自身的stakcing方案，在之后又组到一群优秀队友，取得了A榜Top1，B榜首次提交Top1的成绩。实际在竞赛中，你花下的时间应该通常是：特征工程 > 模型融合 > 算法模型 > 参数调整或者是：模型融合 > 特征工程 > 算法模型 > 参数调整文章总结
本篇文章介绍了我在中国移动消费者人群画像赛中的经验和心历路程，完成入门到冠军的基本复现。大家可以在本文章的竞赛中进行实践和学习，很多知识只有实践过才能真正理解。比赛成绩很有用，但更重要的是通过竞赛学到东西！在竞赛中，想要取得较好成绩，投入大量的时间是必不可少的，有很多时候你的时间投入下去没有回报，不要气馁，相信自己并付诸努力和实践，我在初入竞赛的时候每天都可以见到凌晨四点的校园风景。最后，希望此文章能够给大家带来些许帮助。