[转] Covariate shift && Internal covariate shift

红太狼 2022-01-05 05:37 251阅读 0赞

from: [https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it][https_www.kaggle.com_pavansanagapati_covariate-shift-what-is-it]

# Covariate Shift – What is it ? #

## Introduction ##

You may have heard from various people that data science competitions are a good way to learn data science, but they are not as useful in solving real world data science problems. Why do you think this is the case?

One of the differences lies in the quality of data that has been provided. In Data Science Competitions, the datasets are carefully curated. Usually, a single large dataset is split into train and test file. So, most of the times the train and test have been generated from the same distribution.

But this is not the case when dealing with real world problems, especially when the data has been collected over a long period of time. In such cases, there may be multiple variables / environment changes might have happened during that period. If proper care is not taken then, the training dataset cannot be used to predict anything about the test dataset in a usable manner.

In this kernel, we will see the different types of problems or Dataset Shift that we might encounter in the real world. Specifically, we will be talking in detail about one particular kind of shift in the Dataset (**Covariate shift**), the existing methods to deal with this kind of shift and an in depth demonstration of a particular method to correct this shift.

## Table of Contents ##

*  [1. What is Dataset Shift?][1. What is Dataset Shift]
 *  [2. What causes Dataset Shift?][2. What causes Dataset Shift]
 *  [3. Types of Dataset Shift][]
 *  [4. Covariate Shift][]
 *  [5. Identification][]
 *  [6. Treatment][]
    
     *  [6.1 Dropping of drifting features][]
     *  [6.2 Importance Weight using Density Ratio Estimation][]

## 1. What is Dataset Shift? ##

Every time you participate in a competition, your journey will look quite similar to the one shown in the figure below.![11uyd5g.png][]Let me explain this with the help of a scenario depicted in the picture below. You are given a train and a test file in a competition. You complete the preprocessing, the feature engineering and the cross validation part on the model created but you do not get the same result as the one you get on the cross-validation. No matter what validation strategy you try, it seems like you are bound to get different results in comparison to the cross validation.![a26ed2.png][]

What can be a possible reason for this failure? So, if you carefully notice the first picture, you will find that you did all the manipulation by just looking at the train file. Therefore, you completely ignored the information contained in the test file.

Now take a look back on the second picture, you will notice that the training file contains information about male and females of fairly younger age while the test file contains information about people of older age. Therefore it means that the distribution of data contained in the train and test file is significantly different.

So, if you build your model based on the data set containing information about people having lower age and predict on a data set containing higher values of age, that will definitely give you a low score. The reason is that there will a wide gap in the interest and the activities between these two groups. So your model will fail in these conditions.

This change in the distribution of data contained in train and test file is called dataset shift (or drifting).

## 2. What causes Dataset Shift? ##

Try to think some of the examples, where you can encounter the problem of dataset shift.

Basically, in the real world, dataset shift mainly occurs because of the change of environments (popularly called as non-stationary environment), where the environment can be referred as location, time, etc.

Let us consider an example. We collected the sales of various item during the period of July-September. Now your job is to predict the sales during the period of Diwali. The visual representation of sales in the train (blue line) and test (black line) file would be similar to the image shown below.

![8zo7sj.png][]

Clearly, the sales during the time of Diwali would be much higher as compared to routine days. Therefore we can say that it is the situation of dataset shift, which occurred due to change of time period between our train and test file.

But our machine learning algorithms work by ignoring these changes. They presume that the train and test environments match and even if they don’t, it assumes that it makes no difference if the environment changes.

Now take a look back at both of the examples that we discussed above. Is there any difference between them?

Yes, in the first scenario, there was a shift in the age (independent variable or predictor) of the population due to which we were getting wrong predictions. While in the latter one, there was a shift in the sales (target variable) of the items. This brings the next topic to the table – Different types of Dataset shifts.

## 3. Types of Dataset Shift ##

Dataset shift could be divided into three types:

