REDROOM

Edit File Size: 4.25 KB

/home/godevadmin/public_html/upload_images/home/000~ROOT~000/lib/fm-agent/library/log_matcher.py

Text Base64

import re
from datetime import datetime, timedelta
import logging
import os

class LogMatcher(object):
    """
    Handles the matching of filter in the logs.
    """

def __init__(self, inode):
        """
        @param file_creation: last known creation timestamp of the log file.
        """
        self._inode = inode

def match(self, lines, expression, results=None):
        """
        Match the ampount of times expression is present in lines,
        return the results with the new entry appended to it.

@param expression: String,
        @param lines: Iterable
        @param results: List of past results
        """
        if not results:
            results = []
        try:
            self._valid_inode()
        except ValueError:
            import sys

_, error, _ = sys.exc_info()
            logging.info(error)
            return []
        else:

def find_match(line):
                match = re.search(expression, line)
                return match and line or False

matched_lines = list(filter(find_match, lines))
            results.append((datetime.now(), len(matched_lines)))
            return results

def match_in_column(self, lines, expression, column, results=None):
        """
        Return the number of lines that the where the column is
        equal to the expression by splitting the lines.

@param lines: Array of lines to split and search.
        @param expression: Regular expression to match agains the specified column
        @param column: Column number to separate from the regular line.
        @param results: List of past results
        """
        if not results:
            results = []
        try:
            self._valid_inode()
        except ValueError:
            import sys

_, error, _ = sys.exc_info()
            logging.info(error)
            return []
        splitted_lines = [line.split() for line in lines]

def find_match(line):
            data_point = line[column]
            match = re.search(expression, data_point)
            return match and line or False

matched_lines = list(filter(find_match, splitted_lines))
        results.append((datetime.now(), len(matched_lines)))
        return results

def _valid_inode(self):
        """
        Validate that we have an inode. If we dont
        that means we are running the check for the first time,
        and don't have enought information to calculate the matchs.
        """
        if self._inode is None:
            raise ValueError("Inode is None. Returning None")

def calculate_metric(self, results, timescale):
        """
        Check the results and the timescale to determine if a metric
        should be given. The delta between now and the last results time
        must be greater than the timescale to properly calculate the metric.

@param results: List of past results.
        @param timescale: Integer of the buffer size to take into
        consideration.
        @param last_results_time: Datetime
        """
        total_sum = 0
        valid_results = []
        for timestamp, result in results:
            delta = datetime.now() - timestamp
            if delta < timedelta(minutes=timescale):
                total_sum += result
                valid_results.append((timestamp, result))
        if not self._inode:
            return None, []
        return total_sum, valid_results

@staticmethod
    def get_file_lines(last_known_line_number, source, current_inode, stored_inode):
        """
        Grab the lines from the last known line number to the
        end of the file.
        """
        expected_lines = []
        index = 0
        total_lines = 0
        opened_file = open(source, "r")
        if stored_inode is None:
            for index, line in enumerate(opened_file):
                pass
            total_lines = index
        else:
            for index, line in enumerate(opened_file):
                if index > last_known_line_number:
                    expected_lines.append(line)
            total_lines = index
        opened_file.close()

return total_lines, expected_lines

@staticmethod
    def get_file_inode(source):
        """
        Grab the file created timstamp.
        """
        return os.stat(source).st_ino

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
__pycache__ DIR	-	drwxr-xr-x	2025-06-19 05:08:01	Edit Download recursive recursive
agent.py	107.89 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
agent_exceptions.py	110 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
agent_util.py	9.19 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
aggregator.py	14.82 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
anomaly.py	2.17 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
blacklister.py	807 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
container_discovery.py	3.54 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
display.py	2.12 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
forticlient_helper.py	2.99 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
inspector.py	16.17 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
ipc_client.py	2.97 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
iperf3.py	1.96 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
log_matcher.py	4.25 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
maintenance.py	3.62 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
pickle_database.py	1.34 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
plugin_driver.py	5.32 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
plugin_manager.py	11.69 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
process_manager.py	872 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
progress_printer.py	874 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
result_queue.py	1.99 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
schedule.py	3.23 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
threshold.py	1.48 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
__init__.py	0 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive

Directory Contents