Storage inmemory

Example

storage_inmemory.py
 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
import pprint

import asab
import asab.storage


asab.Config.add_defaults(
    {
        'asab:storage': {
            'type': 'inmemory',
        }
    }
)


class MyApplication(asab.Application):

    async def initialize(self):
        # Loading the web service module
        self.add_module(asab.storage.Module)


    async def main(self):
        storage = self.get_service("asab.StorageService")

        # Obtain upsertor object which is associated with given "test-collection"
        # To create new object we keep default `version` to zero
        u = storage.upsertor("test-collection")
        u.set("foo", "bar")
        objid = await u.execute()

        obj = await storage.get("test-collection", objid)
        # Obtain upsertor object for update - specify existing `version` number
        u = storage.upsertor("test-collection", obj_id=objid, version=obj['_v'])
        u.set("foo", "buzz")
        objid = await u.execute()

        obj = await storage.get("test-collection", objid)
        print(f"Result of get by id: {objid}")
        pprint.pprint(obj)

        await storage.delete("test-collection", objid)

        self.stop()


if __name__ == '__main__':
    app = MyApplication()
    app.run()