*  Shift in the independent variables (**Covariate Shift**)
 *  Shift in the target variable (**Prior probability shift**)
 *  Shift in the relationship between the independent and the target variable (**Concept Shift**)

In this kernel, we will discuss only covariate shift in this article since the other two topics are still an active research area and there has not been any substantial work to mitigate these problems.

We will also see the methods to identify Covariate shift and the proper measures that can be taken in order to improve the predictions.

## 4. Covariate Shift ##

Covariate shift refers to the change in the distribution of the input variables present in the training and the test data. It is the most common type of shift and it is now gaining more attention as nearly every real-world dataset suffers from this problem.

First, let us try to understand how does the change in distribution creates a problem for us. Take a look at the image shown below.

![2w4isyu.png][]

If you carefully notice the image given above, our learning function tries to fit the training data. But here, we can see that the distribution of training and test is different, so predicting using this learned function will definitely give us wrong predictions.

So our first step should be to identify this shift in the distribution. Let’s try and understand it.

## 5. Identification ##

Here, I have used a quick and dirty machine learning technique to check whether there is a shift between the training data and the test data.

For this purpose, I have used Sberbank Russian Housing Market dataset.

**The basic idea to identify shift**

If there exists a shift in the dataset, then on mixing the train and test file, you should still be able to classify an instance of the mixed dataset as train or test with reasonable accuracy. Why?

Because, if the features in both the dataset belong to different distributions then, they should be able to separate the dataset into train and test file significantly.

Let’s try to make it simple. Take a look at the distribution of the feature ‘id’ in both the dataset.![2egd5z7.jpg][]

By looking at the above distribution, we can clearly see that after a certain value (=30,473), all the instances will belong to test dataset.

So if we create a dataset which is a mixture of training and test instances, where we have labelled each instance of training data as ‘training’ and test as ‘test’ before mixing.

In this new dataset, if we just look at the feature ‘id’, we can clearly classify any instance that whether it belongs to training data or test data. Therefore, we can conclude that ‘id’ is a drifting feature for this dataset.

So this was fairly easy. But we can’t visualise every variable and check whether it is drifting or not.

For that purpose, let us try to code this in Python as a simple classification problem and identify the drifting features.

### Steps to identify drift ###

The basic steps that we will follow are:

*  Preprocessing: This step involves imputing all missing values and label encoding of all categorical variables.
 *  Creating a random sample of your training and test data separately and adding a new feature origin which has value train or test depending on whether the observation comes from the training dataset or the test dataset.
 *  Now combine these random samples into a single dataset. Note that the shape of both the samples of training and test dataset should be nearly equal, otherwise it can be a case of an unbalanced dataset.
 *  Now create a model taking one feature at a time while having ‘origin’ as the target variable on a part of the dataset (say ~75%).
 *  Now predict on the rest part(~25%) of the dataset and calculate the value of AUC-ROC.
 *  Now if the value of AUC-ROC for a particular feature is greater than **0.80**, we classify that feature as drifting.
 *  Note that we generally take 0.80 as the threshold value, but the value can be altered based on the situation.

So that is enough of theory, now let’s code this and find which of the features are drifting in this problem.

Code

---------------------------------------------------------------------------
    ModuleNotFoundError Traceback (most recent call last) <ipython-input-1-3adbf147ef87> in <module>() 18 from sklearn.ensemble import RandomForestClassifier 19 ---> 20 from sklearn.cross_validation import cross_val_score 21 22 from sklearn.preprocessing import LabelEncoder ModuleNotFoundError: No module named 'sklearn.cross_validation'

In \[2\]:

# Reading the train and test files
    
    train = pd.read_csv('../input/train.csv') test = pd.read_csv('../input/test.csv')

In \[3\]:

train.shape,test.shape

Out\[3\]:

((30471, 292), (7662, 291))

In \[4\]:

train.head()

Out\[4\]:

<table> 
 <thead> 
  <tr> 
   <th>&nbsp;</th> 
   <th>id</th> 
   <th>timestamp</th> 
   <th>full_sq</th> 
   <th>life_sq</th> 
   <th>floor</th> 
   <th>max_floor</th> 
   <th>material</th> 
   <th>build_year</th> 
   <th>num_room</th> 
   <th>kitch_sq</th> 
   <th>state</th> 
   <th>product_type</th> 
   <th>sub_area</th> 
   <th>area_m</th> 
   <th>raion_popul</th> 
   <th>green_zone_part</th> 
   <th>indust_part</th> 
   <th>children_preschool</th> 
   <th>preschool_quota</th> 
   <th>preschool_education_centers_raion</th> 
   <th>children_school</th> 
   <th>school_quota</th> 
   <th>school_education_centers_raion</th> 
   <th>school_education_centers_top_20_raion</th> 
   <th>hospital_beds_raion</th> 
   <th>healthcare_centers_raion</th> 
   <th>university_top_20_raion</th> 
   <th>sport_objects_raion</th> 
   <th>additional_education_raion</th> 
   <th>culture_objects_top_25</th> 
   <th>culture_objects_top_25_raion</th> 
   <th>shopping_centers_raion</th> 
   <th>office_raion</th> 
   <th>thermal_power_plant_raion</th> 
   <th>incineration_raion</th> 
   <th>oil_chemistry_raion</th> 
   <th>radiation_raion</th> 
   <th>railroad_terminal_raion</th> 
   <th>big_market_raion</th> 
   <th>nuclear_reactor_raion</th> 
   <th>...</th> 
   <th>cafe_sum_3000_min_price_avg</th> 
   <th>cafe_sum_3000_max_price_avg</th> 
   <th>cafe_avg_price_3000</th> 
   <th>cafe_count_3000_na_price</th> 
   <th>cafe_count_3000_price_500</th> 
   <th>cafe_count_3000_price_1000</th> 
   <th>cafe_count_3000_price_1500</th> 
   <th>cafe_count_3000_price_2500</th> 
   <th>cafe_count_3000_price_4000</th> 
   <th>cafe_count_3000_price_high</th> 
   <th>big_church_count_3000</th> 
   <th>church_count_3000</th> 
   <th>mosque_count_3000</th> 
   <th>leisure_count_3000</th> 
   <th>sport_count_3000</th> 
   <th>market_count_3000</th> 
   <th>green_part_5000</th> 
   <th>prom_part_5000</th> 
   <th>office_count_5000</th> 
   <th>office_sqm_5000</th> 
   <th>trc_count_5000</th> 
   <th>trc_sqm_5000</th> 
   <th>cafe_count_5000</th> 
   <th>cafe_sum_5000_min_price_avg</th> 
   <th>cafe_sum_5000_max_price_avg</th> 
   <th>cafe_avg_price_5000</th> 
   <th>cafe_count_5000_na_price</th> 
   <th>cafe_count_5000_price_500</th> 
   <th>cafe_count_5000_price_1000</th> 
   <th>cafe_count_5000_price_1500</th> 
   <th>cafe_count_5000_price_2500</th> 
   <th>cafe_count_5000_price_4000</th> 
   <th>cafe_count_5000_price_high</th> 
   <th>big_church_count_5000</th> 
   <th>church_count_5000</th> 
   <th>mosque_count_5000</th> 
   <th>leisure_count_5000</th> 
   <th>sport_count_5000</th> 
   <th>market_count_5000</th> 
   <th>price_doc</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <th>0</th> 
   <td>1</td> 
   <td>2011-08-20</td> 
   <td>43</td> 
   <td>27.0</td> 
   <td>4.0</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>Investment</td> 
   <td>Bibirevo</td> 
   <td>6.407578e+06</td> 
   <td>155572</td> 
   <td>0.189727</td> 
   <td>0.000070</td> 
   <td>9576</td> 
   <td>5001.0</td> 
   <td>5</td> 
   <td>10309</td> 
   <td>11065.0</td> 
   <td>5</td> 
   <td>0</td> 
   <td>240.0</td> 
   <td>1</td> 
   <td>0</td> 
   <td>7</td> 
   <td>3</td> 
   <td>no</td> 
   <td>0</td> 
   <td>16</td> 
   <td>1</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>...</td> 
   <td>639.68</td> 
   <td>1079.37</td> 
   <td>859.52</td> 
   <td>5</td> 
   <td>21</td> 
   <td>22</td> 
   <td>16</td> 
   <td>3</td> 
   <td>1</td> 
   <td>0</td> 
   <td>2</td> 
   <td>4</td> 
   <td>0</td> 
   <td>0</td> 
   <td>21</td> 
   <td>1</td> 
   <td>13.09</td> 
   <td>13.31</td> 
   <td>29</td> 
   <td>807385</td> 
   <td>52</td> 
   <td>4036616</td> 
   <td>152</td> 
   <td>708.57</td> 
   <td>1185.71</td> 
   <td>947.14</td> 
   <td>12</td> 
   <td>39</td> 
   <td>48</td> 
   <td>40</td> 
   <td>9</td> 
   <td>4</td> 
   <td>0</td> 
   <td>13</td> 
   <td>22</td> 
   <td>1</td> 
   <td>0</td> 
   <td>52</td> 
   <td>4</td> 
   <td>5850000</td> 
  </tr> 
  <tr> 
   <th>1</th> 
   <td>2</td> 
   <td>2011-08-23</td> 
   <td>34</td> 
   <td>19.0</td> 
   <td>3.0</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>Investment</td> 
   <td>Nagatinskij Zaton</td> 
   <td>9.589337e+06</td> 
   <td>115352</td> 
   <td>0.372602</td> 
   <td>0.049637</td> 
   <td>6880</td> 
   <td>3119.0</td> 
   <td>5</td> 
   <td>7759</td> 
   <td>6237.0</td> 
   <td>8</td> 
   <td>0</td> 
   <td>229.0</td> 
   <td>1</td> 
   <td>0</td> 
   <td>6</td> 
   <td>1</td> 
   <td>yes</td> 
   <td>1</td> 
   <td>3</td> 
   <td>0</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>...</td> 
   <td>631.03</td> 
   <td>1086.21</td> 
   <td>858.62</td> 
   <td>1</td> 
   <td>11</td> 
   <td>11</td> 
   <td>4</td> 
   <td>2</td> 
   <td>1</td> 
   <td>0</td> 
   <td>1</td> 
   <td>7</td> 
   <td>0</td> 
   <td>6</td> 
   <td>19</td> 
   <td>1</td> 
   <td>10.26</td> 
   <td>27.47</td> 
   <td>66</td> 
   <td>2690465</td> 
   <td>40</td> 
   <td>2034942</td> 
   <td>177</td> 
   <td>673.81</td> 
   <td>1148.81</td> 
   <td>911.31</td> 
   <td>9</td> 
   <td>49</td> 
   <td>65</td> 
   <td>36</td> 
   <td>15</td> 
   <td>3</td> 
   <td>0</td> 
   <td>15</td> 
   <td>29</td> 
   <td>1</td> 
   <td>10</td> 
   <td>66</td> 
   <td>14</td> 
   <td>6000000</td> 
  </tr> 
  <tr> 
   <th>2</th> 
   <td>3</td> 
   <td>2011-08-27</td> 
   <td>43</td> 
   <td>29.0</td> 
   <td>2.0</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>Investment</td> 
   <td>Tekstil'shhiki</td> 
   <td>4.808270e+06</td> 
   <td>101708</td> 
   <td>0.112560</td> 
   <td>0.118537</td> 
   <td>5879</td> 
   <td>1463.0</td> 
   <td>4</td> 
   <td>6207</td> 
   <td>5580.0</td> 
   <td>7</td> 
   <td>0</td> 
   <td>1183.0</td> 
   <td>1</td> 
   <td>0</td> 
   <td>5</td> 
   <td>1</td> 
   <td>no</td> 
   <td>0</td> 
   <td>0</td> 
   <td>1</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>yes</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>...</td> 
   <td>697.44</td> 
   <td>1192.31</td> 
   <td>944.87</td> 
   <td>2</td> 
   <td>9</td> 
   <td>17</td> 
   <td>9</td> 
   <td>3</td> 
   <td>1</td> 
   <td>0</td> 
   <td>0</td> 
   <td>11</td> 
   <td>0</td> 
   <td>0</td> 
   <td>20</td> 
   <td>6</td> 
   <td>13.69</td> 
   <td>21.58</td> 
   <td>43</td> 
   <td>1478160</td> 
   <td>35</td> 
   <td>1572990</td> 
   <td>122</td> 
   <td>702.68</td> 
   <td>1196.43</td> 
   <td>949.55</td> 
   <td>10</td> 
   <td>29</td> 
   <td>45</td> 
   <td>25</td> 
   <td>10</td> 
   <td>3</td> 
   <td>0</td> 
   <td>11</td> 
   <td>27</td> 
   <td>0</td> 
   <td>4</td> 
   <td>67</td> 
   <td>10</td> 
   <td>5700000</td> 
  </tr> 
  <tr> 
   <th>3</th> 
   <td>4</td> 
   <td>2011-09-01</td> 
   <td>89</td> 
   <td>50.0</td> 
   <td>9.0</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>Investment</td> 
   <td>Mitino</td> 
   <td>1.258354e+07</td> 
   <td>178473</td> 
   <td>0.194703</td> 
   <td>0.069753</td> 
   <td>13087</td> 
   <td>6839.0</td> 
   <td>9</td> 
   <td>13670</td> 
   <td>17063.0</td> 
   <td>10</td> 
   <td>0</td> 
   <td>NaN</td> 
   <td>1</td> 
   <td>0</td> 
   <td>17</td> 
   <td>6</td> 
   <td>no</td> 
   <td>0</td> 
   <td>11</td> 
   <td>4</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>...</td> 
   <td>718.75</td> 
   <td>1218.75</td> 
   <td>968.75</td> 
   <td>0</td> 
   <td>5</td> 
   <td>14</td> 
   <td>10</td> 
   <td>3</td> 
   <td>0</td> 
   <td>0</td> 
   <td>1</td> 
   <td>2</td> 
   <td>0</td> 
   <td>0</td> 
   <td>18</td> 
   <td>3</td> 
   <td>14.18</td> 
   <td>3.89</td> 
   <td>8</td> 
   <td>244166</td> 
   <td>22</td> 
   <td>942180</td> 
   <td>61</td> 
   <td>931.58</td> 
   <td>1552.63</td> 
   <td>1242.11</td> 
   <td>4</td> 
   <td>7</td> 
   <td>21</td> 
   <td>15</td> 
   <td>11</td> 
   <td>2</td> 
   <td>1</td> 
   <td>4</td> 
   <td>4</td> 
   <td>0</td> 
   <td>0</td> 
   <td>26</td> 
   <td>3</td> 
   <td>13100000</td> 
  </tr> 
  <tr> 
   <th>4</th> 
   <td>5</td> 
   <td>2011-09-05</td> 
   <td>77</td> 
   <td>77.0</td> 
   <td>4.0</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>NaN</td> 
   <td>Investment</td> 
   <td>Basmannoe</td> 
   <td>8.398461e+06</td> 
   <td>108171</td> 
   <td>0.015234</td> 
   <td>0.037316</td> 
   <td>5706</td> 
   <td>3240.0</td> 
   <td>7</td> 
   <td>6748</td> 
   <td>7770.0</td> 
   <td>9</td> 
   <td>0</td> 
   <td>562.0</td> 
   <td>4</td> 
   <td>2</td> 
   <td>25</td> 
   <td>2</td> 
   <td>no</td> 
   <td>0</td> 
   <td>10</td> 
   <td>93</td> 
   <td>no</td> 
   <td>no</td> 
   <td>no</td> 
   <td>yes</td> 
   <td>yes</td> 
   <td>no</td> 
   <td>no</td> 
   <td>...</td> 
   <td>853.03</td> 
   <td>1410.45</td> 
   <td>1131.74</td> 
   <td>63</td> 
   <td>266</td> 
   <td>267</td> 
   <td>262</td> 
   <td>149</td> 
   <td>57</td> 
   <td>4</td> 
   <td>70</td> 
   <td>121</td> 
   <td>1</td> 
   <td>40</td> 
   <td>77</td> 
   <td>5</td> 
   <td>8.38</td> 
   <td>10.92</td> 
   <td>689</td> 
   <td>8404624</td> 
   <td>114</td> 
   <td>3503058</td> 
   <td>2283</td> 
   <td>853.88</td> 
   <td>1411.45</td> 
   <td>1132.66</td> 
   <td>143</td> 
   <td>566</td> 
   <td>578</td> 
   <td>552</td> 
   <td>319</td> 
   <td>108</td> 
   <td>17</td> 
   <td>135</td> 
   <td>236</td> 
   <td>2</td> 
   <td>91</td> 
   <td>195</td> 
   <td>14</td> 
   <td>16331452</td> 
  </tr> 
 </tbody> 
