pip install pipelinedb-python
python
import pipeline
client = pipeline.Client(dbname='mydb', hosted=True)
python
stream = client.create_stream('mystream', x='integer', y='float', z='text')
python
stream.insert({'x': 1, 'y': 2.5, 'z': 'example'})
python
results = client.execute('SELECT avg(x), sum(y) FROM mystream')
python
client.close()
