The Swiss army knife of local data.

from beaver import BeaverDB

db = BeaverDB("app.db")
config = db.dict("config")
config["theme"] = "dark"
config.set("session", {"user": "ana"}, ttl_seconds=3600)
print(config["theme"], len(config))

from beaver import BeaverDB

db = BeaverDB("app.db")
todo = db.list("todo")
todo.push("write the report")
todo.push("ship the release")
todo.prepend("buy coffee")
print(todo[0], todo[1:], len(todo))

from beaver import BeaverDB

db = BeaverDB("app.db")
jobs = db.queue("jobs")
jobs.put({"task": "resize", "file": "a.png"}, priority=2)
jobs.put({"task": "urgent"}, priority=1)
job = jobs.get()          # lowest priority value first
print(job.data)

import time
from beaver import BeaverDB

db = BeaverDB("app.db")
metrics = db.log("metrics")
metrics.log({"cpu": 0.42, "host": "web-1"})
metrics.log({"cpu": 0.57, "host": "web-2"})
last_hour = metrics.range(start=time.time() - 3600)
print(len(last_hour), last_hour[-1].data)

from beaver import BeaverDB, Document

db = BeaverDB("app.db")
notes = db.docs("notes")
notes.index(Document(id="wal", body="readers and writers share one file"), fuzzy=True)
notes.index(Document(id="aio", body="asyncio runs coroutines"), fuzzy=True)
print([h.document.id for h in notes.search("readers")])                 # full-text
print([h.document.id for h in notes.search("corutines", fuzzy=True)])   # typo-tolerant

from beaver import BeaverDB

db = BeaverDB("app.db")
emb = db.vectors("embeddings")
emb.set("cat", [0.9, 0.1, 0.0])
emb.set("dog", [0.8, 0.2, 0.1])
emb.set("car", [0.0, 0.1, 0.9])
for item in emb.near([0.85, 0.15, 0.05], k=2):
    print(item.id)

from beaver import BeaverDB

db = BeaverDB("app.db")
g = db.graph("people")
g.link("ana", "ben", "knows")
g.link("ben", "cara", "knows")
g.link("ana", "acme", "works_at")
print(list(g.children("ana", label="knows")))
print(list(g.parents("cara")))

from beaver import BeaverDB

db = BeaverDB("app.db")
files = db.blob("files")
files.put("logo.png", b"\x89PNG...", metadata={"type": "image/png"})
item = files.fetch("logo.png")
print(len(item.data), item.metadata)

from beaver import BeaverDB

db = BeaverDB("app.db")
# coordinates threads and processes that share app.db
with db.lock("nightly-backup", timeout=5):
    print("only this process runs the backup")

import threading
from beaver import BeaverDB

db = BeaverDB("app.db")
chat = db.channel("chat")

def listen():
    for msg in chat.listen():       # any process with app.db can listen
        print("got", msg.payload)
        break

t = threading.Thread(target=listen); t.start()
chat.publish({"from": "ana", "text": "hello"})
t.join(timeout=5)