notebook.community

Edit and run



In [ ]:

    
from streamz.dataframe import Random, DataFrame



In [ ]:

    
source = Random(freq='5ms', interval='100ms')
source.x.sum()



In [ ]:

    
sdf = (source - 0.5).cumsum()
sdf.tail()



In [ ]:

    
p = (DataFrame({'raw': sdf.x,
                        'smooth': sdf.x.rolling('100ms').mean(),
                        'very-smooth': sdf.x.rolling('500ms').mean()})
     .plot(width=700)
    )



In [ ]: