appwrite/app/workers.php

<?php

use Appwrite\Extend\PDO;
use Utopia\App;
use Utopia\CLI\Console;
use Utopia\Logger\Log;
use Appwrite\Resque\Worker;

/** @var Utopia\Registry\Registry $register */

require_once __DIR__.'/init.php';

$register->set('db', function () {
    $dbHost = App::getEnv('_APP_DB_HOST', '');
    $dbUser = App::getEnv('_APP_DB_USER', '');
    $dbPass = App::getEnv('_APP_DB_PASS', '');
    $dbScheme = App::getEnv('_APP_DB_SCHEMA', '');

    $pdo = new PDO("mysql:host={$dbHost};dbname={$dbScheme};charset=utf8mb4", $dbUser, $dbPass, array(
        PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8mb4',
        PDO::ATTR_TIMEOUT => 3, // Seconds
        PDO::ATTR_PERSISTENT => true,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
    ));

    return $pdo;
});

$register->set('cache', function () { // Register cache connection
    $redis = new Redis();
    $redis->pconnect(App::getEnv('_APP_REDIS_HOST', ''), App::getEnv('_APP_REDIS_PORT', ''));
    $redis->setOption(Redis::OPT_READ_TIMEOUT, -1);

    return $redis;
});

Worker::error(function ($error, $action, $workerType, $optionalExtras) use ($register) {
    /** @var Throwable|Exception $error */
    /** @var string $action */
    /** @var string $workerType */

    $logger = $register->get('logger');

    if(!$logger) {
        return;
    }

    $version = App::getEnv('_APP_VERSION', 'UNKNOWN');

    $log = new Log();

    $log->setNamespace("worker-" . $workerType);
    $log->setServer(\gethostname());
    $log->setVersion($version);
    $log->setType(Log::TYPE_ERROR);
    $log->setMessage($error->getMessage());

    $log->addTag('workerType', $workerType);
    $log->addTag('code', $error->getCode());
    $log->addTag('verboseType', \get_class($error));

    $log->addExtra('file', $error->getFile());
    $log->addExtra('line', $error->getLine());
    $log->addExtra('trace', $error->getTraceAsString());

    if($optionalExtras) {
        $log->addExtra('args', $optionalExtras);
    }

    $action = 'worker.' . $workerType . '.' . $action;
    $log->setAction($action);

    $isProduction = App::getEnv('_APP_ENV', 'development') === 'production';
    $log->setEnvironment($isProduction ? Log::ENVIRONMENT_PRODUCTION : Log::ENVIRONMENT_STAGING);

    $responseCode = $logger->addLog($log);
    Console::info('Setup log pushed with status code: ' . $responseCode);
});