minikv 1.0.1

Distributed key-value store with Raft consensus, encryption at rest, and pluggable storage backends.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

#!/usr/bin/env python3
"""End-to-end data science quickstart for minikv."""

from sdk.python.minikv_client import MinikvClient, to_pandas_points


def main() -> None:
    client = MinikvClient()

    print("== Vector demo ==")
    client.vector_upsert("signal-a", [0.12, 0.94, 0.21], {"kind": "signal", "region": "eu"})
    client.vector_upsert("signal-b", [0.11, 0.91, 0.25], {"kind": "signal", "region": "us"})
    client.vector_upsert("signal-c", [0.76, 0.14, 0.51], {"kind": "noise", "region": "eu"})

    nearest = client.vector_query([0.10, 0.90, 0.20], top_k=2)
    print(nearest)

    print("\n== Time-series demo ==")
    write_resp = client.timeseries_write(
        {
            "metric": "cpu.usage",
            "tags": {"host": "node-1", "env": "dev"},
            "points": [
                {"timestamp": 1710000000000, "value": 42.1},
                {"timestamp": 1710000060000, "value": 44.3},
            ],
        }
    )
    print("write:", write_resp)

    query_resp = client.timeseries_query(
        {
            "metric": "cpu.usage",
            "start": "2024-03-09T00:00:00Z",
            "end": "2024-03-10T00:00:00Z",
            "tags": {"host": "node-1"},
        }
    )
    print("query:", query_resp)

    try:
        df = to_pandas_points(query_resp)
        print("pandas rows:", len(df))
        print(df.head())
    except Exception as exc:  # pragma: no cover - optional dependency
        print("pandas conversion skipped:", exc)


if __name__ == "__main__":
    main()