pypeline:用于数据流在线处理的面向对象模型 源码

茶碱 Pypeline模块为Python中的数据流在线处理提供了一个通用,易于使用和可扩展的面向对象模型,该模型特别适合于处理EARS软件中的多通道电生理信号。 受R中dplyr软件包的启发, Pypeline允许将流处理阶段定义为Node ,可以使用shift运算符>>相互连接。 或者, | 或者可以使用壳管操作器。 daqs . physiologyInput \ >> pypeline . LFilter ( fl = 300 , fh = 6e3 , n = 6 ) \ >> self . physiologyPlot 此处,与dplyr的主要区别在于>>仅声明管道中的连接,但此语句未进行任何实际的数据处理。 所有Node都继承了write()方法,该方法在调用时会将新数据传递到该节点进行处理。 处理后的数据将进一步传递到下游的连接节点。 通常,数据是在管道