reclog_objectifier.py

def objectify(frame):
    """ yeilds one parsed object defined by the parsers in
    the waas library.
    """
    parsers = {'SP': sp_log.parse,
               'CP': cp_log.parse,
               'WAAS': waas_log.parse,
               }
    log_source = frame['log_type']

    if log_source in parsers:
        parse = parsers[ log_source ]

        for [(raw_line, channel, msg) for raw_line in frame['lines'] for channel, msg in parse(raw_line)]:
            if channel:
                msg.update({'site': frame['site_name']})
                yield {'channel': log_source + '.' + channel,
                        'msg': msg}
            else:  # channel was None
                yield {'channel': log_source + '.' + 'UNPARSED',
                        'msg': {'line': raw_line,
                                'site': frame['site_name']}}