Parsing Tivoli Storage Manager logs for syslog-ng

dsm.conf

log {
    source { file("/var/log/dsmsched.log" follow-freq(10) flags(no-parse)); };
    parser { python(class("TivoliParser")); };
    destination(d_syslog_tcp);
};

python {
import re
import dateutil.parser
import socket
class TivoliParser(object):
    def init(self, options):
        self.regex = re.compile('(?P<timestamp>\d{2}\/\d{2}\/\d{4} \d{2}:\d{2}:\d{2}) +(?P<MSG>.+)')
        self.host = socket.gethostname()
        return True
    def parse(self, log_message):
        match = re.match(self.regex, log_message['MESSAGE'])
        if match:
            for key, value in match.groupdict().items():
                log_message[key] = value
            
            log_message['R_UNIXTIME'] = dateutil.parser.parse(log_message['timestamp']).strftime('%s')
            log_message['HOST'] = self.host
            return True
        return False
};