python pipe包管道包学习

• python Pipe包可以实现管道操作命令，实现高效的代码写作

from pipe import  *

#加法
[1,2,3] | add

#select 函数，相当于map映射操作
x | select(lambda x:float(x +"1"))  |as_list
#x

#聚合函数，可以使用lambda函数自定义
(1, 2, 3, 4, 5, 6, 7, 8, 9) | aggregate(lambda x, y: x + y)


#筛选和过滤
[1, 2, 3] | where(lambda x: x % 2 == 0) | as_list
[1, 2, 3, 4] | take_while(lambda x: x < 3) | concat
[1, 2, 3, 4] | where(lambda x: x < 3) | concat

#take 前几个元素和count生成器的长度
[1,2,3]|take(2) |as_list |where(lambda  x : x ==2) |as_list |count

[1,2,3]|count

#平均数，使用自定义函数，必须在函数前面加上@pipe装饰
[1, 2, 3] | select(lambda x: x * x) |average1


#相当于flatmap
[[1, 2], [3, 4], [5]] | chain |as_list


#[1, 2, 3, 4, 5] | tee |as_list

#将生成器转换成list列表
[1, 2, 3, 4, 5, 6] | as_list

#平均数
[1, 2, 3, 4, 5, 6] | average

#使用islice截取从下表2到7,按照索引截取数组中的元素
(1, 2, 3, 4, 5, 6, 7, 8, 9) | islice(2, 8) | concat
(1, 2, 3, 4, 5, 6, 7, 8, 9) | islice(0,1) |as_list


#两个列表实现zip函数
(1, 2, 3, 4, 5, 6, 7, 8, 9) \
| izip([9, 8, 7, 6, 5, 4, 3, 2, 1]) \
| concat


#any()，只要存在一个就返回true
(1, 3, 5, 6, 7) | any(lambda x: x >= 7)
(1, 3, 5, 6, 7) | any(lambda x: x > 7)

#all(),必须全部满足才会返回true
(1, 3, 5, 6, 7) | all(lambda x: x < 7)
(1, 3, 5, 6, 7) | all(lambda x: x <= 7)

#max() 按照key中的指定的函数来排序，然后筛选出max的函数
('aa', 'b', 'fosdfdfo', 'qwerty', 'bar', 'zoog') | max(key=len)
('aa', 'b', 'foo', 'qwerty', 'bar', 'zoog') | max()

('aa', 'b', 'foo', 'qwerty', 'bar', 'zoog') | max
    'zoog'



#groupby() 对列表实现分组计算
(1, 2, 3, 4, 5, 6, 7, 8, 9) \
| groupby(lambda x: x % 2 and "Even" or "Odd") \
| select(lambda x: "%s : %s" % (x[0], (x[1] | concat(', ')))) \
| concat(' / ')

#(1, 2, 3, 4, 5, 6, 7, 8, 9) | groupby(lambda x: x % 2 and "Even" or "Odd") | islice(0,1) | as_dict





#sort()对列表实现排序操作，其中key为指定的自定义函数,reverse 则指定是顺序排还是逆序排
#  Like Python's built-in "sorted" primitive. Allows cmp (Python 2.x    only), key, and reverse arguments. By default sorts using the    identity function as the key.

"python" | sort(key=lambda x:len(x),reverse=True) | concat("")    #'hnopty',设置逆序
[5, -4, 3, -2, 1] | sort(key=abs) | concat
#    '1, -2, 3, -4, 5'


#dedup()    Deduplicate values删除重复的值
[1,1,2,2,3,3,1,2,3] | dedup  |as_list

#uniq() Like dedup() but only deduplicate consecutive values.
#删除连续的且重复的值
[1,1,2,2,3,3,1,2,3] | uniq | as_list


#reverse 逆转
#Like Python's built-in "reversed" primitive.
[1, 2, 3] | reverse | concat


#index
#Returns index of value in iterable 检索值
#输入value start stop
[1,2,3,2,1] | index(value=2,start=2,stop=4)
[1,2,3,2,1] | index(3)#2

• 构造你自己的pipe管道函数

stdout = Pipe(lambda x: sys.stdout.write(str(x)))
select = Pipe(lambda iterable, pred: (pred(x) for x in iterable))
# 或者
@Pipe
def stdout(x):
    sys.stdout.write(str(x))

• 参考github : https://github.com/JulienPalard/Pipe