Download 2.3-archived PDF

Celery Documentation, Release 2.3.5
11.5.21 celery.backends.cache
class celery.backends.cache.CacheBackend(expires=None,
**kwargs)
backend=None,
options={},
client
delete(key)
get(key)
mget(keys)
set(key, value)
class celery.backends.cache.DummyClient(*args, **kwargs)
delete(key, *args, **kwargs)
get(key, *args, **kwargs)
get_multi(keys)
set(key, value, *args, **kwargs)
celery.backends.cache.get_best_memcache(*args, **kwargs)
celery.backends.cache.import_best_memcache()
11.5.22 celery.backends.amqp
class celery.backends.amqp.AMQPBackend(connection=None,
exchange=None,
exchange_type=None,
persistent=None,
serializer=None, auto_delete=True, expires=None, connection_max=None, **kwargs)
Publishes results by sending messages.
exception BacklogLimitExceeded
Too much state history to fast-forward.
class AMQPBackend.Consumer(channel, queues, no_ack=None, auto_declare=None,
backs=None, on_decode_error=None)
Message consumer.
Parameters
• channel – see channel.
• queues – see queues.
• no_ack – see no_ack.
• auto_declare – see auto_declare
• callbacks – see callbacks.
• on_decode_error – see on_decode_error.
add_queue(queue)
call-
auto_declare = True
callbacks = None
cancel()
End all active queue consumers.
This does not affect already delivered messages, but it does mean the server will not send any more
messages for this consumer.
11.5. Internal Module Reference
295