</table>

#### Preprocessing ####

In \[5\]:

## Handling missing values
    for i in train.columns: if train[i].dtype == 'object': train[i] = train[i].fillna(train[i].mode().iloc[0]) if (train[i].dtype == 'int' or train[i].dtype == 'float'): train[i] = train[i].fillna(np.mean(train[i])) for i in test.columns: if test[i].dtype == 'object': test[i] = test[i].fillna(test[i].mode().iloc[0]) if (test[i].dtype == 'int' or test[i].dtype == 'float'): test[i] = test[i].fillna(np.mean(test[i]))

In \[6\]:

## Label    encoding
    number = LabelEncoder() for i in train.columns: if (train[i].dtype == 'object'): train[i] = number.fit_transform(train[i].astype('str')) train[i] = train[i].astype('object') for i in test.columns: if (test[i].dtype == 'object'): test[i] = number.fit_transform(test[i].astype('str')) test[i] = test[i].astype('object')

---------------------------------------------------------------------------
    NameError Traceback (most recent call last) <ipython-input-6-09f525e50b42> in <module>() 1 ## Label encoding ----> 2 number = LabelEncoder() 3 for i in train.columns: 4 if (train[i].dtype == 'object'): 5 train[i] = number.fit_transform(train[i].astype('str')) NameError: name 'LabelEncoder' is not defined

