Function consume has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

    def consume(self):
        """
        Run loop. Consume messages from reader, convert it to the
        output format using encoder and write to output with writer
        """

• Read up
  Read up

Function encode has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def encode(self,
               msg,
               delimiter='.',
               prefix='',
               prefix_tag=None,

• Read up
  Read up

Function __init__ has 11 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(self,

Function _handle_read has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

    def _handle_read(self):
        """
        Read messages from Kafka.
        """
        while True:

• Read up
  Read up

Function parse_args has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

def parse_args(args=sys.argv[1:]):
    parser = argparse.ArgumentParser(description='A Kafka consumer for InfluxDB',
                                     formatter_class=argparse.ArgumentDefaultsHelpFormatter)
    parser.add_argument('--kafka_host', type=str, default=argparse.SUPPRESS,
                        help="Hostname or IP of Kafka message broker (default: localhost)")

Function load_reader has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

def load_reader(name, host, port, group, topic, offset):

Function encode has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def encode(self,

Function __init__ has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(self, host, port, group, topic, offset, broker_version=KAFKA_VERSION_ZOOKEEPER_OPTIONAL):

Function encode has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    def encode(self, msg):
        # type: (bytes) -> List[Text]
        measurements = []

        for line in msg.decode().split("\n"):

• Read up
  Read up

Function flatten has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

def flatten(d, parent_key='', sep='_'):
    """
    Flatten keys in a dictionary
    Example:
    flatten({'a': 1, 'c': {'a': 2, 'b': {'x': 5, 'y' : 10}}, 'd': [1, 2, 3]})

• Read up
  Read up

Function format_measurement_name has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def format_measurement_name(entry, args):
        name = []
        for arg in args:
            if arg in entry:
                # avoid to add extra _ if some entry value is None

• Read up
  Read up

Function format_tags has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def format_tags(entry, args):
        tag = []
        for arg in args:
            if arg in entry:
                # to avoid add None as tag value

• Read up
  Read up