checkConsistency.py

__author__ = 'xudshen'
import hashlib

cache = {}

def insertAlert(type, timestamp, desc, host, cluster):
    global cache
    id = hashlib.md5((type + timestamp + desc + host).encode("utf8")).hexdigest()
    if not id in cache:
        cache[id] = []
    cache[id].append({'cluster':cluster, 'type':type, 'timestamp':timestamp, 'desc':desc, 'host':host})

def isOK(arr):
    global cache
    return len(set(map(lambda x:x['cluster'] ,arr))) == 2

def checkAlert():
    global cache
    print(dict((key,value) for key, value in cache.items() if not isOK(value)))

insertAlert("type1", "123", "desccccc", "hostname1", "titan")
insertAlert("type2", "123", "desccccc", "hostname1", "titan")
insertAlert("type2", "123", "desccccc", "hostname1", "titan")
insertAlert("type1", "123", "desccccc", "hostname1", "cluster4ut")

#print(cache)
checkAlert()