syslogpublisher.py 文件源码

def publish(self, host, data):
        code = 200
        if self.isBST(data):
            success, sdata = BSTToMonasca().serialize(host, data)
        elif self.isPT(data):
            success, sdata = PTToMonasca().serialize(host, data)
        elif self.isBHD(data):
            success, sdata = BHDToMonasca().serialize(host, data)
        else:
            success = False
        if success:
            sdata = json.loads(sdata)

            for x in sdata:
                syslog.syslog(json.dumps(x))
        else:
            code = 500
        return code