机器学习实战-使用FP-growth算法来高效发现频繁项集

上一章介绍了发现频繁项集与关键规则的算法,本章将继续关注发现频繁项集这一任务。我们会深入探索该任务的解决方法,并应用FP-growth算法进行处理。这种算法虽然能更为高效地发现频繁项集,但不能用于发现关联规则。

FP-growth算法
优点:一般要快于Apriori
缺点:实现比较困难,在某些数据集上性能会下降
适用数据类型:标称型数据

FP-growth算法讲数据存储在一种称为FP树的紧凑数据结构中。FP代表频繁模式,Frequent pattern。同搜索树不同的是,一个元素项可以在一棵FP树中出现多次。FP树会存储项集的出现频率,而每个项集会以路径的方式存储在树中。
相似点之间的链接即节点链接(node link),用于快速发现相似的位置。
本章的FP树比书中的其他树更加复杂,因此要创建一个类来保存树的每一个节点:

#FP树
class treeNode:
    def __init__(self, nameValue, numOccur, parentNode):
        self.name = nameValue
        self.count = numOccur#计数器
        self.nodeLink = None#用于链接相似的元素项
        self.parent = parentNode#指向父节点,需要被更新
        self.children = {} #存放子节点
    
    def inc(self, numOccur):
        self.count += numOccur
        
    def disp(self, ind=1):
        print '  '*ind, self.name, ' ', self.count
        for child in self.children.values():
            child.disp(ind+1)

先创建树中的一个单节点:

In [45]: import fpGrowth
    ...: rootNode = fpGrowth.treeNode('pyramid',9,None)

接下来增加一个子节点:

In [46]: rootNode.children['eye'] = fpGrowth.treeNode('eye',13,None)

显示子节点:

In [47]: rootNode.disp()
   pyramid   9
     eye   13

再增加一个节点看看子节点的展示效果:

In [48]: rootNode.children['phoenix']=fpGrowth.treeNode('phoenix',3,None)
    ...: rootNode.disp()
    ...: 
   pyramid   9
     eye   13
     phoenix   3

除了刚刚给出的FP树以外,还需要一个头指针表来指向给定类型的第一个实例。这里使用一个字典作为数据结构,来保存头指针表。除了存放指针外,头指针表还可以用来存放FP树中每类元素的总数。
接下来,我们通过代码来实现上述过程:

def createTree(dataSet, minSup=1): #数据集,最小支持度
    headerTable = {}
    #遍历数据集两次
    for trans in dataSet:#统计
        for item in trans:
            headerTable[item] = headerTable.get(item, 0) + dataSet[trans]
    for k in headerTable.keys():  #移除不满足最小支持度的元素项
        if headerTable[k] < minSup: 
            del(headerTable[k])
    freqItemSet = set(headerTable.keys())
    #print 'freqItemSet: ',freqItemSet
    if len(freqItemSet) == 0: return None, None  #都不满足,则退出
    for k in headerTable:
        headerTable[k] = [headerTable[k], None] #修改为下一步准备
    #print 'headerTable: ',headerTable
    retTree = treeNode('Null Set', 1, None) #根节点
    for tranSet, count in dataSet.items():  #第二次遍历
        localD = {}
        for item in tranSet:  #排序
            if item in freqItemSet:
                localD[item] = headerTable[item][0]
        if len(localD) > 0:
            orderedItems = [v[0] for v in sorted(localD.items(), key=lambda p: p[1], reverse=True)]
            updateTree(orderedItems, retTree, headerTable, count)#用排序后的频率项进行填充
    return retTree, headerTable 

def updateTree(items, inTree, headerTable, count):
    if items[0] in inTree.children:#检查第一个元素是否作为子节点存在
        inTree.children[items[0]].inc(count) #更新计数
    else:   #新建一个子节点添加到树中
        inTree.children[items[0]] = treeNode(items[0], count, inTree)
        if headerTable[items[0]][1] == None: 
            headerTable[items[0]][1] = inTree.children[items[0]]
        else:
            updateHeader(headerTable[items[0]][1], inTree.children[items[0]])
    if len(items) > 1:#对剩下的元素项迭代调用,每一次奥调用去掉第一个元素
        updateTree(items[1::], inTree.children[items[0]], headerTable, count)
        
def updateHeader(nodeToTest, targetNode):   #确保节点链接指向树中该元素项的每一个实例
    while (nodeToTest.nodeLink != None):    #直达链尾
        nodeToTest = nodeToTest.nodeLink
    nodeToTest.nodeLink = targetNode

下面将数据集和数据包装器加入代码中:

def loadSimpDat():
    simpDat = [['r', 'z', 'h', 'j', 'p'],
               ['z', 'y', 'x', 'w', 'v', 'u', 't', 's'],
               ['z'],
               ['r', 'x', 'n', 'o', 's'],
               ['y', 'r', 'x', 'z', 'q', 't', 'p'],
               ['y', 'z', 'x', 'e', 'q', 's', 't', 'm']]
    return simpDat

def createInitSet(dataSet):
    retDict = {}
    for trans in dataSet:
        retDict[frozenset(trans)] = 1
    return retDict

首先,导入数据库实例:

In [2]: import fpGrowth
   ...: simpDat = fpGrowth.loadSimpDat()
   ...: 

In [3]: simpDat
Out[3]: 
[['r', 'z', 'h', 'j', 'p'],
 ['z', 'y', 'x', 'w', 'v', 'u', 't', 's'],
 ['z'],
 ['r', 'x', 'n', 'o', 's'],
 ['y', 'r', 'x', 'z', 'q', 't', 'p'],
 ['y', 'z', 'x', 'e', 'q', 's', 't', 'm']]

接下来为了函数createTree(),需要对上面的数据进行格式化处理:

In [4]: initSet = fpGrowth.createInitSet(simpDat)
   ...: initSet
   ...: 
Out[4]: 
{frozenset({'e', 'm', 'q', 's', 't', 'x', 'y', 'z'}): 1,
 frozenset({'n', 'o', 'r', 's', 'x'}): 1,
 frozenset({'z'}): 1,
 frozenset({'s', 't', 'u', 'v', 'w', 'x', 'y', 'z'}): 1,
 frozenset({'p', 'q', 'r', 't', 'x', 'y', 'z'}): 1,
 frozenset({'h', 'j', 'p', 'r', 'z'}): 1}

于是可以通过如下 命令创建FP树:

In [10]: myFPtree, myHeaderTab = fpGrowth.createTree(initSet, 3)
    ...: myFPtree.disp()
    ...: 
   Null Set   1
     x   1
       s   1
         r   1
     z   5
       x   3
         y   3
           s   2
             t   2
           r   1
             t   1
       r   1

上面给出的是元素项及其对应的频率计数值,其中每个缩进表示所处的树的深度。
现在我们已经构建了FP树,接下来就使用它进行数据挖掘。
从FP树中抽取频繁项集的三个基本步骤如下:
(1)从FP树中获取条件模式基;
(2)利用条件模式基,构建一个条件FP树;
(3)迭代重复步骤(1)和步骤(2),直到树包含一个元素项为止。

首先从上一节发现的已经保存在头指针表中的单个频繁元素项开始。对于每一个元素项,获得其对于的条件模式基(conditional pattern base)。条件模式基是以所查找元素项为结尾的路径集合。每一条路径其实都是一条前缀路径(prefixpath)。简而言之,一条前缀路径是介于所查找元素项与树根节点之间的所有内容。
下面的程序清单给出了前缀路径发现的代码:

def ascendTree(leafNode, prefixPath): #迭代回溯整棵树
    if leafNode.parent != None:
        prefixPath.append(leafNode.name)
        ascendTree(leafNode.parent, prefixPath)
   
#遍历链表直到到达结尾,每遇到一个元素项都会调用ascendTree()函数来上溯FP树,ing收集所有遇到的元素项的名称    
def findPrefixPath(basePat, treeNode): 
    condPats = {}
    while treeNode != None:
        prefixPath = []
        ascendTree(treeNode, prefixPath)
        if len(prefixPath) > 1: 
            condPats[frozenset(prefixPath[1:])] = treeNode.count
        treeNode = treeNode.nodeLink
    return condPats

使用之前构建的树来看一下实际的运行效果:

In [4]: import fpGrowth
   ...: fpGrowth.findPrefixPath('x',myHeaderTab['x'][1])
   ...: 
Out[4]: {frozenset({'z'}): 3}

In [5]: fpGrowth.findPrefixPath('z',myHeaderTab['z'][1])
Out[5]: {}

In [6]: fpGrowth.findPrefixPath('r',myHeaderTab['r'][1])
Out[6]: {frozenset({'s', 'x'}): 1, frozenset({'z'}): 1, frozenset({'x', 'y', 'z'}): 1}

下面继续补充完整程序:

def mineTree(inTree, headerTable, minSup, preFix, freqItemList):
    bigL = [v[0] for v in sorted(headerTable.items(), key=lambda p: p[1])]#对头指针表的元素项按照其出现的频率进行排序
    for basePat in bigL:  #从头指针的底端开始
        newFreqSet = preFix.copy()
        newFreqSet.add(basePat)
        freqItemList.append(newFreqSet)
        condPattBases = findPrefixPath(basePat, headerTable[basePat][1])
        myCondTree, myHead = createTree(condPattBases, minSup)
        if myHead != None: #递归调用
            print 'conditional tree for: ',newFreqSet
            myCondTree.disp(1)      
            mineTree(myCondTree, myHead, minSup, newFreqSet, freqItemList)

接下来运行mineTree(),显示出所有的条件树:

In [14]: import fpGrowth
    ...: freqItems = []
    ...: fpGrowth.mineTree(myFPtree, myHeaderTab, 3, set([]),freqItems)
    ...: 
conditional tree for:  set(['y'])
   Null Set   1
     x   3
       z   3
conditional tree for:  set(['y', 'z'])
   Null Set   1
     x   3
conditional tree for:  set(['s'])
   Null Set   1
     x   3
conditional tree for:  set(['t'])
   Null Set   1
     y   3
       x   3
         z   3
conditional tree for:  set(['z', 't'])
   Null Set   1
     y   3
       x   3
conditional tree for:  set(['x', 'z', 't'])
   Null Set   1
     y   3
conditional tree for:  set(['x', 't'])
   Null Set   1
     y   3
conditional tree for:  set(['x'])
   Null Set   1
     z   3

下面检查一下返回的项集是否与条件树匹配:

In [15]: freqItems
Out[15]: 
[{'y'},
 {'y', 'z'},
 {'x', 'y', 'z'},
 {'x', 'y'},
 {'s'},
 {'s', 'x'},
 {'t'},
 {'t', 'z'},
 {'t', 'y', 'z'},
 {'t', 'x', 'z'},
 {'t', 'x', 'y', 'z'},
 {'t', 'x'},
 {'t', 'x', 'y'},
 {'t', 'y'},
 {'r'},
 {'x'},
 {'x', 'z'},
 {'z'}]
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,042评论 6 490
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 89,996评论 2 384
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 156,674评论 0 345
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,340评论 1 283
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,404评论 5 384
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,749评论 1 289
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,902评论 3 405
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,662评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,110评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,451评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,577评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,258评论 4 328
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,848评论 3 312
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,726评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,952评论 1 264
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,271评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,452评论 2 348

推荐阅读更多精彩内容