diff options
author | Marcin Przybysz <marcin.przybysz@nokia.com> | 2021-03-02 07:25:10 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2021-03-02 07:25:10 +0000 |
commit | f767caa1d32370f28917f243227f2292105c071e (patch) | |
tree | 4f56a7bab9e9cedd8442334f0389c75640d909dc /tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py | |
parent | 527b6f87106cef6651cd6800709c1f2368926a84 (diff) | |
parent | 59bad158d7dd96c157fb9387db2de8ecb9214914 (diff) |
Merge "Add CSITs for Pm-mapper files processing performance"
Diffstat (limited to 'tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py')
-rw-r--r-- | tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py b/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py new file mode 100644 index 00000000..01718e35 --- /dev/null +++ b/tests/dcaegen2-pmmapper/files-processing-config-pmmapper/libraries/LogReader.py @@ -0,0 +1,22 @@ +import re + +class LogReader: + + def filter_unique(self, merged_logs_output, testname): + logs = merged_logs_output.splitlines() + del_logs = list(filter(lambda line: "|DEL|" in line, logs)) + nrs_set = set() + ret_logs = set() + for log in del_logs: + filename = re.findall(testname + "\d", log) + if len(filename) > 0 and filename[0] not in nrs_set: + ret_logs.add(log) + nrs_set.add(filename[0]) + return ret_logs + + def get_number_of_dropped_messages(self, logs_output): + return len(list(filter(lambda line: "|429|" in line, logs_output))) + + def get_log_files_list(self, fileNames): + files = fileNames.split() + return files |