pyella 0.1.5

Python bindings for the ella datastore.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

import ella
import numpy as np


def main(root):
    with ella.open(root, create=True) as rt:
        a = rt.tables.get_or_create(
            "a", ella.topic(ella.column("x", ella.float32, row_shape=(10, 10)))
        )
        with a.publish() as pb:
            for _ in range(10):
                pb.write(np.random.rand(10, 10).astype(np.float32))

        for df in rt.query("SELECT * FROM a"):
            print(df.to_arrow())


if __name__ == "__main__":
    main("/tmp/ella")