def __getUTF8Encoding()

in provider/consumer.py [0:0]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    def __getUTF8Encoding(self, value):
        try:
            value.decode('utf-8')
        except UnicodeDecodeError:
            try:
                logging.debug('[{}] Value is not UTF-8 encoded. Attempting encoding...'.format(self.trigger))
                value = value.encode('utf-8')
            except UnicodeDecodeError:
                logging.debug('[{}] Value contains non-unicode bytes. Replacing invalid bytes.'.format(self.trigger))
                value = unicode(value, errors='replace').encode('utf-8')
        except AttributeError:
            logging.debug('[{}] Cannot decode a NoneType message value'.format(self.trigger))

        return value