Мониторинг планировщика задач PHP: диагностика и отслеживание

Расширенные примеры проверки выполнения cron задач

1. Комбинированная блокировка с проверкой PID через /proc

class CronLock {
    private string $lockFile;
    private $handle;

    public function __construct(string $taskName) {
        $this->lockFile = sys_get_temp_dir() . '/' . md5($taskName) . '.lock';
    }

    public function acquire(): bool {
        $this->handle = fopen($this->lockFile, 'c+');
        if (!$this->handle) return false;
        
        if (!flock($this->handle, LOCK_EX | LOCK_NB)) {
            // Проверяем, жив ли процесс, который держит блокировку
            $data = json_decode(fread($this->handle, 1024), true);
            $pid = $data['pid'] ?? 0;
            if ($pid && !$this->isProcessAlive($pid)) {
                // Процесс мёртв, принудительно снимаем блокировку
                flock($this->handle, LOCK_UN);
                fclose($this->handle);
                $this->handle = fopen($this->lockFile, 'w+');
                return flock($this->handle, LOCK_EX | LOCK_NB);
            }
            return false;
        }
        $pid = getmypid();
        ftruncate($this->handle, 0);
        fwrite($this->handle, json_encode(['pid' => $pid, 'time' => time()]));
        fflush($this->handle);
        return true;
    }

    private function isProcessAlive(int $pid): bool {
        // Проверка существования процесса в /proc
        return file_exists("/proc/{$pid}");
    }

    public function release(): void {
        if ($this->handle) {
            // Обновляем время последнего выполнения
            file_put_contents($this->lockFile . '.last', time());
            flock($this->handle, LOCK_UN);
            fclose($this->handle);
        }
    }

    public function getLastRun(): ?int {
        $file = $this->lockFile . '.last';
        return file_exists($file) ? (int)file_get_contents($file) : null;
    }
}

// Использование в cron
$lock = new CronLock('send_emails');
if (!$lock->acquire()) {
    die("Задача уже выполняется или зависла.");
}
// ... работа ...
$lock->release();
echo "Выполнение завершено.";

Выполнение завершено.

2. Мониторинг с помощью очередей (RabbitMQ) и heartbeat

Каждая задача при запуске публикует сообщение в очередь cron:heartbeats. Отдельный потребитель отслеживает, приходят ли сообщения вовремя. Если heartbeat отсутствует дольше заданного интервала - генерируется alert.

// heartbeat_producer.php (запускается из cron каждую минуту)
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('cron:heartbeats', false, true, false, false);

$taskName = 'send_emails';
$timestamp = time();
$data = json_encode(['task' => $taskName, 'time' => $timestamp]);
$msg = new AMQPMessage($data, ['delivery_mode' => 2]);
$channel->basic_publish($msg, '', 'cron:heartbeats');

$channel->close();
$connection->close();
echo "Heartbeat отправлен для {$taskName}.";

// heart_checker.php (демон, запускается постоянно)
// Потребитель анализирует время последнего heartbeat
// Если задача не отзывается более 2 минут (120 сек) - предупреждение

// ... consumer logic ...
$lastHeartbeat = getLastHeartbeatFromDB('send_emails'); // предполагаем хранение
if ($lastHeartbeat && (time() - $lastHeartbeat > 120)) {
    echo "Пропуск heartbeat: задача send_emails не отзывается!";
    // Отправить уведомление
}

3. Проверка через INOTIFY или аналоги для файловых блокировок

Использование расширения inotify для немедленного получения уведомлений об изменении статуса блокировочного файла. Не подходит для проверки текущего состояния, но полезно для логов.

// inotify_cron.php
$inotify = inotify_init();
stream_set_blocking($inotify, true);
$watch = inotify_add_watch($inotify, '/tmp/my_cron.lock', IN_CLOSE_WRITE | IN_MODIFY);

echo "Ожидание изменений файла блокировки...\n";
$events = inotify_read($inotify);
foreach ($events as $event) {
    echo "Событие: " . $event['mask'] . "\n";
    if ($event['mask'] & IN_CLOSE_WRITE) {
        echo "Файл записан: возможно, задача завершилась.\n";
    }
}

4. Отправка уведомлений при пропуске выполнения

Сравнение последнего времени завершения с текущим. Если разница превышает допустимый интервал - отправляется письмо или сообщение в Telegram.

// notify_if_missed.php
$taskName = 'send_emails';
$lockFile = '/tmp/' . $taskName . '_last_run';
$interval = 120; // ожидаемый интервал в секундах

if (file_exists($lockFile)) {
    $lastRun = (int)file_get_contents($lockFile);
    $diff = time() - $lastRun;
    if ($diff > $interval + 30) { // +30 секунд запаса
        $msg = "Задача {$taskName} не выполнялась уже {$diff} секунд. Последний запуск: " . date('Y-m-d H:i:s', $lastRun);
        // mail() или Telegram API
        echo $msg . "\n";
    } else {
        echo "Всё в порядке. Последний запуск: " . date('Y-m-d H:i:s', $lastRun) . "\n";
    }
} else {
    echo "Нет информации о последнем запуске.\n";
}

Всё в порядке. Последний запуск: 2024-08-05 12:34:56

5. Использование systemd timers и journalctl для мониторинга

Если cron задачи перенесены в systemd таймеры, проверять статус можно через systemctl is-active и читать логи journalctl.

// systemd_check.php
$serviceName = 'my-cron-task.service';
exec("systemctl is-active {$serviceName}", $output, $code);
echo "Статус service: " . trim(implode('', $output)) . "\n";
// Вывод: active или inactive

// Получение времени последнего успешного запуска
$days = 1;
exec("journalctl -u {$serviceName} --since '{$days} day ago' --output=json --no-pager 2>/dev/null | tail -1", $jsonLines);
$lastLog = json_decode(implode('', $jsonLines), true);
if ($lastLog) {
    echo "Последний запуск (лог): " . ($lastLog['__REALTIME_TIMESTAMP'] ?? 'неизвестно') . "\n";
}