In \[7\]:

# Creating a new feature origin
    train['origin'] = 0 test['origin'] = 1 training = train.drop('price_doc',axis=1) #droping target variable

In \[8\]:

## Taking sample from training and test data
    training = training.sample(7662, random_state=12) testing = test.sample(7000, random_state=11)

In \[9\]:

## Combining random samples
    combine = training.append(testing) y = combine['origin'] combine.drop('origin',axis=1,inplace=True)

In \[10\]:

## Modelling
    model = RandomForestClassifier(n_estimators = 50, max_depth = 5,min_samples_leaf = 5) drop_list = [] for i in combine.columns: score = cross_val_score(model,pd.DataFrame(combine[i]),y,cv=2,scoring='roc_auc') if (np.mean(score) > 0.8): drop_list.append(i) print(i,np.mean(score))

---------------------------------------------------------------------------
    NameError Traceback (most recent call last) <ipython-input-10-7e6054cbafe1> in <module>() 3 drop_list = [] 4 for i in combine.columns: ----> 5 score = cross_val_score(model,pd.DataFrame(combine[i]),y,cv=2,scoring='roc_auc') 6 if (np.mean(score) > 0.8): 7 drop_list.append(i) NameError: name 'cross_val_score' is not defined

In \[11\]:

# List   of   drifting   features 
    drop_list

