php使用python celery

A modern PHP client library for Celery - Distributed Task Queue.

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-requirements>)Requirements

• PHP 8.0+

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-installation>)Installation

Install celery-for-php via Composer.

composer require smuuf/celery-for-php

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-redis-predis>)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.

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-example-usage>)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: 'myceleryapp.add_numbers',

queue: 'my_queue', // Optional, 'celery' by default.

args: [1, 3, 5],

// kwargs: ['arga' => 123, 'argb' => '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

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-amqprabbitmq-phpamqplib>)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.

[](<https://packagist.org/packages/smuuf/celery-for-php#user-content-example-usage-1>)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: 'myceleryapp.add_numbers',

queue: 'my_queue', // Optional, 'celery' by default.

args: [1, 3, 5],

// kwargs: ['arga' => 123, 'argb' => '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