README

此软件包提供类似于 Laravel Horizon 的 MongoDB 数据库队列监控功能。

此软件包是 romanzipp 的 laravel-queue-monitor 的分支。

此软件包需要 Jenssegers 的 laravel-mongodb。

特性

监控任何队列的任务，如 Laravel Horizon
处理失败的作业，存储异常
监控作业进度
获取作业剩余时间的估计值
为作业监控存储额外数据

安装

composer require sbourdette/laravel-mongo-queue-monitor

配置

将配置和迁移文件复制到您的项目中

php artisan vendor:publish --provider="sbourdette\MongoQueueMonitor\Providers\MongoQueueMonitorProvider"

迁移队列监控表。表名可以在配置文件中配置，或者通过发布的迁移来配置。

php artisan migrate

使用

要监控作业，只需添加 sbourdette\MongoQueueMonitor\Traits\IsMonitored 特性。

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored; // <---

class ExampleJob implements ShouldQueue
{
    use Dispatchable;
    use InteractsWithQueue;
    use Queueable;
    use SerializesModels;
    use IsMonitored; // <---
}

重要！ 您需要在作业类中实现 Illuminate\Contracts\Queue\ShouldQueue 接口。否则，Laravel 不会派发包含作业监控状态信息的任何事件。

用户界面

您可以通过在路由文件中调用 Route::queueMonitor() 来启用可选的 UI 路由，类似于官方的 ui 架构。

Route::prefix('jobs')->group(function () {
    Route::queueMonitor();
});

路由

有关更多信息，请参阅完整的配置文件。

扩展使用

进度

您可以设置 进度值（0-100），以获取作业进度的估计值。

use Illuminate\Contracts\Queue\ShouldQueue;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored;

class ExampleJob implements ShouldQueue
{
    use IsMonitored;

    public function handle()
    {
        $this->queueProgress(0);

        // Do something...

        $this->queueProgress(50);

        // Do something...

        $this->queueProgress(100);
    }
}

块进度

作业的常见场景是迭代大集合。

此示例作业遍历大量用户，并在每个块迭代中更新其进度值。

use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Database\Eloquent\Collection;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored;

class ChunkJob implements ShouldQueue
{
    use IsMonitored;

    public function handle()
    {
        $usersCount = User::count();

        $perChunk = 50;

        User::query()
            ->chunk($perChunk, function (Collection $users) use ($perChunk, $usersCount) {

                $this->queueProgressChunk($usersCount‚ $perChunk);

                foreach ($users as $user) {
                    // ...
                }
            });
    }
}

进度冷却

为了避免快速重复的更新查询使数据库过载，您可以设置覆盖 progressCooldown 方法，并指定一个在将进度更新写入数据库之前等待的秒数。请注意，冷却总是忽略 0、25、50、75 和 100 的值。

use Illuminate\Contracts\Queue\ShouldQueue;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored;

class LazyJob implements ShouldQueue
{
    use IsMonitored;

    public function progressCooldown(): int
    {
        return 10; // Wait 10 seconds between each progress update
    }
}

自定义数据

此软件包还允许在监控模型上以数组语法设置自定义数据。

use Illuminate\Contracts\Queue\ShouldQueue;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored;

class CustomDataJob implements ShouldQueue
{
    use IsMonitored;

    public function handle()
    {
        $this->queueData(['foo' => 'Bar']);

        // WARNING! This is overriding the monitoring data
        $this->queueData(['bar' => 'Foo']);

        // To preserve previous data and merge the given payload, set the $merge parameter true
        $this->queueData(['bar' => 'Foo'], true);
    }
}

为了在 UI 上显示自定义数据，您需要在 config/queue-monitor.php 下添加此行。

'ui' => [
    ...

    'show_custom_data' => true,

    ...
]

仅保留失败的作业

您可以通过覆盖 keepMonitorOnSuccess() 方法来仅存储已执行作业的失败监控条目。如果只想保留经常执行但值得监控的作业的失败监控，则可以使用此方法。或者，您也可以使用 Laravel 内置的 failed_jobs 表。

use Illuminate\Contracts\Queue\ShouldQueue;
use sbourdette\MongoQueueMonitor\Traits\IsMonitored;

class FrequentSucceedingJob implements ShouldQueue
{
    use IsMonitored;

    public static function keepMonitorOnSuccess(): bool
    {
        return false;
    }
}

检索处理过的作业

use sbourdette\MongoQueueMonitor\Models\Monitor;

$job = Monitor::query()->first();

// Check the current state of a job
$job->isFinished();
$job->hasFailed();
$job->hasSucceeded();

// Exact start & finish dates with milliseconds
$job->getStartedAtExact();
$job->getFinishedAtExact();

// If the job is still running, get the estimated seconds remaining
// Notice: This requires a progress to be set
$job->getRemainingSeconds();
$job->getRemainingInterval(); // Carbon\CarbonInterval

// Retrieve any data that has been set while execution
$job->getData();

// Get the base name of the executed job
$job->getBasename();

模型作用域

use sbourdette\MongoQueueMonitor\Models\Monitor;

// Filter by Status
Monitor::failed();
Monitor::succeeded();

// Filter by Date
Monitor::lastHour();
Monitor::today();

// Chain Scopes
Monitor::today()->failed();