kafka_influxdb.encoder.multiple_replacer() - Code Metrics - Inspection of "Avoid crash in encoder on invalid json input" - mre/kafka-influxdb - Measure and Improve Code Quality continuously with Scrutinizer

kafka-influxdb

Completed

Push — master ( 5cbcf8...d3d059 )

by Matthias

created 2016-06-01 20:27 UTC

kafka_influxdb.encoder.multiple_replacer() A

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Metric	Value
cc	4
dl	0
loc	5
rs	9.2

import re


def multiple_replacer(*key_values):
    replace_dict = dict(key_values)
    replacement_function = lambda match: replace_dict[match.group(0)]
    pattern = re.compile("|".join([re.escape(k) for k, v in key_values]), re.M)
    return lambda string: pattern.sub(replacement_function, string)


def multiple_replace(string, *key_values):
    return multiple_replacer(*key_values)(string)


def influxdb_tag_escaper():
    return multiple_replacer(('\\', '\\\\'), (' ', '\\ '), (',', '\\,'), ('=', '\\='))


1			import re
2
3
4			def multiple_replacer(*key_values):
5			replace_dict = dict(key_values)
6			replacement_function = lambda match: replace_dict[match.group(0)]
7			pattern = re.compile("\|".join([re.escape(k) for k, v in key_values]), re.M)
8			return lambda string: pattern.sub(replacement_function, string)
9
10
11			def multiple_replace(string, *key_values):
12			return multiple_replacer(*key_values)(string)
13
14
15			def influxdb_tag_escaper():
16			return multiple_replacer(('\\', '\\\\'), (' ', '\\ '), (',', '\\,'), ('=', '\\='))
17

mre / kafka-influxdb

Push — master ( 5cbcf8...d3d059 )

kafka_influxdb.encoder.multiple_replacer() A

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like