Scalable Data Streams for Python

Quick Start

Install the library via pip to begin processing streams:

pip install pydatastream-core

Basic Usage Example

import pydatastream as pds

# Initialize the stream processor
stream = pds.Stream(buffer_size=1024)

@stream.on_event
def process_data(data):
    return data.map(lambda x: x * 2)

stream.run()