Out\[11\]:

[]

Here we have classified nine features as drifting

So, now the important question is how to treat them effectively such that we can improve our predictions.

## 6. Treatment ##

There are different techniques by which we can treat these features in order to improve our model. Let us discuss some of them.

*  Dropping of drifting features
 *  Importance weight using Density Ratio Estimation So let’s try to understand one by one

### 6.1 Dropping of drifting features ###

This method is quite simple, as in this, we basically drop the features which are being classified as drifting. But just give it a thought, that simply dropping features might result in some loss of information.

To deal with this, we have defined a simple rule.

Features having a drift value greater than 0.8 and are not important in our model, we drop them.

So, let’s try this in our problem.

Here, I have used a basic random forest model just to check which features are important.

Code

---------------------------------------------------------------------------
    ValueError Traceback (most recent call last) <ipython-input-12-a567de6a5f2a> in <module>() 4 # Using a basic random forest model with all the features 5 rf = RandomForestRegressor(n_estimators=200, max_depth=6,max_features=10) ----> 6 rf.fit(training.drop('price_doc',axis=1),training['price_doc']) 7 pred = rf.predict(testing) 8 columns = ['price_doc'] /opt/conda/lib/python3.6/site-packages/sklearn/ensemble/forest.py in fit(self, X, y, sample_weight) 250 251 # Validate or convert input data --> 252 X = check_array(X, accept_sparse="csc", dtype=DTYPE) 253 y = check_array(y, accept_sparse='csc', ensure_2d=False, dtype=None) 254 if sample_weight is not None: /opt/conda/lib/python3.6/site-packages/sklearn/utils/validation.py in check_array(array, accept_sparse, accept_large_sparse, dtype, order, copy, force_all_finite, ensure_2d, allow_nd, ensure_min_samples, ensure_min_features, warn_on_dtype, estimator) 520 try: 521 warnings.simplefilter('error', ComplexWarning) --> 522 array = np.asarray(array, dtype=dtype, order=order) 523 except ComplexWarning: 524 raise ValueError("Complex data not supported\n" /opt/conda/lib/python3.6/site-packages/numpy/core/numeric.py in asarray(a, dtype, order) 499 500 """ --> 501 return array(a, dtype, copy=False, order=order) 502 503 ValueError: could not convert string to float: '2011-08-20'

