Utilities - kombu.utils

kombu.utils

Internal utilities.

class kombu.utils.EqualityDict
kombu.utils.say(m, *fargs, **fkwargs)
kombu.utils.uuid()

Generate a unique id, having - hopefully - a very small chance of collision.

For now this is provided by uuid.uuid4().

kombu.utils.kwdict(kwargs)
kombu.utils.maybe_list(v)
kombu.utils.fxrange(start=1.0, stop=None, step=1.0, repeatlast=False)
kombu.utils.fxrangemax(start=1.0, stop=None, step=1.0, max=100.0)
kombu.utils.retry_over_time(fun, catch, args=, []kwargs={}, errback=None, max_retries=None, interval_start=2, interval_step=2, interval_max=30, callback=None)

Retry the function over and over until max retries is exceeded.

For each retry we sleep a for a while before we try again, this interval is increased for every retry until the max seconds is reached.

Parameters:
  • fun – The function to try
  • catch – Exceptions to catch, can be either tuple or a single exception class.
  • args – Positional arguments passed on to the function.
  • kwargs – Keyword arguments passed on to the function.
  • errback – Callback for when an exception in catch is raised. The callback must take two arguments: exc and interval, where exc is the exception instance, and interval is the time in seconds to sleep next..
  • max_retries – Maximum number of retries before we give up. If this is not set, we will retry forever.
  • interval_start – How long (in seconds) we start sleeping between retries.
  • interval_step – By how much the interval is increased for each retry.
  • interval_max – Maximum number of seconds to sleep between retries.
kombu.utils.emergency_dump_state(state, open_file=<built-in function open>, dump=None)
class kombu.utils.cached_property(fget=None, fset=None, fdel=None, doc=None)

Property descriptor that caches the return value of the get function.

Examples

@cached_property
def connection(self):
    return Connection()

@connection.setter  # Prepares stored value
def connection(self, value):
    if value is None:
        raise TypeError('Connection must be a connection')
    return value

@connection.deleter
def connection(self, value):
    # Additional action to do at del(self.attr)
    if value is not None:
        print('Connection {0!r} deleted'.format(value)
deleter(fdel)
setter(fset)
kombu.utils.reprkwargs(kwargs, sep=', ', fmt='{0}={1}')
kombu.utils.reprcall(name, args=(), kwargs={}, sep=', ')
kombu.utils.nested(*args, **kwds)

Combine multiple context managers into a single nested context manager.

kombu.utils.fileno(f)
kombu.utils.maybe_fileno(f)

Get object fileno, or None if not defined.

Table Of Contents

Previous topic

kombu.serialization

Next topic

Evented I/O - kombu.utils.eventio

This Page