Содержание страницы
9.7. itertools – Функции, создающие итераторы для эффективного перебора¶itertools – Functions creating iterators for efficient looping
Новое в версии 2.3.
Этот модуль реализует ряд строительных блоков итераторов, вдохновлённых конструкциями из APL, Haskell и SML. Каждый из них переработан в форму, подходящую для Python.
Модуль стандартизирует основной набор быстрых и эффективных по памяти инструментов, которые полезны сами по себе или в комбинации. Вместе они образуют «алгебру итераторов», позволяющую создавать специализированные инструменты кратко и эффективно на чистом Python.
Например, SML предоставляет инструмент табуляции: tabulate(f), который порождает
последовательность f(0), f(1), .... Того же эффекта можно достичь в Python
скомбинировав imap() и count() для получения imap(f, count()).
Эти инструменты и их встроенные аналоги также хорошо работают с высокоскоростными
функциями из модуля operator. Например, оператор умножения
можно применить к двум векторам, чтобы получить эффективное скалярное произведение:
sum(imap(operator.mul, vector1, vector2)).
Бесконечные итераторы:
Итератор |
Аргументы |
Результаты |
Пример |
|---|---|---|---|
start, [step] |
start, start+step, start+2*step, … |
|
|
p |
p0, p1, … plast, p0, p1, … |
|
|
elem [,n] |
elem, elem, elem, … бесконечно или до n раз |
|
Итераторы, завершающиеся по кратчайшей входной последовательности:
Итератор |
Аргументы |
Результаты |
Пример |
|---|---|---|---|
p, q, … |
p0, p1, … plast, q0, q1, … |
|
|
data, selectors |
(d[0] if s[0]), (d[1] if s[1]), … |
|
|
pred, seq |
seq[n], seq[n+1], начиная с момента, когда pred не выполняется |
|
|
iterable[, keyfunc] |
под-итераторы, сгруппированные по значению keyfunc(v) |
||
pred, seq |
элементы seq, для которых pred(elem) истинно |
|
|
pred, seq |
элементы seq, для которых pred(elem) ложно |
|
|
seq, [start,] stop [, step] |
элементы из seq[start:stop:step] |
|
|
func, p, q, … |
func(p0, q0), func(p1, q1), … |
|
|
func, seq |
func(*seq[0]), func(*seq[1]), … |
|
|
it, n |
it1, it2, … itn разделяет один итератор на n |
||
pred, seq |
seq[0], seq[1], пока pred не вернёт ложь |
|
|
p, q, … |
(p[0], q[0]), (p[1], q[1]), … |
|
|
p, q, … |
(p[0], q[0]), (p[1], q[1]), … |
|
Комбинаторные генераторы:
Итератор |
Аргументы |
Результаты |
|---|---|---|
p, q, … [repeat=1] |
декартово произведение, эквивалентно вложенному циклу for |
|
p[, r] |
кортежи длиной r, все возможные перестановки, без повторяющихся элементов |
|
p, r |
кортежи длиной r, в отсортированном порядке, без повторяющихся элементов |
|
p, r |
кортежи длиной r, в отсортированном порядке, с повторяющимися элементами |
|
|
|
|
|
|
|
|
|
|
|
|
9.7.1. Функции itertools¶Itertool functions
Следующие функции модуля создают и возвращают итераторы. Некоторые из них порождают потоки бесконечной длины, поэтому обращаться к ним следует только с помощью функций или циклов, которые обрывают поток.
-
itertools.chain(*iterables)¶ Создаёт итератор, который возвращает элементы из первого итерируемого объекта, пока он не будет исчерпан, затем переходит к следующему, пока все итерируемые объекты не будут исчерпаны. Используется для объединения последовательностей в одну. Приблизительный эквивалент:
def chain(*iterables): # chain('ABC', 'DEF') --> A B C D E F for it in iterables: for element in it: yield element
-
classmethod
chain.from_iterable(iterable)¶ Альтернативный конструктор для
chain(). Получает цепочку входных данных из одного аргумента iterable, который вычисляется лениво. Примерная реализация:def from_iterable(iterables): # chain.from_iterable(['ABC', 'DEF']) --> A B C D E F for it in iterables: for element in it: yield element
Новое в версии 2.6.
-
itertools.combinations(iterable, r)¶ Возвращает подпоследовательности элементов длины r из входного iterable.
Комбинации выдаются в лексикографическом порядке. Таким образом, если входной итерируемый объект отсортирован, кортежи комбинаций будут созданы в отсортированном порядке.
Элементы считаются уникальными на основе их позиции, а не значения. Поэтому если входные элементы уникальны, то в каждой комбинации не будет повторяющихся значений.
Примерно эквивалентно:
def combinations(iterable, r): # combinations('ABCD', 2) --> AB AC AD BC BD CD # combinations(range(4), 3) --> 012 013 023 123 pool = tuple(iterable) n = len(pool) if r > n: return indices = range(r) yield tuple(pool[i] for i in indices) while True: for i in reversed(range(r)): if indices[i] != i + n - r: break else: return indices[i] += 1 for j in range(i+1, r): indices[j] = indices[j-1] + 1 yield tuple(pool[i] for i in indices)
Код для
combinations()можно также выразить как подпоследовательностьpermutations()после фильтрации записей, где элементы не находятся в отсортированном порядке (согласно их позиции во входном пуле):def combinations(iterable, r): pool = tuple(iterable) n = len(pool) for indices in permutations(range(n), r): if sorted(indices) == list(indices): yield tuple(pool[i] for i in indices)
Количество возвращаемых элементов равно
n! / r! / (n-r)!, когда0 <= r <= n, или нулю, когдаr > n.Новое в версии 2.6.
-
itertools.combinations_with_replacement(iterable, r)¶ Возвращает подпоследовательности элементов длины r из входного iterable, допуская повторение отдельных элементов.
Комбинации выдаются в лексикографическом порядке. Таким образом, если входной итерируемый объект отсортирован, кортежи комбинаций будут созданы в отсортированном порядке.
Элементы считаются уникальными по их позиции, а не по значению. Поэтому если входные элементы уникальны, сгенерированные комбинации также будут уникальны.
Примерно эквивалентно:
def combinations_with_replacement(iterable, r): # combinations_with_replacement('ABC', 2) --> AA AB AC BB BC CC pool = tuple(iterable) n = len(pool) if not n and r: return indices = [0] * r yield tuple(pool[i] for i in indices) while True: for i in reversed(range(r)): if indices[i] != n - 1: break else: return indices[i:] = [indices[i] + 1] * (r - i) yield tuple(pool[i] for i in indices)
Код для
combinations_with_replacement()можно также выразить как подпоследовательностьproduct()после фильтрации записей, где элементы не находятся в отсортированном порядке (согласно их позиции во входном пуле):def combinations_with_replacement(iterable, r): pool = tuple(iterable) n = len(pool) for indices in product(range(n), repeat=r): if sorted(indices) == list(indices): yield tuple(pool[i] for i in indices)
Количество возвращаемых элементов равно
(n+r-1)! / r! / (n-1)!, когдаn > 0.Новое в версии 2.7.
-
itertools.compress(data, selectors)¶ Создаёт итератор, который фильтрует элементы из data, возвращая только те, для которых в selectors есть соответствующий элемент, вычисляемый как
True. Останавливается, когда исчерпан либо итерабельный объект data, либо selectors. Примерно эквивалентен:def compress(data, selectors): # compress('ABCDEF', [1,0,1,0,1,1]) --> A C E F return (d for d, s in izip(data, selectors) if s)
Новое в версии 2.7.
-
itertools.count(start=0, step=1)¶ Создаёт итератор, который возвращает равномерно распределённые значения, начиная с n. Часто используется как аргумент для
imap()для генерации последовательных точек данных. Также используется сizip()для добавления порядковых номеров. Эквивалентно:def count(start=0, step=1): # count(10) --> 10 11 12 13 14 ... # count(2.5, 0.5) -> 2.5 3.0 3.5 ... n = start while True: yield n n += step
При подсчёте с числами с плавающей запятой иногда можно добиться лучшей точности, заменив код на мультипликативный, например:
(start + step * i for i in count()).Изменено в версии 2.7: добавлен аргумент step и разрешены нецелые аргументы.
-
itertools.cycle(iterable)¶ Создаёт итератор, возвращающий элементы из итерабельного объекта и сохраняющий копию каждого. Когда итерабельный объект исчерпан, возвращает элементы из сохранённой копии. Повторяется бесконечно. Примерно эквивалентен:
def cycle(iterable): # cycle('ABCD') --> A B C D A B C D A B C D ... saved = [] for element in iterable: yield element saved.append(element) while saved: for element in saved: yield element
Примечание: этот элемент набора инструментов может потребовать значительного дополнительного хранилища (в зависимости от длины итерабельного объекта).
-
itertools.dropwhile(predicate, iterable)¶ Создаёт итератор, который отбрасывает элементы из итерабельного объекта, пока предикат истинен; после этого возвращает каждый элемент. Примечание: итератор не выдаёт никакого вывода, пока предикат впервые не станет ложным, поэтому время запуска может быть большим. Примерно эквивалентен:
def dropwhile(predicate, iterable): # dropwhile(lambda x: x<5, [1,4,6,4,1]) --> 6 4 1 iterable = iter(iterable) for x in iterable: if not predicate(x): yield x break for x in iterable: yield x
-
itertools.groupby(iterable[, key])¶ Make an iterator that returns consecutive keys and groups from the iterable. The key is a function computing a key value for each element. If not specified or is
None, key defaults to an identity function and returns the element unchanged. Generally, the iterable needs to already be sorted on the same key function.Работа
groupby()аналогична фильтруuniqв Unix. Она создает разрыв или новую группу каждый раз, когда изменяется значение ключевой функции (поэтому обычно необходимо отсортировать данные с помощью той же ключевой функции). Такое поведение отличается от SQL GROUP BY, которая объединяет общие элементы независимо от порядка их ввода.Возвращаемая группа сама является итератором, который использует общий исходный итерируемый объект с
groupby(). Поскольку источник общий, при продвижении объектаgroupby()предыдущая группа перестает быть видимой. Поэтому, если эти данные понадобятся позже, их следует сохранить в виде списка:groups = [] uniquekeys = [] data = sorted(data, key=keyfunc) for k, g in groupby(data, keyfunc): groups.append(list(g)) # Сохранить групповой итератор как список uniquekeys.append(k)
groupby()примерно эквивалентно:class groupby(object): # [k for k, g in groupby('AAAABBBCCDAABBB')] --> A B C D A B # [list(g) for k, g in groupby('AAAABBBCCD')] --> AAAA BBB CC D def __init__(self, iterable, key=None): if key is None: key = lambda x: x self.keyfunc = key self.it = iter(iterable) self.tgtkey = self.currkey = self.currvalue = object() def __iter__(self): return self def next(self): while self.currkey == self.tgtkey: self.currvalue = next(self.it) # Выход при StopIteration self.currkey = self.keyfunc(self.currvalue) self.tgtkey = self.currkey return (self.currkey, self._grouper(self.tgtkey)) def _grouper(self, tgtkey): while self.currkey == tgtkey: yield self.currvalue self.currvalue = next(self.it) # Выход при StopIteration self.currkey = self.keyfunc(self.currvalue)
Новое в версии 2.4.
-
itertools.ifilter(predicate, iterable)¶ Создаёт итератор, который фильтрует элементы из итерируемого объекта, возвращая только те, для которых предикат равен
True. Если предикат равенNone, возвращает элементы, которые являются истинными. Примерный эквивалент:def ifilter(predicate, iterable): # ifilter(lambda x: x%2, range(10)) --> 1 3 5 7 9 if predicate is None: predicate = bool for x in iterable: if predicate(x): yield x
-
itertools.ifilterfalse(predicate, iterable)¶ Создаёт итератор, который фильтрует элементы из итерируемого объекта, возвращая только те, для которых предикат равен
False. Если предикат равенNone, возвращает элементы, которые являются ложными. Примерно эквивалентно:def ifilterfalse(predicate, iterable): # ifilterfalse(lambda x: x%2, range(10)) --> 0 2 4 6 8 if predicate is None: predicate = bool for x in iterable: if not predicate(x): yield x
-
itertools.imap(function, *iterables)¶ Создаёт итератор, который вычисляет функцию, используя аргументы из каждого итерируемого объекта. Если функция установлена в
None, тоimap()возвращает аргументы в виде кортежа. Какmap(), но останавливается, когда самый короткий итерируемый объект исчерпан, вместо заполненияNoneдля более коротких итерируемых объектов. Причина различия в том, что аргументы-бесконечные итераторы обычно являются ошибкой дляmap()(поскольку результат полностью вычисляется), но представляют собой распространённый и полезный способ передачи аргументов вimap(). Примерный эквивалент:def imap(function, *iterables): # imap(pow, (2,3,10), (5,2,3)) --> 32 9 1000 iterables = map(iter, iterables) while True: args = [next(it) for it in iterables] if function is None: yield tuple(args) else: yield function(*args)
-
itertools.islice(iterable, stop)¶ -
itertools.islice(iterable, start, stop[, step]) Создаёт итератор, который возвращает выбранные элементы из итерируемого объекта. Если start не равен нулю, то элементы из итерируемого объекта пропускаются до достижения start. Затем элементы возвращаются последовательно, если только step не установлен больше единицы, что приводит к пропуску элементов. Если stop равен
None, то итерация продолжается до тех пор, пока итератор не будет исчерпан, если вообще; в противном случае она останавливается на указанной позиции. В отличие от обычной срезки,islice()не поддерживает отрицательные значения для start, stop или step. Может использоваться для извлечения связанных полей из данных, где внутренняя структура была уплощена (например, многострочный отчёт может содержать поле имени на каждой третьей строке). Примерно эквивалентно:def islice(iterable, *args): # islice('ABCDEFG', 2) --> A B # islice('ABCDEFG', 2, 4) --> C D # islice('ABCDEFG', 2, None) --> C D E F G # islice('ABCDEFG', 0, None, 2) --> A C E G s = slice(*args) start, stop, step = s.start or 0, s.stop or sys.maxint, s.step or 1 it = iter(xrange(start, stop, step))) try: nexti = next(it) except StopIteration: # Потребляет *iterable* до позиции *start*. for i, element in izip(xrange(start), iterable): pass return try: for i, element in enumerate(iterable): if i == nexti: yield element nexti = next(it) except StopIteration: # Потребляет до *stop*. for i, element in izip(xrange(i + 1, stop), iterable): pass
Если start равен
None, то итерация начинается с нуля. Если step равенNone, то шаг по умолчанию равен единице.Изменено в версии 2.5: принимаются значения
Noneдля аргументов по умолчанию start и step.
-
itertools.izip(*iterables)¶ Создаёт итератор, который объединяет элементы из каждого итерируемого объекта. Как
zip(), за исключением того, что возвращает итератор вместо списка. Используется для синхронного перебора нескольких итерируемых объектов одновременно. Примерный эквивалент:def izip(*iterables): # izip('ABCD', 'xy') --> Ax By iterators = map(iter, iterables) while iterators: yield tuple(map(next, iterators))
Изменено в версии 2.4: Если итерируемые объекты не указаны, возвращается итератор нулевой длины вместо возбуждения исключения
TypeError.Гарантируется порядок вычисления итерируемых объектов слева направо. Это позволяет использовать идиому для группировки ряда данных в группы длины n с помощью
izip(*[iter(s)]*n).izip()следует использовать только с последовательностями разной длины, если не важны несовпавшие хвостовые значения из более длинных последовательностей. Если эти значения важны, используйтеizip_longest().
-
itertools.izip_longest(*iterables[, fillvalue])¶ Создаёт итератор, который агрегирует элементы из каждого из итерируемых объектов. Если итерируемые объекты имеют разную длину, недостающие значения заполняются с помощью fillvalue. Итерация продолжается до тех пор, пока самый длинный итерируемый объект не будет исчерпан. Приблизительно эквивалентно:
class ZipExhausted(Exception): pass def izip_longest(*args, **kwds): # izip_longest('ABCD', 'xy', fillvalue='-') --> Ax By C- D- fillvalue = kwds.get('fillvalue') counter = [len(args) - 1] def sentinel(): if not counter[0]: raise ZipExhausted counter[0] -= 1 yield fillvalue fillers = repeat(fillvalue) iterators = [chain(it, sentinel(), fillers) for it in args] try: while iterators: yield tuple(map(next, iterators)) except ZipExhausted: pass
Если один из итерируемых объектов может быть бесконечным, то функцию
izip_longest()следует обернуть во что-то, ограничивающее количество вызовов (например,islice()илиtakewhile()). Если не указано, fillvalue по умолчанию равенNone.Новое в версии 2.6.
-
itertools.permutations(iterable[, r])¶ Возвращает последовательные перестановки длины r элементов из iterable.
Если r не указан или равен
None, то r по умолчанию равен длине iterable и генерируются все возможные перестановки полной длины.Перестановки выдаются в лексикографическом порядке. Таким образом, если входной итерируемый объект отсортирован, кортежи перестановок будут созданы в отсортированном порядке.
Элементы считаются уникальными на основе их позиции, а не значения. Поэтому если входные элементы уникальны, то в каждой перестановке не будет повторяющихся значений.
Примерно эквивалентно:
def permutations(iterable, r=None): # permutations('ABCD', 2) --> AB AC AD BA BC BD CA CB CD DA DB DC # permutations(range(3)) --> 012 021 102 120 201 210 pool = tuple(iterable) n = len(pool) r = n if r is None else r if r > n: return indices = range(n) cycles = range(n, n-r, -1) yield tuple(pool[i] for i in indices[:r]) while n: for i in reversed(range(r)): cycles[i] -= 1 if cycles[i] == 0: indices[i:] = indices[i+1:] + indices[i:i+1] cycles[i] = n - i else: j = cycles[i] indices[i], indices[-j] = indices[-j], indices[i] yield tuple(pool[i] for i in indices[:r]) break else: return
Код для
permutations()также можно выразить как подпоследовательностьproduct(), отфильтрованную для исключения записей с повторяющимися элементами (тех, которые находятся на одной и той же позиции во входном пуле):def permutations(iterable, r=None): pool = tuple(iterable) n = len(pool) r = n if r is None else r for indices in product(range(n), repeat=r): if len(set(indices)) == r: yield tuple(pool[i] for i in indices)
Количество возвращаемых элементов равно
n! / (n-r)!, когда0 <= r <= n, или нулю, когдаr > n.Новое в версии 2.6.
-
itertools.product(*iterables[, repeat])¶ Декартово произведение входных итерируемых объектов.
Примерно эквивалентно вложенным циклам for в генераторном выражении. Например,
product(A, B)возвращает то же, что и((x,y) for x in A for y in B).Вложенные циклы работают как одометр: самый правый элемент увеличивается на каждой итерации. Этот шаблон создает лексикографический порядок, так что если входные итерируемые объекты отсортированы, кортежи произведения выдаются в отсортированном порядке.
Чтобы вычислить произведение итерируемого объекта на самого себя, укажите количество повторений с помощью необязательного именованного аргумента repeat. Например,
product(A, repeat=4)эквивалентноproduct(A, A, A, A).Эта функция примерно эквивалентна следующему коду, за исключением того, что реальная реализация не накапливает промежуточные результаты в памяти:
def product(*args, **kwds): # product('ABCD', 'xy') --> Ax Ay Bx By Cx Cy Dx Dy # product(range(2), repeat=3) --> 000 001 010 011 100 101 110 111 pools = map(tuple, args) * kwds.get('repeat', 1) result = [[]] for pool in pools: result = [x+[y] for x in result for y in pool] for prod in result: yield tuple(prod)
Новое в версии 2.6.
-
itertools.repeat(object[, times])¶ Создаёт итератор, который снова и снова возвращает object. Выполняется бесконечно, если не указан аргумент times. Используется как аргумент
imap()для инвариантных параметров функции. Также используется сizip()для создания константных полей в кортеже. Примерный эквивалент:def repeat(object, times=None): # repeat(10, 3) --> 10 10 10 if times is None: while True: yield object else: for i in xrange(times): yield object
Обычное применение repeat – подача потока константных значений в imap или zip:
>>> list(imap(pow, xrange(10), repeat(2))) [0, 1, 4, 9, 16, 25, 36, 49, 64, 81]
-
itertools.starmap(function, iterable)¶ Создаёт итератор, который вычисляет функцию, используя аргументы, полученные из итерируемого объекта. Используется вместо
imap(), когда параметры аргументов уже сгруппированы в кортежи из одного итерируемого объекта (данные были «предварительно сжаты»). Разница междуimap()иstarmap()параллельна различию междуfunction(a,b)иfunction(*c). Примерно эквивалентно:def starmap(function, iterable): # starmap(pow, [(2,5), (3,2), (10,3)]) --> 32 9 1000 for args in iterable: yield function(*args)
Изменено в версии 2.6: Ранее
starmap()требовал, чтобы аргументы функции были кортежами. Теперь разрешён любой итерируемый объект.
-
itertools.takewhile(predicate, iterable)¶ Создаёт итератор, возвращающий элементы из итерируемого объекта, пока предикат истинен. Приблизительно эквивалентно:
def takewhile(predicate, iterable): # takewhile(lambda x: x<5, [1,4,6,4,1]) --> 1 4 for x in iterable: if predicate(x): yield x else: break
-
itertools.tee(iterable[, n=2])¶ Возвращает n независимых итераторов из одного итерируемого объекта. Примерно эквивалентно:
def tee(iterable, n=2): it = iter(iterable) deques = [collections.deque() for i in range(n)] def gen(mydeque): while True: if not mydeque: # когда локальная deque пуста newval = next(it) # извлечь новое значение и for d in deques: # загрузить его во все двусторонние очереди d.append(newval) yield mydeque.popleft() return tuple(gen(d) for d in deques)
После того как
tee()выполнил разделение, исходный итерируемый объект не следует использовать где-либо ещё; в противном случае итерируемый объект может продвинуться без уведомления объектов tee.Итераторы
teeне являются потокобезопасными.RuntimeErrorможет быть возбуждён при одновременном использовании итераторов, возвращённых одним и тем же вызовомtee(), даже если исходный iterable является потокобезопасным.Этот инструмент итерации может потребовать значительного вспомогательного хранилища (в зависимости от объёма временных данных, которые необходимо сохранить). В общем случае, если один итератор использует большую часть или все данные до того, как запустится другой итератор, быстрее использовать
list()вместоtee().Новое в версии 2.4.
9.7.2. Рецепты¶Recipes
В этом разделе представлены рецепты для создания расширенного набора инструментов с использованием существующих itertools в качестве строительных блоков.
Расширенные инструменты обеспечивают такую же высокую производительность, как и базовый набор инструментов. Превосходная производительность по памяти достигается за счёт обработки элементов по одному, а не загрузки всего итерируемого объекта в память сразу. Объём кода остаётся небольшим благодаря связыванию инструментов в функциональном стиле, что помогает избавиться от временных переменных. Высокая скорость сохраняется за счёт предпочтения «векторизованных» строительных блоков вместо использования циклов for и генераторов, которые создают накладные расходы интерпретатора.
def take(n, iterable):
"Return first n items of the iterable as a list"
return list(islice(iterable, n))
def tabulate(function, start=0):
"Return function(0), function(1), ..."
return imap(function, count(start))
def consume(iterator, n=None):
"Advance the iterator n-steps ahead. If n is None, consume entirely."
# Используйте функции, потребляющие итераторы на скорости C.
if n is None:
# передать весь итератор в deque нулевой длины
collections.deque(iterator, maxlen=0)
else:
# перейти к пустому срезу начиная с позиции n
next(islice(iterator, n, n), None)
def nth(iterable, n, default=None):
"Returns the nth item or a default value"
return next(islice(iterable, n, None), default)
def all_equal(iterable):
"Returns True if all the elements are equal to each other"
g = groupby(iterable)
return next(g, True) and not next(g, False)
def quantify(iterable, pred=bool):
"Count how many times the predicate is true"
return sum(imap(pred, iterable))
def padnone(iterable):
"""Возвращает элементы последовательности, а затем бесконечно возвращает None.
Полезно для эмуляции поведения встроенной функции map().
"""
return chain(iterable, repeat(None))
def ncycles(iterable, n):
"Returns the sequence elements n times"
return chain.from_iterable(repeat(tuple(iterable), n))
def dotproduct(vec1, vec2):
return sum(imap(operator.mul, vec1, vec2))
def flatten(listOfLists):
"Flatten one level of nesting"
return chain.from_iterable(listOfLists)
def repeatfunc(func, times=None, *args):
"""Повторяет вызовы func с указанными аргументами.
Пример: repeatfunc(random.random)
"""
if times is None:
return starmap(func, repeat(args))
return starmap(func, repeat(args, times))
def pairwise(iterable):
"s -> (s0,s1), (s1,s2), (s2, s3), ..."
a, b = tee(iterable)
next(b, None)
return izip(a, b)
def grouper(iterable, n, fillvalue=None):
"Collect data into fixed-length chunks or blocks"
# grouper('ABCDEFG', 3, 'x') --> ABC DEF Gxx
args = [iter(iterable)] * n
return izip_longest(fillvalue=fillvalue, *args)
def roundrobin(*iterables):
"roundrobin('ABC', 'D', 'EF') --> A D E B F C"
# Автор рецепта – Джордж Саккис
pending = len(iterables)
nexts = cycle(iter(it).next for it in iterables)
while pending:
try:
for next in nexts:
yield next()
except StopIteration:
pending -= 1
nexts = cycle(islice(nexts, pending))
def powerset(iterable):
"powerset([1,2,3]) --> () (1,) (2,) (3,) (1,2) (1,3) (2,3) (1,2,3)"
s = list(iterable)
return chain.from_iterable(combinations(s, r) for r in range(len(s)+1))
def unique_everseen(iterable, key=None):
"List unique elements, preserving order. Remember all elements ever seen."
# unique_everseen('AAAABBBCCDAABBB') --> A B C D
# unique_everseen('ABBCcAD', str.lower) --> A B C D
seen = set()
seen_add = seen.add
if key is None:
for element in ifilterfalse(seen.__contains__, iterable):
seen_add(element)
yield element
else:
for element in iterable:
k = key(element)
if k not in seen:
seen_add(k)
yield element
def unique_justseen(iterable, key=None):
"List unique elements, preserving order. Remember only the element just seen."
# unique_justseen('AAAABBBCCDAABBB') --> A B C D A B
# unique_justseen('ABBCcAD', str.lower) --> A B C A D
return imap(next, imap(itemgetter(1), groupby(iterable, key)))
def iter_except(func, exception, first=None):
""" Повторно вызывает функцию до возникновения исключения.
Преобразует интерфейс вызова до исключения в интерфейс итератора.
Подобно __builtin__.iter(func, sentinel), но использует исключение вместо этого
сигнального значения для завершения цикла.
Примеры:
bsddbiter = iter_except(db.next, bsddb.error, db.first)
heapiter = iter_except(functools.partial(heappop, h), IndexError)
dictiter = iter_except(d.popitem, KeyError)
dequeiter = iter_except(d.popleft, IndexError)
queueiter = iter_except(q.get_nowait, Queue.Empty)
setiter = iter_except(s.pop, KeyError)
"""
try:
if first is not None:
yield first()
while 1:
yield func()
except exception:
pass
def random_product(*args, **kwds):
"Random selection from itertools.product(*args, **kwds)"
pools = map(tuple, args) * kwds.get('repeat', 1)
return tuple(random.choice(pool) for pool in pools)
def random_permutation(iterable, r=None):
"Random selection from itertools.permutations(iterable, r)"
pool = tuple(iterable)
r = len(pool) if r is None else r
return tuple(random.sample(pool, r))
def random_combination(iterable, r):
"Random selection from itertools.combinations(iterable, r)"
pool = tuple(iterable)
n = len(pool)
indices = sorted(random.sample(xrange(n), r))
return tuple(pool[i] for i in indices)
def random_combination_with_replacement(iterable, r):
"Random selection from itertools.combinations_with_replacement(iterable, r)"
pool = tuple(iterable)
n = len(pool)
indices = sorted(random.randrange(n) for i in xrange(r))
return tuple(pool[i] for i in indices)
def tee_lookahead(t, i):
"""Проверяет i-е следующее значение из объекта tee
оставляя объект tee на его текущей позиции.
Возбуждает IndexError, если базовый итератор не
имеет достаточного количества значений.
"""
for value in islice(t.__copy__(), i, None):
return value
raise IndexError(i)
Обратите внимание: многие из приведённых выше рецептов можно оптимизировать, заменив глобальные поиски локальными переменными, определёнными как значения по умолчанию. Например, рецепт dotproduct можно записать так:
def dotproduct(vec1, vec2, sum=sum, imap=imap, mul=operator.mul):
return sum(imap(mul, vec1, vec2))