Classify structured data with feature columns

Classify structured data with feature columns

This tutorial demonstrates how to classify structured data (e.g. tabular data in a CSV). We will use Keras to define the model, and feature columns as a bridge to map from columns in a CSV to features used to train the model. This tutorial contains complete code to:

  • Load a CSV file using Pandas.
  • Build an input pipeline to batch and shuffle the rows using tf.data.
  • Map from columns in the CSV to features used to train the model using feature columns.
  • Build, train, and evaluate a model using Keras.

The Dataset

We will use a small dataset provided by the Cleveland Clinic Foundation for Heart Disease. There are several hundred rows in the CSV. Each row describes a patient, and each column describes an attribute. We will use this information to predict whether a patient has heart disease, which in this dataset is a binary classification task.

Following is a description of this dataset. Notice there are both numeric and categorical columns.

ColumnDescriptionFeature TypeData Type
AgeAge in yearsNumericalinteger
Sex(1 = male; 0 = female)Categoricalinteger
CPChest pain type (0, 1, 2, 3, 4)Categoricalinteger
TrestbpdResting blood pressure (in mm Hg on admission to the hospital)Numericalinteger
CholSerum cholestoral in mg/dlNumericalinteger
FBS(fasting blood sugar > 120 mg/dl) (1 = true; 0 = false)Categoricalinteger
RestECGResting electrocardiographic results (0, 1, 2)Categoricalinteger
ThalachMaximum heart rate achievedNumericalinteger
ExangExercise induced angina (1 = yes; 0 = no)Categoricalinteger
OldpeakST depression induced by exercise relative to restNumericalfloat
SlopeThe slope of the peak exercise ST segmentNumericalinteger
CANumber of major vessels (0-3) colored by flourosopyNumericalinteger
Thal3 = normal; 6 = fixed defect; 7 = reversable defectCategoricalstring
TargetDiagnosis of heart disease (1 = true; 0 = false)Classificationinteger

Import TensorFlow and other libraries

pip install -q sklearn
import numpy as np
import pandas as pd

import tensorflow as tf

from tensorflow import feature_column
from tensorflow.keras import layers
from sklearn.model_selection import train_test_split

Use Pandas to create a dataframe

Pandas is a Python library with many helpful utilities for loading and working with structured data. We will use Pandas to download the dataset from a URL, and load it into a dataframe.

URL = 'https://storage.googleapis.com/applied-dl/heart.csv'
dataframe
= pd.read_csv(URL)
dataframe
.head()

Split the dataframe into train, validation, and test

The dataset we downloaded was a single CSV file. We will split this into train, validation, and test sets.

train, test = train_test_split(dataframe, test_size=0.2)
train
, val = train_test_split(train, test_size=0.2)
print(len(train), 'train examples')
print(len(val), 'validation examples')
print(len(test), 'test examples')
193 train examples
49 validation examples
61 test examples

Create an input pipeline using tf.data

Next, we will wrap the dataframes with tf.data. This will enable us to use feature columns as a bridge to map from the columns in the Pandas dataframe to features used to train the model. If we were working with a very large CSV file (so large that it does not fit into memory), we would use tf.data to read it from disk directly. That is not covered in this tutorial.

# A utility method to create a tf.data dataset from a Pandas Dataframe
def df_to_dataset(dataframe, shuffle=True, batch_size=32):
  dataframe
= dataframe.copy()
  labels
= dataframe.pop('target')
  ds
= tf.data.Dataset.from_tensor_slices((dict(dataframe), labels))
 
if shuffle:
    ds
= ds.shuffle(buffer_size=len(dataframe))
  ds
= ds.batch(batch_size)
 
return ds
batch_size = 5 # A small batch sized is used for demonstration purposes
train_ds
= df_to_dataset(train, batch_size=batch_size)
val_ds
= df_to_dataset(val, shuffle=False, batch_size=batch_size)
test_ds
= df_to_dataset(test, shuffle=False, batch_size=batch_size)

