跟着b站补基础,视频链接:第一章:决策树原理 1-决策树算法概述_哔哩哔哩_bilibili
· 决策树:从根节点开始一步步走到叶子节点(决策 )。
· 所有的数据最终都会落到叶子节点,既可以做分类也可以做回归。
如上图根据不同的特征:年龄以及性别进行决策 ,5个人(数据)落到了三个叶子节点。
分类问题是从不同类型的数据中学习到这些数据间的边界,比如通过鱼的体长、重量、鱼鳞色泽等维度来分类鲶鱼和鲤鱼,这是一个定性问题。
回归问题则是从同一类型的数据中学习到这种数据中不同维度间的规律,去拟合真实规律,比如通过数据学习到面积、房间数、房价几个维度的关系,用于根据面积和房间数预测房价,这是一个定量问题。
[以上分类与回归问题的文章:ML科普系列(二)分类与回归 - 北岛知寒 - 博客园 (cnblogs.com)]
在决策树当中,选择特征进行决策的顺序是很重要的,不同的决策顺序出来的结果可能会受影响而不同,所以把握决策的顺序是很重要的。
· 根节点:第一个选择点(没有前驱的节点,上图中的根节点就是“age<15”)
· 非叶子节点与分支:中间过程
· 叶子节点:最终的决策结果(没有后继的节点,上图的叶子节点就是最后的三个⚪)
· 训练阶段:从给定的训练集构造出来一棵树(从根节点开始选择特征,如何进行特征切分)
· 测试阶段:根据构造出来的树模型从上到下走一遍就好了
这里的难点在于如何进行训练,特征的选择顺序应该怎么排。
对于根节点的选择,我们的目标应该是根节点就像一个老大似的能更好的切分数据(分类的效果更好),根节点下面的节点自然就是二当家了,以此类推,数据能很快就完成了分类。
所以这就相当于,通过一种衡量标准,来计算通过不同特征进行分支选择后的分类情况,找出来最好的那个当成根节点,以此类推。
熵:表示随机变量不确定的度量(说白了就是混乱程度,商场买的类别越多就越混乱,专卖店只买一种类别就越稳定)
公式:
pi表示概率,我们都知道属于某一类的概率只会在[0,1],使用log的时候就在(-∞,0]区间内,前面有-号,也就是[0,∞),再乘以pi,最终结果还是正值,然后将所有的情况进行累加。
举个例子:A集合[1,1,1,1,1,1,1,2,2]、B集合[1,2,3,4,5,6,7,8,9]
显然A的类别少熵值小,B的类别多熵值大。
- import math
-
- def calculate_entropy(data):
- frequency = {} # 计算每个元素出现的次数
- for item in data:
- if item in frequency:
- frequency[item] += 1
- else:
- frequency[item] = 1
- total_elements = len(data) # 计算总元素数量
-
- entropy = 0 # 计算熵
- for item, count in frequency.items():
- p = count / total_elements # 计算当前元素出现的概率
- entropy -= p * math.log2(p) # 累加熵
-
- return entropy
-
- A = [1, 1, 1, 1, 1, 1, 1, 2, 2]
- B = [1, 2, 3, 4, 5, 6, 7, 8, 9]
-
- entropy_A = calculate_entropy(A)
- print(f"集合A的熵为: {entropy_A}")
- entropy_B = calculate_entropy(B)
- print(f"集合B的熵为: {entropy_B}")
因此可以知道,我们要想分类效果越好,就要熵值越小越好。也就是说,接下来要做的是让分类更好,就是让熵值越来越小,也就是要让熵值下降,且选择熵值下降越多的。
计算可知,当p=0.5的时候,H(p)=1,此时的随机变量不确定值最大;p=0或p=1时,H(p)=0,此时的随机变量不确定值最小。
在选择决策节点的时候,要考虑信息增益:表示特征X使得类Y的不确定性减少的程度。
有以下数据,一共14条数据、4个特征。
在进行决策选择的时候,根据不同的特征有不同的结果:
这时候就可以计算信息增益,来选择决策节点。在历史数据中,14天有9天打球,据此计算此时的熵值:
4个特征逐一分析:
根据数据统计,outlook取值分别为sunny、overcast、rainy的概率分别为:5/14、4/14、5/14
熵值计算:5/14*0.971 + 4/14*0 + 5/14*0.971 = 0.693
信息增益:系统的熵值从原始的0.940下降到了0.693,增益为0.247
同样的方式可以计算出其他特征的信息增益,选择增益最多的就好了。
计算得到:gain(temperature)=0.029 gain(humidity)=0.152 gain(windy)=0.048
所以最终选的的是outlook该特征进行决策。接下来就继续再现在分出来的3个类种,继续分别进行决策划分,选择二当家,以此类推。
注:这部分是AI生成的,参考的文章:决策树三种算法比较(ID3、C4.5、CART)_三种决策树算法的区别-CSDN博客
ID3、C4.5、CART三种决策树的区别_id3决策树和c4.5决策树的区别-CSDN博客
对于离散值,也就是类似于前面这种,可以根据特征进行选择,对于连续值也是类似的,选择一个值将数据进行离散化就好了。
决策树随着划分的越来越细,在训练的时候效果会越来越好,但是在别的数据集上的泛化能力可能比较差效果不好,这就是过拟合情况,为了减少过拟合程度,因此要进行剪枝操作。
预剪枝是边建立决策树边进行剪枝的操作。比如限制深度、叶子节点个数、叶子节点样本数、信息增益量等。
后剪枝是当建立完决策树后来进行剪枝操作。需要通过一定的衡量标准。C(T)是基尼系数,α是自己设置的,T_leaf是叶子节点数
如下是一个决策树图,X[]表示对应数据集种的哪个特征,gini是基尼系数,samples是当前节点所有样本数量,value是不同类别的数量,例如第一个框中,[49,50,50]表示的是a类有49个b类有50个c类有50个。
基尼系数表示在全部居民收入中,用于进行不平均分配的那部分收入占总收入的百分比。社会中每个人的收入都一样、收入分配绝对平均时,基尼系数是 0; 全社会的收入都集中于一个人、收入分配绝对不平均时,基尼系数是 1。现实生活中,两种情况都不可能发生,基尼系数的实际数值只能介于 0 ~ 1 之间。【参考:什么是基尼系数 - 国家统计局 (stats.gov.cn)】
例如上图第一个节点的左孩子节点,gini为0,因为它所有数据都属于a类,此时达到了纯化。
某个节点要不要分裂,需要按照公式计算,如果新的C值比较大,就说明损失严重,需要分裂。
对于分类问题可以根据熵值进行划分,而回归问题则根据方差结果(离散程度),预测结果是取该节点中所有数的平均数。
这里使用的是iris数据集
- from sklearn.datasets import load_iris
- from sklearn.model_selection import train_test_split
- from sklearn.tree import DecisionTreeClassifier
- from sklearn import tree
- import matplotlib.pyplot as plt
-
- iris = load_iris() # 加载示例数据集
- X = iris.data # 特征
- y = iris.target # 标签
- X_train, X_test, y_train, y_test = train_test_split(X, y, test_size=0.3, random_state=42)
-
- # 创建决策树分类器
- clf = DecisionTreeClassifier(criterion='entropy', max_depth=3, random_state=42)
- clf.fit(X_train, y_train) # 训练模型
- y_pred = clf.predict(X_test) # 预测
- accuracy = clf.score(X_test, y_test) # 模型准确率
- print(f"模型准确率: {accuracy:.2f}")
-
- plt.figure(figsize=(6, 4)) # 可视化决策树
- tree.plot_tree(clf, feature_names=iris.feature_names, class_names=iris.target_names, filled=True)
- plt.show()
生成的决策树如下所示:
输出结果:
模型准确率: 0.98
- import matplotlib.pyplot as plt
- from math import log
- import operator
-
- # part1:定义数据集
- def creatDataSet():
- DataSet = [
- [0, 0, 0, 0, 'no'],
- [0, 0, 0, 1, 'no'],
- [0, 1, 0, 1, 'yes'],
- [0, 1, 1, 0, 'yes'],
- [0, 0, 0, 0, 'no'],
- [1, 0, 0, 0, 'no'],
- [1, 1, 1, 1, 'yes'],
- [1, 0, 1, 2, 'yes'],
- [1, 0, 1, 2, 'yes'],
- [2, 0, 1, 2, 'yes'],
- [2, 0, 1, 1, 'yes'],
- [2, 1, 0, 1, 'yes'],
- [2, 1, 0, 2, 'yes'],
- [2, 0, 0, 0, 'no']]
- labels = ['F1-AGE', 'F2-WORK', 'F3-HOME', 'F4-LOAN']
- return DataSet, labels
-
-
- # part2:创建树
- def createTree(DataSet, labels, featLabels):
- # 其实就是labels-classList:['no', 'no', 'yes', 'yes', 'no', 'no', 'yes', 'yes', 'yes', 'yes', 'yes', 'yes', 'yes', 'no']
- classList = [example[-1] for example in DataSet]
-
- # 判断是否只属于一类,所有数据均属于同一类则返回该类别
- if classList.count(classList[0]) == len(classList):
- return classList[0]
-
- # 判断特征是否删除完毕,返回最多的类
- if len(DataSet[0]) == 1:
- return majorityCnt(classList)
-
- # 得到最佳收益的特征
- bestFeat = chooseBestFeatureTosplit(DataSet)
-
- # 得到最佳收益的label
- bestFeatLabel = labels[bestFeat]
-
- # 添加最佳label
- featLabels.append(bestFeatLabel)
-
- myTree = {bestFeatLabel: {}}
-
- # 删除特征
- del(labels[bestFeat])
-
- # 得到最佳特征的所有值
- featValue = [example[bestFeat] for example in DataSet]
- uniqueVals = set(featValue)
-
- # 自调用创建树
- for value in uniqueVals:
- sublabels = labels[:]
- myTree[bestFeatLabel][value] = createTree(splitDataSet(DataSet, bestFeat, value), sublabels, featLabels)
- return myTree
-
-
- # 决策完成之后,统计类别最多的类
- def majorityCnt(classList):
- classCount = {}
- for vote in classList:
- if vote not in classCount.keys():
- classCount[vote] = 0
- classCount[vote] += 1
- sortedClassCount = sorted(classCount.items(), key=operator.itemgetter(1), reverse=True)
- return sortedClassCount[0][0]
-
- # 得到使得增益最高的特征
- def chooseBestFeatureTosplit(DataSet):
- numFeatures = len(DataSet[0]) - 1 # 统计特征个数
- baseEntropy = calcshannonEnt(DataSet) # 计算最右边特征的熵值,也就是还没进行决策的初始熵
- bestInfoGain = 0.0
- bestFeature = -1
- for i in range(numFeatures):
- featList = [example[i] for example in DataSet] # 存储第i个特征的所有数据
- uniqueVals = set(featList) # 只保留唯一数据
- newEntropy = 0.0
- for value in uniqueVals: # 计算根据某标签进行划分后的熵
- subDataSet = splitDataSet(DataSet, i, value)
- prob = len(subDataSet) / float(len(DataSet))
- newEntropy += prob * calcshannonEnt(subDataSet)
- infoGain = baseEntropy - newEntropy # 计算增益
- if infoGain > bestInfoGain: # 判断是否是最佳特征及最佳增益
- bestInfoGain = infoGain
- bestFeature = i
- return bestFeature
-
- # 按照第i个特征划分不同值的数量(value在前面是循环的,所以会统计到每一类),并删掉该特征
- def splitDataSet(DataSet, axis, value):
- retDataSet = []
- for featVec in DataSet:
- if featVec[axis] == value:
- reducedFeatVec = featVec[:axis]
- reducedFeatVec.extend(featVec[axis + 1:])
- retDataSet.append(reducedFeatVec)
- return retDataSet
-
- # 计算某个特征的熵值
- def calcshannonEnt(DataSet):
- numExamples = len(DataSet) # 统计数据量
- labelCounts = {}
- for featVec in DataSet: # labelCounts:存储最后一个特征的类别及数量
- currentLabel = featVec[-1]
- if currentLabel not in labelCounts.keys():
- labelCounts[currentLabel] = 0
- labelCounts[currentLabel] += 1
- shannonEnt = 0.0
- for key in labelCounts: # 计算某个特征的熵值
- prob = float(labelCounts[key]) / numExamples
- shannonEnt -= prob * log(prob, 2)
- return shannonEnt
-
- # 定义节点的格式
- decisionNode = dict(boxstyle="sawtooth", fc="0.8")
- leafNode = dict(boxstyle="round4", fc="0.8")
- arrow_args = dict(arrowstyle="<-")
-
-
- def plotTree(myTree, parentPt, nodeTxt):
- # 如果 myTree 是一个叶节点,直接返回
- if type(myTree).__name__ != 'dict':
- plotNode(myTree, parentPt, parentPt, leafNode)
- return
-
- numLeafs = getNumLeafs(myTree)
- depth = getTreeDepth(myTree)
- firstStr = list(myTree.keys())[0]
- cntrPt = (plotTree.xOff + (1.0 + float(numLeafs)) / 2.0 / plotTree.totalW, plotTree.yOff)
- plotMidText(cntrPt, parentPt, nodeTxt)
- plotNode(firstStr, cntrPt, parentPt, decisionNode)
- secondDict = myTree[firstStr]
- plotTree.yOff = plotTree.yOff - 1.0 / plotTree.totalD
- for key in secondDict.keys():
- if type(secondDict[key]).__name__ == 'dict':
- plotTree(secondDict[key], cntrPt, str(key))
- else:
- plotTree.xOff = plotTree.xOff + 1.0 / plotTree.totalW
- plotNode(secondDict[key], (plotTree.xOff, plotTree.yOff), cntrPt, leafNode)
- plotMidText((plotTree.xOff, plotTree.yOff), cntrPt, str(key))
- plotTree.yOff = plotTree.yOff + 1.0 / plotTree.totalD
-
-
- def plotMidText(cntrPt, parentPt, txtString):
- xMid = (parentPt[0] - cntrPt[0]) / 2.0 + cntrPt[0]
- yMid = (parentPt[1] - cntrPt[1]) / 2.0 + cntrPt[1]
- plt.text(xMid, yMid, txtString)
-
- def plotNode(nodeTxt, centerPt, parentPt, nodeType):
- plt.annotate(nodeTxt, xy=parentPt, xycoords='axes fraction', xytext=centerPt, textcoords='axes fraction',
- va="center", ha="center", bbox=nodeType, arrowprops=arrow_args)
-
- def createPlot(inTree):
- fig = plt.figure(1, facecolor='white')
- fig.clf()
- axprops = dict(xticks=[], yticks=[])
- createPlot.ax1 = plt.subplot(111, frameon=False, **axprops)
- plotTree.totalW = float(getNumLeafs(inTree))
- plotTree.totalD = float(getTreeDepth(inTree))
- plotTree.xOff = -0.5 / plotTree.totalW
- plotTree.yOff = 1.0
- plotTree(inTree, (0.5, 1.0), '')
- plt.show()
-
- def getNumLeafs(myTree):
- numLeafs = 0
- # 如果 myTree 是一个叶子节点,直接返回1
- if type(myTree).__name__ != 'dict':
- return 1
- firstStr = list(myTree.keys())[0]
- secondDict = myTree[firstStr]
- for key in secondDict.keys():
- if type(secondDict[key]).__name__ == 'dict':
- numLeafs += getNumLeafs(secondDict[key])
- else:
- numLeafs += 1
- return numLeafs
-
- def getTreeDepth(myTree):
- maxDepth = 0
- # 如果 myTree 是一个叶子节点,深度为1
- if type(myTree).__name__ != 'dict':
- return 1
- firstStr = list(myTree.keys())[0]
- secondDict = myTree[firstStr]
- for key in secondDict.keys():
- if type(secondDict[key]).__name__ == 'dict':
- thisDepth = 1 + getTreeDepth(secondDict[key])
- else:
- thisDepth = 1
- if thisDepth > maxDepth:
- maxDepth = thisDepth
- return maxDepth
-
- if __name__ == '__main__':
- DataSet, labels = creatDataSet()
- featLabels = []
- myTree = createTree(DataSet, labels, featLabels)
- createPlot(myTree)
输出结果: