dasi package

Submodules

dasi.dasi module

class dasi.dasi.Dasi(config: str)

Bases: object

The Python interface to DASI.

# Import dasi
from dasi import Dasi

# Create new DASI session
dasi = Dasi("config.yaml")

archive(key, data)

Write data to be stored according to Dasi configuration.

Parameters:

key – The metadata description of the data to store and index
data – A pointer to a (read-only) copy of the data

flush(): Flushes all buffers and ensures internal state is safe (wrt failure).

list(query) → List

List data present and retrievable from the archive

Parameters:: query – A description of the span of metadata to list within
Returns:: An iterable details of the objects describing data.
Return type:: List

retrieve(query) → Retrieve

Retrieve data objects from the archive

Parameters:: query – A description of the span of data to retrieve
Returns:: A generic data handle, that will retrieve the data
Return type:: Retrieve

wipe(query, doit: bool = False, all: bool = False) → Wipe

Wipe data from dasi

Parameters:: query – A description of the span of metadata to wipe
Returns:: An iterable wipe output.
Return type:: Wipe

dasi.key module

class dasi.key.Key(key=None)

Bases: object

Container for keyword:value.

property cdata

clear()

has(keyword: str) → bool

insert(keys: dict)

dasi.list module

class dasi.list.List(dasi: _CDataBase, query)

Bases: object

property key: Key

property length: int

property offset: int

property timestamp: int

property uri: str

dasi.query module

class dasi.query.Query(query=None)

Bases: object

Container for the keyword:value for retrieving data.

append(keyword, value)

property cdata

clear()

count_value(keyword) → int

get_value(keyword, number) → str

has(keyword) → bool

insert(query: dict)

dasi.retrieve module

class dasi.retrieve.Retrieve(dasi: _CDataBase, query)

Bases: object

property data: bytearray

property key: Key

property length: int

property offset: int

property timestamp: int