thamtech/yii2-scheduler

A configuration-driven scheduled task runner for Yii2 applications

Yii2 Scheduler

A configuration-driven scheduled task manager for Yii2., _(*1)

This is adapted from webtoolsnz/yii2-scheduler to provide a more configuration-driven approach., _(*2)

The main differences:, _(*3)

• webtoolsnz/yii2-scheduler
  • automatically picks up Task classes in the @app/tasks folder
  • once tasks have been established in the database table, the active value from the database controls whether the task is enabled, not the active property in the Task class
• thamtech/yii2-scheduler
  • tasks are defined explicitly as part of the scheduler module config
  • the active property of the Task instance controls whether the task is enabled (so that it may be controlled programmatically instead of only via the scheduler's databse table)

, _(*4)

Installation

The preferred way to install this extension is through composer., _(*5)

Install using the following command., _(*6)

$ composer require thamtech/yii2-scheduler

Now that the package has been installed you need to configure the module in your application., _(*7)

The config/console.php file (or the equivalent console config file if you are using a different Yii project template) should be updated to reflect the changes below:, _(*8)

<?php
[
    'bootstrap' => ['log', 'scheduler'],
    'modules' => [
        'scheduler' => [
            'class' => 'thamtech\scheduler\Module',

            // optional: define a mutex component to acquire a lock
            // while executing tasks so only one execution of schedule tasks
            // can be running at a time.
            'mutex' => [
                'class' => 'yii\mutex\MysqlMutex',
            ], 

            // OR optionally reference an existing application mutex component,
            // for example, one named "mutex":
            // 'mutex' => 'mutex',
        ],
    ],
    'components' => [
        'log' => [
            'traceLevel' => YII_DEBUG ? 3 : 0,
            'targets' => [
                [
                    'class' => 'yii\log\EmailTarget',
                    'mailer' =>'mailer',
                    'levels' => ['error', 'warning'],
                    'message' => [
                        'to' => ['alets@example.com'],
                        'from' => ['app@example.com'],
                        'subject' => 'Scheduler Error - ####SERVERNAME####'
                    ],
                    'except' => [
                    ],
                ],
            ],
        ],
    ],
];

also add this to the top of your config/console.php file:, _(*9)

\yii\base\Event::on(
    \thamtech\scheduler\console\SchedulerController::className(),
    \thamtech\scheduler\events\SchedulerEvent::EVENT_AFTER_RUN,
    function ($event) {
        if (!$event->success) {
            foreach($event->exceptions as $exception) {
                throw $exception;
            }
        }
    }
);

Run the database migrations, which will create the necessary tables:, _(*10)

php yii migrate up --migrationPath=vendor/thamtech/yii2-scheduler/src/migrations

To implement the GUI for reviewing scheduled tasks and logs, add a web controller:, _(*11)

<?php
namespace app\modules\admin\controllers;

use yii\web\Controller;

/**
 * SchedulerController has a set of actions for viewing scheduled tasks and
 * their logs.
 */
class SchedulerController extends Controller
{
    public function actions()
    {
        return [
            'index' => [
                'class' => 'thamtech\scheduler\actions\IndexAction',
                'view' => '@scheduler/views/index',
            ],
            'view' => [
                'class' => 'thamtech\scheduler\actions\ViewAction',
                'view' => '@scheduler/views/view',
            ],
            'view-log' => [
                'class' => 'thamtech\scheduler\actions\ViewLogAction',
                'view' => '@scheduler/views/view-log',
            ],
        ];
    }
}

Example Task

You can now create your first task using scheduler. In this example, we will create ConcatStringsTask.php inside the tasks directory of your app:, _(*12)

<?php
namespace app\tasks;

/**
 * Task to print a concatenation of the specified strings.
 */
class ConcatStringsTask extends \thamtech\scheduler\Task
{
    /**
     * @var string task description
     */
    public $description = 'Prints a concatenation of the specified strings';

    /**
     * @var string[] the strings to be concatenated
     */
    public $strings = [];

    /**
     * @inheritdoc
     */
    public function run()
    {
        echo join('', $this->strings);
    }
}

In your scheduler module config within your console app, define the task:, _(*13)

<?php
'modules' => [
    'scheduler' => [
        'class' => 'thamtech\scheduler\Module',
        'tasks' => [
            'hello-world' => [
                'class' => 'app\tasks\ConcatStringsTask',
                'displayName' => 'Hello World Task',
                'schedule' => '0 * * * *',
                'strings' => ['Hello', ' ', 'World'],
            ],
        ],
    ],
],

The above code defines a simple task that runs at the start of every hour, and prints "Hello World". An alternative approach would be to hard-code some or all of the properties in your task class (like schedule). However, this example is more in line with the project's goal of being a more configuration-driven approach to defining tasks., _(*14)

The $schedule property of this class defines how often the task will run, these are simply Cron Expression, _(*15)

You can define multiple task instances in the scheduler module config, and it is ok to reuse the same Task class for multiple instances. Here is an example with an additional "Foo Bar" task that runs every hour on the half-hour:, _(*16)

<?php
'modules' => [
    'scheduler' => [
        'class' => 'thamtech\scheduler\Module',
        'tasks' => [
            'hello-world' => [
                'class' => 'app\tasks\ConcatStringsTask',
                'displayName' => 'Hello World Task',
                'schedule' => '0 * * * *',
                'strings' => ['Hello', ' ', 'World'],
            ],
            'foo-bar' => [
                'class' => 'app\tasks\ConcatStringsTask',
                'displayName' => 'Foo Bar Task',
                'schedule' => '30 * * * *',
                'strings' => ['Foo', ' ', 'Bar'],
            ],
        ],
    ],
],

Running the tasks

Scheduler provides an intuitive CLI for executing tasks, below are some examples, _(*17)

 # list all tasks and their status
 $ php yii scheduler

 # run the task if due
 $ php yii scheduler/run --taskName=hello-world

 # force the task to run regardless of schedule
 $ php yii scheduler/run --taskName=hello-world --force

 # run all tasks
 $ php yii scheduler/run-all

 # force all tasks to run
 $ php yii scheduler/run-all --force

In order to have your tasks run automatically simply setup a crontab like so, _(*18)

*/5 * * * * admin php /path/to/my/app/yii scheduler/run-all > /dev/null &

Events & Errors

Events are thrown before and running individual tasks as well as at a global level for multiple tasks, _(*19)

Task Level, _(*20)

<?php
Event::on(AlphabetTask::className(), AlphabetTask::EVENT_BEFORE_RUN, function ($event) {
    Yii::trace($event->task->className . ' is about to run');
});
Event::on(AlphabetTask::className(), AlphabetTask::EVENT_AFTER_RUN, function ($event) {
    Yii::trace($event->task->className . ' just ran '.($event->success ? 'successfully' : 'and failed'));
});

or at the global level, to throw errors in /yii, _(*21)

<?php
$application->on(\thamtech\scheduler\events\SchedulerEvent::EVENT_AFTER_RUN, function ($event) {
    if (!$event->success) {
        foreach($event->exceptions as $exception) {
            throw $exception;
        }
    }
});

You could throw the exceptions at the task level, however this will prevent further tasks from running., _(*22)

License

The MIT License (MIT). Please see LICENSE.md for more information., _(*23)