On submitting this file on Kaggle, we are getting a rmse score of 0.40116 on private leaderboard.

So, let’s check first 20 important features for this model.

Code

---------------------------------------------------------------------------
    NotFittedError Traceback (most recent call last) <ipython-input-13-e6b27648cf19> in <module>() 1 # plotting importances 2 features = training.drop('price_doc',axis=1).columns.values ----> 3 imp = rf.feature_importances_ 4 indices = np.argsort(imp)[::-1][:20] 5 #plot /opt/conda/lib/python3.6/site-packages/sklearn/ensemble/forest.py in feature_importances_(self) 373 feature_importances_ : array, shape = [n_features] 374 """ --> 375 check_is_fitted(self, 'estimators_') 376 377 all_importances = Parallel(n_jobs=self.n_jobs, /opt/conda/lib/python3.6/site-packages/sklearn/utils/validation.py in check_is_fitted(estimator, attributes, msg, all_or_any) 940 941 if not all_or_any([hasattr(estimator, attr) for attr in attributes]): --> 942 raise NotFittedError(msg % { 'name': type(estimator).__name__}) 943 944 NotFittedError: This RandomForestRegressor instance is not fitted yet. Call 'fit' with appropriate arguments before using this method.

Now if we compare the feature importance list and drop\_list

In \[14\]:

drop_list

Out\[14\]:

[]

Now, if we compare our drop list and feature importance, we will find that the features ‘life\_sq’ and ‘kitch\_sq’ are common.

So, we will keep these two features in our model, while dropping the rest of the drifting features.

NOTE: Before dropping any feature, just make sure you if there any possibility to create a new feature from it.