Understand the input pipeline

Now that we have created the input pipeline, let's call it to see the format of the data it returns. We have used a small batch size to keep the output readable.

for feature_batch, label_batch in train_ds.take(1):
 
print('Every feature:', list(feature_batch.keys()))
 
print('A batch of ages:', feature_batch['age'])
 
print('A batch of targets:', label_batch )
Every feature: ['age', 'sex', 'cp', 'trestbps', 'chol', 'fbs', 'restecg', 'thalach', 'exang', 'oldpeak', 'slope', 'ca', 'thal']
A batch of ages: tf.Tensor([44 59 43 66 61], shape=(5,), dtype=int32)
A batch of targets: tf.Tensor([0 0 0 0 0], shape=(5,), dtype=int32)

We can see that the dataset returns a dictionary of column names (from the dataframe) that map to column values from rows in the dataframe.

Demonstrate several types of feature column

TensorFlow provides many types of feature columns. In this section, we will create several types of feature columns, and demonstrate how they transform a column from the dataframe.

# We will use this batch to demonstrate several types of feature columns
example_batch
= next(iter(train_ds))[0]
# A utility method to create a feature column
# and to transform a batch of data
def demo(feature_column):
  feature_layer
= layers.DenseFeatures(feature_column)
 
print(feature_layer(example_batch).numpy())

Numeric columns

The output of a feature column becomes the input to the model (using the demo function defined above, we will be able to see exactly how each column from the dataframe is transformed). A numeric column is the simplest type of column. It is used to represent real valued features. When using this column, your model will receive the column value from the dataframe unchanged.

age = feature_column.numeric_column("age")
demo
(age)
[[50.]
 [59.]
 [69.]
 [57.]
 [70.]]

In the heart disease dataset, most columns from the dataframe are numeric.

Bucketized columns

Often, you don't want to feed a number directly into the model, but instead split its value into different categories based on numerical ranges. Consider raw data that represents a person's age. Instead of representing age as a numeric column, we could split the age into several buckets using a bucketized column. Notice the one-hot values below describe which age range each row matches.

age_buckets = feature_column.bucketized_column(age, boundaries=[18, 25, 30, 35, 40, 45, 50, 55, 60, 65])
demo
(age_buckets)
[[0. 0. 0. 0. 0. 0. 0. 1. 0. 0. 0.]
 [0. 0. 0. 0. 0. 0. 0. 0. 1. 0. 0.]
 [0. 0. 0. 0. 0. 0. 0. 0. 0. 0. 1.]
 [0. 0. 0. 0. 0. 0. 0. 0. 1. 0. 0.]
 [0. 0. 0. 0. 0. 0. 0. 0. 0. 0. 1.]]

Categorical columns

In this dataset, thal is represented as a string (e.g. 'fixed', 'normal', or 'reversible'). We cannot feed strings directly to a model. Instead, we must first map them to numeric values. The categorical vocabulary columns provide a way to represent strings as a one-hot vector (much like you have seen above with age buckets). The vocabulary can be passed as a list using categorical_column_with_vocabulary_list, or loaded from a file using categorical_column_with_vocabulary_file.

thal = feature_column.categorical_column_with_vocabulary_list(
     
'thal', ['fixed', 'normal', 'reversible'])

thal_one_hot
= feature_column.indicator_column(thal)
demo
(thal_one_hot)
WARNING:tensorflow:From /tmpfs/src/tf_docs_env/lib/python3.6/site-packages/tensorflow_core/python/feature_column/feature_column_v2.py:4267: IndicatorColumn._variable_shape (from tensorflow.python.feature_column.feature_column_v2) is deprecated and will be removed in a future version.
Instructions for updating:
The old _FeatureColumn APIs are being deprecated. Please use the new FeatureColumn APIs instead.
WARNING:tensorflow:From /tmpfs/src/tf_docs_env/lib/python3.6/site-packages/tensorflow_core/python/feature_column/feature_column_v2.py:4322: VocabularyListCategoricalColumn._num_buckets (from tensorflow.python.feature_column.feature_column_v2) is deprecated and will be removed in a future version.
Instructions for updating:
The old _FeatureColumn APIs are being deprecated. Please use the new FeatureColumn APIs instead.
[[0. 0. 1.]
 [0. 1. 0.]
 [0. 1. 0.]
 [0. 1. 0.]
 [0. 0. 1.]]

