Чтение журнала systemd из скрипта Python

Я также работаю над аналогичным модулем Python.

Согласно следующим ссылкам, мы должны вызвать sd_journal_previous (в модуле python systemd это journal.Reader().get_previous()).

http://www.freedesktop.org/software/systemd/man/sd_journal_seek_tail.html

https://bugs.freedesktop.org/show_bug.cgi?id=64614

Кроме того, код вашего примера будет потреблять 80–100 % нагрузки ЦП, потому что состояние читателя остается доступным для чтения даже после получения записи, что приводит к слишком большому количеству poll().

Согласно следующей ссылке, кажется, что мы должны вызывать sd_journal_process (в модуле python systemd, то есть journal.Reader().process()) после каждого poll(), чтобы сбросить читаемое состояние файлового дескриптора.

http://www.freedesktop.org/software/systemd/man/sd_journal_get_events.html

В заключение ваш пример кода будет:

import select
from systemd import journal

j = journal.Reader()
j.log_level(journal.LOG_INFO)

# j.add_match(_SYSTEMD_UNIT="systemd-udevd.service")
j.seek_tail()
j.get_previous()
# j.get_next() # it seems this is not necessary.

p = select.poll()
p.register(j, j.get_events())

while p.poll():
    if j.process() != journal.APPEND:
        continue

    # Your example code has too many get_next() (i.e, "while j.get_next()" and "for event in j") which cause skipping entry.
    # Since each iteration of a journal.Reader() object is equal to "get_next()", just do simple iteration.
    for entry in j:
        if entry['MESSAGE'] != "":
            print(str(entry['__REALTIME_TIMESTAMP'] )+ ' ' + entry['MESSAGE'])

Предыдущий ответ работает, и подсказка о вызове get_next() после seek_tail() действительно важна.

Проще было бы (но очевидно, что предыдущая версия, использующая опрос, более гибкая в больших приложениях)

import systemd.journal

def main():
  j = systemd.journal.Reader()
  j.seek_tail()
  j.get_previous()
  while True:
    event = j.wait(-1)
    if event == systemd.journal.APPEND:
      for entry in j:
         print entry['MESSAGE']

if __name__ == '__main__':
  main()

Если кто-то хочет подробно посмотреть, что происходит, может быть полезна следующая версия, поддерживающая вывод отладки (вызов ее с некоторыми аргументами включит это)

import sys
import systemd.journal

def main(debug):
  j = systemd.journal.Reader()
  j.seek_tail()
  j.get_previous()
  while True:
    event = j.wait(-1)
    if event == systemd.journal.APPEND:
      for entry in j:
         print entry['MESSAGE']
    elif debug and event == systemd.journal.NOP:
      print "DEBUG: NOP"
    elif debug and event == systemd.journal.INVALIDATE:
      print "DEBUG: INVALIDATE"
    elif debug:
      raise ValueError, event   

if __name__ == '__main__':
  main(len(sys.argv) > 1)

Для меня это всегда приводит к одному INVALIDATE в начале. Не уверен, что это на самом деле означает. То, что что-то, что используется в качестве итератора, недействительно, звучит для меня так, что я мог бы каким-то образом воссоздать/повторно открыть/обновить его. Но, по крайней мере, во время моего базового тестирования приведенный выше код просто работает. Не уверен, что могут быть какие-то условия гонки. На самом деле мне было бы трудно объяснить, как этот код свободен от рас.