sender.py 文件源码

def save(self):
        buffers = self._buffers
        self._buffers = []
        try:
            filename = str(uuid.uuid3(uuid.NAMESPACE_DNS, "%s_%s" % (time.time(), randint(0, 100000))))
            filename = os.path.join(self._cache, filename)
            fp = open(filename, 'w')
            for event in buffers:
                fp.write(str(event))
            return filename
        except Exception, e:
            return 'Save Failed, cause: %s' % e