g4/tasker

Application asynchronous tasks manager and runner, cron-like PHP implementation with ability to run tasks with resolution in seconds

2.20.0 2024-03-06 13:45 UTC

Requires

• php: >=5.6
• ext-json: *
• ext-pdo: *
• g4/cron: *
• g4/log: >=1.23.0
• g4/mcache: ^1.4 || ^2.0

Requires (Dev)

• g4/code-coverage: 1.*
• phpunit/phpunit: 5.*

Suggests

• php-amqplib/php-amqplib: Use RabbitMQ for task processing

MIT

• Dejan Samardzija
• Drasko Gomboc
• Ivan Krickovic

• queue
• cron
• task
• async
• g4code
• g4fw

README

Tasker - Application asynchronous tasks manager, cron-like PHP implementation with ability to run task in seconds (unlike cron in minutes)

Requires

• MySQL tables

CREATE TABLE tasks (
    task_id       BIGINT(20)   UNSIGNED          AUTO_INCREMENT,
    recu_id       INT(10)      UNSIGNED NOT NULL DEFAULT 0,
    identifier    VARCHAR(255)          NOT NULL DEFAULT '',
    task          VARCHAR(255)          NOT NULL DEFAULT '',
    data          TEXT,
    request_uuid  CHAR(36)              NOT NULL DEFAULT '',
    status        TINYINT(3)   UNSIGNED NOT NULL DEFAULT 0,
    priority      TINYINT(3)   UNSIGNED NOT NULL DEFAULT 0,
    ts_created    INT(10)      UNSIGNED NOT NULL DEFAULT 0,
    ts_started    INT(10)      UNSIGNED NOT NULL DEFAULT 0,
    exec_time     FLOAT(10,6)  UNSIGNED NOT NULL DEFAULT 0.000000,
    started_count TINYINT(3)   UNSIGNED NOT NULL DEFAULT 0,
    PRIMARY KEY (task_id),
    KEY (recu_id),
    KEY (priority),
    KEY (status),
    KEY pending (status, ts_created),
    KEY started_count (started_count)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE tasks_recurrings (
    recu_id   INT(10)      UNSIGNED          AUTO_INCREMENT,
    frequency VARCHAR(255)          NOT NULL DEFAULT '',
    task      VARCHAR(255)          NOT NULL DEFAULT '',
    data      TEXT,
    status    TINYINT(3)   UNSIGNED NOT NULL DEFAULT 0,
    priority  TINYINT(3)   UNSIGNED NOT NULL DEFAULT 0,
    PRIMARY KEY (recu_id),
    UNIQUE (task),
    KEY (status)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE tasks_error_log (
    tel_id       INT(10)      UNSIGNED          AUTO_INCREMENT,
    task_id      BIGINT(20)   UNSIGNED NOT NULL DEFAULT 0,
    identifier   VARCHAR(255)          NOT NULL DEFAULT '',
    task         VARCHAR(255)          NOT NULL DEFAULT '',
    data         TEXT,
    ts_started   INT(10)      UNSIGNED NOT NULL DEFAULT 0,
    date_started DATETIME                      DEFAULT NULL,
    exec_time    FLOAT(10,6)  UNSIGNED NOT NULL DEFAULT 0.00,
    log          TEXT,
    PRIMARY KEY (tel_id),
    KEY (task_id),
    KEY (identifier),
    KEY (task),
    KEY (ts_started),
    KEY (date_started),
    KEY (exec_time)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE `tasker_pool` (
   `hostname` varchar(255) NOT NULL DEFAULT '',
   `status` tinyint(3) unsigned NOT NULL DEFAULT '0',
   `ts_available` int(10) NOT NULL DEFAULT '0',
    PRIMARY KEY (`hostname`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

• Sample data

INSERT INTO tasks_recurrings
    (task, frequency, data, status)
VALUES
    ('Dummy\\Task\\Foo', '0 3-59/15 2,6-12 */15 1 2-5', '{\"foo\":123}', '1'),
    ('Dummy\\Task\\Bar', '0 */5 * * * *',               '{\"bar\":234}', '1'); # runs every 5 minutes

License

(The MIT License) see LICENSE file for details...