Как обрабатывать обновления из непрерывного процесса в Perl

Question

Я пытаюсь следить за файлами журнала в Perl на Fedora, но, к сожалению, Fedora использует journalctl для чтения двоичных файлов журнала, которые я не могу разобрать напрямую. Это, по моему мнению, означает, что я могу только читать файлы журнала Fedora, вызывая journalctl.

Я попытался с помощью IO::Pipe, чтобы сделать это, но проблема в том, что $p->reader(..) ждет, пока journalctl --follow делается записи выходных данных (который не будет никогда так --follow, как tail -F), а затем позволяет мне печатать все из которых не то, что я хочу , Я хотел бы иметь возможность установить функцию обратного вызова, которая будет вызываться каждый раз, когда новая строка будет напечатана в канале процесса, чтобы я мог анализировать/обрабатывать каждое новое событие журнала.

use IO::Pipe; 

my $p = IO::Pipe->new(); 
$p->reader("journalctl --follow"); #Waits for process to exit 

while (<$p>) { 
    print; 
} 

Answer 1

Я предполагаю, что journalctl работает как tail -f. Если это правильно, простой open должен делать эту работу:

use Fcntl; # Import SEEK_CUR 

my $pid = open my $fh, '|-', 'journalctl --follow' 
    or die "Error $! starting journalctl"; 
while (kill 0, $pid) { 
    while (<$fh>) { 
     print $_; # Print log line 
    } 
    sleep 1; # Wait some time for new lines to appear 
    seek($fh,0,SEEK_CUR); # Reset EOF 
} 

open открывает дескриптор для чтения вывода вызываемой команды: http://perldoc.perl.org/functions/open.html

seek используется для сброса EOF маркеров: http://perldoc.perl.org/functions/seek.html Без сброса , все последующие вызовы <$fh> просто вернут EOF, даже если вызываемый скрипт выпустил дополнительный вывод за это время.

kill 0,$pid будет правдой до тех пор, пока дочерний процесс начинается с open.

Вы можете заменить sleep 1 на usleep из Time::HiRes или select undef,undef,undef,$fractional_seconds; ждать меньше, чем второй в зависимости от частоты входящих линий.

AnyEvent также должен быть в состоянии выполнить работу через AnyEvent::Handle.

Update:

Добавление use POSIX ":sys_wait_h"; в начале и waitpid $pid, WNOHANG) к внешней петле будет также обнаружить (и пожнешь) зомби journalctl процесс:

while (kill(0, $pid) and waitpid($pid, WNOHANG) != $pid) { 

Демон может также хотите, чтобы проверить, $pid все еще является дочерним элементом текущего процесса ($$), и если он все еще является исходным процессом journalctl.

Answer 2

У меня нет доступа к journalctl, но если вы будете избегать IO::Pipe и открыть трубопроводный выход непосредственно, то данные не будут буферным

use strict; 
use warnings 'all'; 

open my $follow_fh, '-|', 'journalctl --follow' or die $!; 

print while <$follow_fh>;