`celery.utils.collections`¶

classmethod fromkeys(iterable: type, *args: Iterable) → ChainMap[исходный код]¶: Create a ChainMap with a single dict created from the iterable.

get(k[, d]) → D[k] if k in D, else d. d defaults to None.[исходный код]¶

items() → a set-like object providing a view on D's items¶

iteritems() → Iterable¶

iterkeys() → Iterable¶

itervalues() → Iterable¶

key_t = None¶

keys() → a set-like object providing a view on D's keys¶

maps = None¶

pop(k[, d]) → v, remove specified key and return the corresponding value.[исходный код]¶: If key is not found, d is returned if given, otherwise KeyError is raised.

setdefault(k[, d]) → D.get(k,d), also set D[k]=d if k not in D[исходный код]¶

update([E, ]**F) → None. Update D from mapping/iterable E and F.[исходный код]¶: If E present and has a .keys() method, does: for k in E: D[k] = E[k] If E present and lacks .keys() method, does: for (k, v) in E: D[k] = v In either case, this is followed by: for k, v in F.items(): D[k] = v

values() → an object providing a view on D's values¶

class celery.utils.collections.ConfigurationView(changes: Mapping, defaults: Optional[Mapping] = None, keys: Optional[List[str]] = None, prefix: Optional[str] = None)[исходный код]¶

A view over an applications configuration dictionaries.

Custom (but older) version of collections.ChainMap.

If the key does not exist in changes, the defaults dictionaries are consulted.

Параметры:

changes (Mapping) – Map of configuration changes.
defaults (List[Mapping]) – List of dictionaries containing the default configuration.

clear() → None[исходный код]¶: Remove all changes, but keep defaults.

first(*keys: str) → Any[исходный код]¶

get(k[, d]) → D[k] if k in D, else d. d defaults to None.[исходный код]¶

swap_with(other: ConfigurationView) → None[исходный код]¶

class celery.utils.collections.DictAttribute(obj: Any)[исходный код]¶

Dict interface to attributes.

obj[k] -> obj.k obj[k] = val -> obj.k = val

get(key: Any, default: Optional[Any] = None) → Any[исходный код]¶

items() → Iterable¶

iteritems() → Iterable¶

iterkeys() → Iterable¶

itervalues() → Iterable¶

keys() → Iterable¶

obj = None¶

setdefault(key: Any, default: Optional[Any] = None) → None[исходный код]¶

values() → Iterable¶

class celery.utils.collections.Evictable[исходный код]¶

Mixin for classes supporting the evict method.

exception Empty¶: Exception raised by Queue.get(block=0)/get_nowait().

evict() → None[исходный код]¶: Force evict until maxsize is enforced.

class celery.utils.collections.LimitedSet(maxlen: int = 0, expires: float = 0, data: Optional[Mapping] = None, minlen: int = 0)[исходный код]¶

Kind-of Set (or priority queue) with limitations.

Good for when you need to test for membership (a in set), but the set should not grow unbounded.

maxlen is enforced at all times, so if the limit is reached we’ll also remove non-expired items.

You can also configure minlen: this is the minimal residual size of the set.

All arguments are optional, and no limits are enabled by default.

Параметры:

maxlen (int) – Optional max number of items. Adding more items than maxlen will result in immediate removal of items sorted by oldest insertion time.
expires (float) – TTL for all items. Expired items are purged as keys are inserted.
minlen (int) –
Minimal residual size of this set. .. versionadded:: 4.0

Value must be less than maxlen if both are configured.

Older expired items will be deleted, only after the set exceeds minlen number of items.
data (Sequence) – Initial data to initialize set with. Can be an iterable of (key, value) pairs, a dict ({key: insertion_time}), or another instance of LimitedSet.

Пример

>>> s = LimitedSet(maxlen=50000, expires=3600, minlen=4000)
>>> for i in range(60000):
...     s.add(i)
...     s.add(str(i))
...
>>> 57000 in s  # last 50k inserted values are kept
True
>>> '10' in s  # '10' did expire and was purged from set.
False
>>> len(s)  # maxlen is reached
50000
>>> s.purge(now=time.monotonic() + 7200)  # clock + 2 hours
>>> len(s)  # now only minlen items are cached
4000
>>>> 57000 in s  # even this item is gone now
False

add(item: Any, now: Optional[float] = None) → None[исходный код]¶: Add a new item, or reset the expiry time of an existing item.

as_dict() → Dict[исходный код]¶

Whole set as serializable dictionary.

Пример

>>> s = LimitedSet(maxlen=200)
>>> r = LimitedSet(maxlen=200)
>>> for i in range(500):
...     s.add(i)
...
>>> r.update(s.as_dict())
>>> r == s
True

clear() → None[исходный код]¶: Clear all data, start from scratch again.

discard(item: Any) → None[исходный код]¶

max_heap_percent_overload = 15¶

pop(default: Optional[Any] = None) → Any[исходный код]¶: Remove and return the oldest item, or None when empty.

pop_value(item: Any) → None¶

purge(now: Optional[float] = None) → None[исходный код]¶

Check oldest items and remove them if needed.

Параметры:: now (float) – Time of purging – by default right now. This can be useful for unit testing.

update(other: Iterable) → None[исходный код]¶: Update this set from other LimitedSet, dict or iterable.

class celery.utils.collections.Messagebuffer(maxsize: int, iterable: ~typing.Optional[~typing.Iterable] = None, deque: ~typing.Any = <class 'collections.deque'>)[исходный код]¶