celery-php / celery-php
PHP client for Celery task queue
Requires
- predis/predis: 0.8.5
- videlalvaro/php-amqplib: >=2.4.0
This package is not auto-updated.
Last update: 2016-01-22 02:20:24 UTC
README
PHP client capable of executing Celery tasks and reading asynchronous results.
Uses AMQP extension from PECL, the PHP AMQP implementation or Redis and the following settings in Celery:
CELERY_RESULT_SERIALIZER = "json"
CELERY_TASK_RESULT_EXPIRES = None
PECL-AMQP is supported in version 1.0.0 and higher because its API has been completely remade when it entered 1.0. There is a separate branch for 0.3.
Last PHP-amqplib version tested is 2.2.6.
Last Celery version tested is 3.1.11
$c = new Celery('localhost', 'myuser', 'mypass', 'myvhost');
$result = $c->PostTask('tasks.add', array(2,2));
// The results are serializable so you can do the following:
$_SESSION['celery_result'] = $result;
// and use this variable in an AJAX call or whatever
READING ASYNC RESULTS
while(!$result->isReady())
{
sleep(1);
echo '...';
}
if($result->isSuccess())
{
echo $result->getResult();
}
else
{
echo "ERROR";
echo $result->getTraceback();
}
GET ASYNC RESULT MESSAGE
$c = new Celery('localhost', 'myuser', 'mypass', 'myvhost');
$message = $c->getAsyncResultMessage('tasks.add', 'taskId);
PYTHON-LIKE API
An API compatible to AsyncResult in Python is available too.
$c = new Celery('localhost', 'myuser', 'mypass', 'myvhost');
$result = $c->PostTask('tasks.add', array(2,2));
$result->get();
if($result->successful())
{
echo $result->result;
}
ABOUT
Based on this blog post and reading Celery sources. Thanks to Skrat, author of Celerb for a tip about response encoding. Created for the needs of my consulting work at Massive Scale. License is 2-clause BSD.
PHP-amqplib support is experimental right now. It passes most unit tests and should be safe to work with, though.
SUPPORT
If you need help integrating Celery in your PHP app, you may be interested in hiring me as a consultant.
CONNECTING VIA SSL
Connecting to a RabbitMQ server that requires SSL is currently only possible via PHP-amqplib to do so you'll need to create a celery object with ssl options:
$ssl_options = array(
'cafile' => 'PATH_TO_CA_CERT_FILE',
'verify_peer' => true,
'passphrase' => 'LOCAL_CERT_PASSPHRASE',
'local_cert' => 'PATH_TO_COMBINED_CLIENT_CERT_KEY',
'CN_match' => 'CERT_COMMON_NAME'
);
$c = new Celery($host, $user, $password, $vhost, 'celery', 'celery', 5671, false, false, $ssl_options);
CONNECTING TO REDIS
Refer to files in testscenario/ for examples of celeryconfig.py.
$c = new Celery(
'localhost', /* Server */
'', /* Login */
'test', /* Password */
'wutka', /* vhost */
'celery', /* exchange */
'celery', /* binding */
6379, /* port */
'redis' /* connector */
);