Streaming log lines from journald in python 3

journald_stream.py

import asyncio

from systemd import journal

class Journal(object):

    def __init__(self, unit):
        self.journal = journal.Reader()
        # self.journal.log_level(journal.LOG_INFO)
        self.journal.add_match(_SYSTEMD_UNIT=unit)
        self.journal.seek_tail()
        self.journal.get_previous()

    def attach_to_loop(self, loop):
        loop.add_reader(self.journal.fileno(), self.process)

    def process_entry(self, entry):
        print(str(entry['__REALTIME_TIMESTAMP'] )+ ' ' + entry['MESSAGE'])

    def process(self):
        if self.journal.process() != journal.APPEND:
            return
        for entry in self.journal:
            self.process_entry(entry)


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    Journal("pubbot.service").attach_to_loop(loop)
    loop.run_forever()