smuuf / celery-for-php
A modern Celery client for modern PHP.
Installs: 2 623
Dependents: 0
Suggesters: 0
Security: 0
Stars: 8
Watchers: 3
Forks: 2
Open Issues: 0
Requires
- php: >=8.0
- symfony/polyfill-php81: ^1.26
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.37
- nette/tester: ^2.4
- php-amqplib/php-amqplib: ^3.6
- phpstan/phpstan: ^1.8
- predis/predis: ^2
Suggests
- predis/predis: Adds support for Predis - a PHP library providing a Redis result backend
This package is auto-updated.
Last update: 2024-08-14 16:34:05 UTC
README
A modern PHP client library for Celery - Distributed Task Queue.
Requirements
- PHP 8.0+
Installation
Install celery-for-php via Composer.
composer require smuuf/celery-for-php
Redis (Predis)
If you want to use Redis as a broker and/or result backend, celery-for-php contains a Redis driver backed by Predis
.
The Predis Client
object then needs to be wrapped in our Smuuf\CeleryForPhp\Drivers\PredisRedisDriver
driver object, which provides the necessary interface for celery-for-php's actual communication with Redis.
Example usage
<?php use Predis\Client as PredisClient; use Smuuf\CeleryForPhp\Celery; use Smuuf\CeleryForPhp\TaskSignature; use Smuuf\CeleryForPhp\Brokers\RedisBroker; use Smuuf\CeleryForPhp\Drivers\PredisRedisDriver; use Smuuf\CeleryForPhp\Backends\RedisBackend; $predis = new PredisClient(['host' => '127.0.0.1']); $redisDriver = new PredisRedisDriver($predis); $celery = new Celery( new RedisBroker($redisDriver), new RedisBackend($redisDriver), // Optionally explicit config object. // config: new \Smuuf\CeleryForPhp\Config(...) ); $task = new TaskSignature( taskName: 'my_celery_app.add_numbers', queue: 'my_queue', // Optional, 'celery' by default. args: [1, 3, 5], // kwargs: ['arg_a' => 123, 'arg_b' => 'something'], // eta: 'now +10 minutes', // ... or more optional arguments. ); // Send the task into Celery. $asyncResult = $celery->sendTask($task); // Wait for the result (up to 10 seconds by default) and return it. // Alternatively a \Smuuf\CeleryForPhp\Exc\CeleryTimeoutException exception will // be thrown if the task won't finish in time. $result = $asyncResult->get(); // $result === 9
AMQP/RabbitMQ (PhpAmqpLib)
You can use AMQP/RabbitMQ as the broker instead, with Redis as the backend. celery-for-php contains a AMQP driver backed by PhpAmqpLib
.
The PhpAmqpLib AMQPConnection
or AMQPSSLConnection
object needs to be wrapped in our Smuuf\CeleryForPhp\Drivers\PhpAmqpLibAmqpDriver
driver object, which provides the necessary interface for celery-for-php's actual communication via AMQP.
Example usage
<?php use Predis\Client as PredisClient; use Smuuf\CeleryForPhp\Celery; use Smuuf\CeleryForPhp\TaskSignature; use Smuuf\CeleryForPhp\Brokers\AmqpBroker; use Smuuf\CeleryForPhp\Drivers\PredisRedisDriver; use Smuuf\CeleryForPhp\Drivers\PhpAmqpLibAmqpDriver; use PhpAmqpLib\Connection\AMQPSSLConnection; use Smuuf\CeleryForPhp\Backends\RedisBackend; //$amqpConn = new AMQPConnection(['127.0.0.1', '5672', '', '', '/']); $amqpConn = new AMQPSSLConnection(['127.0.0.1', '5672', '', '', '/', ['verify_peer'=>false]]); $amqpDriver = new PhpAmqpLibAmqpDriver($amqpConn); $predis = new PredisClient(['host' => '127.0.0.1']); $redisDriver = new PredisRedisDriver($predis); $celery = new Celery( new AmqpBroker($amqpDriver), new RedisBackend($redisDriver), // Optionally explicit config object. // config: new \Smuuf\CeleryForPhp\Config(...) ); $task = new TaskSignature( taskName: 'my_celery_app.add_numbers', queue: 'my_queue', // Optional, 'celery' by default. args: [1, 3, 5], // kwargs: ['arg_a' => 123, 'arg_b' => 'something'], // eta: 'now +10 minutes', // ... or more optional arguments. ); // Send the task into Celery. $asyncResult = $celery->sendTask($task); // Wait for the result (up to 10 seconds by default) and return it. // Alternatively a \Smuuf\CeleryForPhp\Exc\CeleryTimeoutException exception will // be thrown if the task won't finish in time. $result = $asyncResult->get(); // $result === 9