ObjectsDb.py 文件源码

def decode( cls, data, withRouting = False, isFullDump = False ):
        event = None
        routing = None
        try:
            data = msgpack.unpackb( base64.b64decode( data ), use_list = True )
            if isFullDump:
                event = data
                cls._dataToUtf8( event )
            else:
                if 'event' in data:
                    event = data[ 'event' ]
                    cls._dataToUtf8( event )
                if 'routing' in data and withRouting:
                    routing = data[ 'routing' ]
                    cls._dataToUtf8( routing )
        except:
            event = None
            routing = None

        if withRouting and not isFullDump:
            return routing, event
        else:
            return event