Library

Example

library.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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#!/usr/bin/env python3
import os.path

import asab
import asab.library
import asab.zookeeper

asab.Config.add_defaults({
    "zookeeper": {
        # "servers": "zookeeper-1:2181,zookeeper-2:2181,zookeeper-3:2181",
        "servers": "zookeeper-1:2181"
    },

    "library": {
        "azure_cache": "true",
    }

})


class MyApplication(asab.Application):

    def __init__(self):
        super().__init__(modules=[asab.zookeeper.Module])

        # Specify a locations of the default library
        asab.Config["library"]["providers"] = '\n'.join([
            os.path.join(os.path.dirname(__file__), "library"),
            # "zk:///library",
            # "git+https://github.com/TeskaLabs/asab.git"
            "azure+https://lmio.blob.core.windows.net/library"
        ])

        self.LibraryService = asab.library.LibraryService(
            self,
            "LibraryService",
        )

        # Continue only if the library is ready
        # We need to wait till eg. Zookeeper is connected
        self.PubSub.subscribe("Library.ready!", self.on_library_ready)


    async def on_library_ready(self, event_name, library):
        items = await self.LibraryService.list("", recursive=True)
        print("# Library\n")
        for item in items:
            print(" *", item)
            if item.type == 'item':
                itemio = await self.LibraryService.read(item.name)
                if itemio is not None:
                    with itemio:
                        content = itemio.read()
                        print("  - content: {} bytes".format(len(content)))
                else:
                    print("  - N/A")  # Item is likely disabled
        print("\n===")
        self.stop()


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