sqlitedict + zstandard compression (w/ immediatey disk writes)

zstd_sqlitedict.py

import sqlitedict
import zstandard


def zstd_sqlitedict(*args, **kwargs):
    return sqlitedict.SqliteDict(
        *args,
        decode=lambda obj: sqlitedict.decode(zstandard.decompress(obj)),
        encode=lambda obj: zstandard.compress(bytes(sqlitedict.encode(obj))),
        autocommit=True,
        **kwargs)