In a more complex dataset, many columns would be categorical (e.g. strings). Feature columns are most valuable when working with categorical data. Although there is only one categorical column in this dataset, we will use it to demonstrate several important types of feature columns that you could use when working with other datasets.

Embedding columns

Suppose instead of having just a few possible strings, we have thousands (or more) values per category. For a number of reasons, as the number of categories grow large, it becomes infeasible to train a neural network using one-hot encodings. We can use an embedding column to overcome this limitation. Instead of representing the data as a one-hot vector of many dimensions, an embedding column represents that data as a lower-dimensional, dense vector in which each cell can contain any number, not just 0 or 1. The size of the embedding (8, in the example below) is a parameter that must be tuned.

# Notice the input to the embedding column is the categorical column
# we previously created
thal_embedding
= feature_column.embedding_column(thal, dimension=8)
demo
(thal_embedding)
[[ 0.4017021   0.6076338  -0.07035336 -0.49105015  0.25653887 -0.0523118
   0.03033678 -0.03875173]
 [ 0.22658078  0.44009814 -0.2293082  -0.41952112  0.00313324 -0.10137992
   0.19356865 -0.32178992]
 [ 0.22658078  0.44009814 -0.2293082  -0.41952112  0.00313324 -0.10137992
   0.19356865 -0.32178992]
 [ 0.22658078  0.44009814 -0.2293082  -0.41952112  0.00313324 -0.10137992
   0.19356865 -0.32178992]
 [ 0.4017021   0.6076338  -0.07035336 -0.49105015  0.25653887 -0.0523118
   0.03033678 -0.03875173]]

Hashed feature columns

Another way to represent a categorical column with a large number of values is to use a categorical_column_with_hash_bucket. This feature column calculates a hash value of the input, then selects one of the hash_bucket_size buckets to encode a string. When using this column, you do not need to provide the vocabulary, and you can choose to make the number of hash_buckets significantly smaller than the number of actual categories to save space.

thal_hashed = feature_column.categorical_column_with_hash_bucket(
     
'thal', hash_bucket_size=1000)
demo
(feature_column.indicator_column(thal_hashed))
WARNING:tensorflow:From /tmpfs/src/tf_docs_env/lib/python3.6/site-packages/tensorflow_core/python/feature_column/feature_column_v2.py:4322: HashedCategoricalColumn._num_buckets (from tensorflow.python.feature_column.feature_column_v2) is deprecated and will be removed in a future version.
Instructions for updating:
The old _FeatureColumn APIs are being deprecated. Please use the new FeatureColumn APIs instead.
[[0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]]

Crossed feature columns

Combining features into a single feature, better known as feature crosses, enables a model to learn separate weights for each combination of features. Here, we will create a new feature that is the cross of age and thal. Note that crossed_column does not build the full table of all possible combinations (which could be very large). Instead, it is backed by a hashed_column, so you can choose how large the table is.

crossed_feature = feature_column.crossed_column([age_buckets, thal], hash_bucket_size=1000)
demo
(feature_column.indicator_column(crossed_feature))
WARNING:tensorflow:From /tmpfs/src/tf_docs_env/lib/python3.6/site-packages/tensorflow_core/python/feature_column/feature_column_v2.py:4322: CrossedColumn._num_buckets (from tensorflow.python.feature_column.feature_column_v2) is deprecated and will be removed in a future version.
Instructions for updating:
The old _FeatureColumn APIs are being deprecated. Please use the new FeatureColumn APIs instead.
[[0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]
 [0. 0. 0. ... 0. 0. 0.]]

Choose which columns to use