Let’s try this and check whether it improves our prediction or not.

Code

---------------------------------------------------------------------------
    ValueError Traceback (most recent call last) <ipython-input-15-ad4bb45c1add> in <module>() 3 drift_test = testing.drop(['id','hospital_beds_raion','cafe_sum_500_min_price_avg','cafe_sum_500_max_price_avg','cafe_avg_price_500'], axis=1) 4 rf = RandomForestRegressor(n_estimators=200, max_depth=6,max_features=10) ----> 5 rf.fit(drift_train.drop('price_doc',axis=1),training['price_doc']) 6 pred = rf.predict(drift_test) 7 columns = ['price_doc'] /opt/conda/lib/python3.6/site-packages/sklearn/ensemble/forest.py in fit(self, X, y, sample_weight) 250 251 # Validate or convert input data --> 252 X = check_array(X, accept_sparse="csc", dtype=DTYPE) 253 y = check_array(y, accept_sparse='csc', ensure_2d=False, dtype=None) 254 if sample_weight is not None: /opt/conda/lib/python3.6/site-packages/sklearn/utils/validation.py in check_array(array, accept_sparse, accept_large_sparse, dtype, order, copy, force_all_finite, ensure_2d, allow_nd, ensure_min_samples, ensure_min_features, warn_on_dtype, estimator) 520 try: 521 warnings.simplefilter('error', ComplexWarning) --> 522 array = np.asarray(array, dtype=dtype, order=order) 523 except ComplexWarning: 524 raise ValueError("Complex data not supported\n" /opt/conda/lib/python3.6/site-packages/numpy/core/numeric.py in asarray(a, dtype, order) 499 500 """ --> 501 return array(a, dtype, copy=False, order=order) 502 503 ValueError: could not convert string to float: '2011-08-20'

On submission of this file on Kaggle, we got a rmse score of 0.39759 on the private leaderboard.

This means our objective is met .We have successfully improved our performance using this technique.

### 6.2 Importance weight using Density Ratio Estimation ###

In this method, the approach to importance estimation would be to first estimate the training and test densities separately and then estimate the importance by taking the ratio of the estimated densities of test and train.

Then these densities act as weights for each instance in the training data.

But giving weights to each instance based on the density ratio could be a rigorous task in higher dimensional data sets. I tried this method on an i3 processor with 12 GB RAM and it took around 48 minutes to calculate the ratio density for a single feature. Also, I could not find any improvement in the score on applying the weights to the training data.

Also scaling this feature for 200 features would be a very time-consuming task.

Therefore, this method is only good up to research papers but the application of this in the real world is still questionable. Also, this is an active area of research.

# Conclusion #

I hope that now we have a better understanding about drift, how we can identify it and treat it effectively. It has now become a common problem in real world dataset. So we should develop a habit to check this every time while solving problems, and surely it will give us positive results.

转载于:https://www.cnblogs.com/Arborday/p/10888639.html

[https_www.kaggle.com_pavansanagapati_covariate-shift-what-is-it]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it
[1. What is Dataset Shift]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#1
[2. What causes Dataset Shift]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#2
[3. Types of Dataset Shift]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#3
[4. Covariate Shift]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#4
[5. Identification]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#5
[6. Treatment]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#6
[6.1 Dropping of drifting features]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#6.1
[6.2 Importance Weight using Density Ratio Estimation]: https://www.kaggle.com/pavansanagapati/covariate-shift-what-is-it#6.2
[11uyd5g.png]: http://i67.tinypic.com/11uyd5g.png
[a26ed2.png]: /images/20211230/4e98351df3c948a8b4cb7578771ebc0b.png
[8zo7sj.png]: /images/20211230/d509d5d3bf5443deb77072a5a562bc70.png
[2w4isyu.png]: /images/20211230/83611aba08864f789ce3867924d7af16.png
[2egd5z7.jpg]: /images/20211230/59bb80703139431ebefcbb19f84fb9e0.png