We have seen how to use several types of feature columns. Now we will use them to train a model. The goal of this tutorial is to show you the complete code (e.g. mechanics) needed to work with feature columns. We have selected a few columns to train our model below arbitrarily.

feature_columns = []

# numeric cols
for header in ['age', 'trestbps', 'chol', 'thalach', 'oldpeak', 'slope', 'ca']:
  feature_columns
.append(feature_column.numeric_column(header))

# bucketized cols
age_buckets
= feature_column.bucketized_column(age, boundaries=[18, 25, 30, 35, 40, 45, 50, 55, 60, 65])
feature_columns
.append(age_buckets)

# indicator cols
thal
= feature_column.categorical_column_with_vocabulary_list(
     
'thal', ['fixed', 'normal', 'reversible'])
thal_one_hot
= feature_column.indicator_column(thal)
feature_columns
.append(thal_one_hot)

# embedding cols
thal_embedding
= feature_column.embedding_column(thal, dimension=8)
feature_columns
.append(thal_embedding)

# crossed cols
crossed_feature
= feature_column.crossed_column([age_buckets, thal], hash_bucket_size=1000)
crossed_feature
= feature_column.indicator_column(crossed_feature)
feature_columns
.append(crossed_feature)

Create a feature layer

Now that we have defined our feature columns, we will use a DenseFeatures layer to input them to our Keras model.

feature_layer = tf.keras.layers.DenseFeatures(feature_columns)

Earlier, we used a small batch size to demonstrate how feature columns worked. We create a new input pipeline with a larger batch size.

batch_size = 32
train_ds
= df_to_dataset(train, batch_size=batch_size)
val_ds
= df_to_dataset(val, shuffle=False, batch_size=batch_size)
test_ds
= df_to_dataset(test, shuffle=False, batch_size=batch_size)

Create, compile, and train the model

model = tf.keras.Sequential([
  feature_layer
,
  layers
.Dense(128, activation='relu'),
  layers
.Dense(128, activation='relu'),
  layers
.Dense(1)
])

model
.compile(optimizer='adam',
              loss
=tf.keras.losses.BinaryCrossentropy(from_logits=True),
              metrics
=['accuracy'])

model
.fit(train_ds,
          validation_data
=val_ds,
          epochs
=5)
Train for 7 steps, validate for 2 steps
Epoch 1/5
7/7 [==============================] - 1s 167ms/step - loss: 5.5965 - accuracy: 0.5337 - val_loss: 4.7812 - val_accuracy: 0.7551
Epoch 2/5
7/7 [==============================] - 0s 10ms/step - loss: 4.1440 - accuracy: 0.7461 - val_loss: 3.5570 - val_accuracy: 0.7551
Epoch 3/5
7/7 [==============================] - 0s 10ms/step - loss: 1.6436 - accuracy: 0.7461 - val_loss: 1.7037 - val_accuracy: 0.3878
Epoch 4/5
7/7 [==============================] - 0s 10ms/step - loss: 0.8367 - accuracy: 0.6166 - val_loss: 1.1000 - val_accuracy: 0.7551
Epoch 5/5
7/7 [==============================] - 0s 10ms/step - loss: 1.0686 - accuracy: 0.7461 - val_loss: 0.5817 - val_accuracy: 0.7959

<tensorflow.python.keras.callbacks.History at 0x7f10c00a9518>
loss, accuracy = model.evaluate(test_ds)
print("Accuracy", accuracy)
2/2 [==============================] - 0s 112ms/step - loss: 0.6410 - accuracy: 0.7213
Accuracy 0.72131145

Next steps

The best way to learn more about classifying structured data is to try it yourself. We suggest finding another dataset to work with, and training a model to classify it using code similar to the above. To improve accuracy, think carefully about which features to include in your model, and how they should be represented.

Comments

Popular posts from this blog

Maxpooling vs minpooling vs average pooling

Percentiles, Deciles, and Quartiles

Data Warehouse Vs Data Mart