Asyncio plugins, components, dependency injection and configs
Project description
This is heavily inspired by Pyramid and my daily needs to fastly create and maintain microservice like applications.
a plugin mechanic
plugin may depend on other plugins
plugins yield tasks to run
a registry serves as a store for application components created by plugins
a dependency injection creates intermediate components
a config source is mapped to plugin specific needs
structlog boilerplate for json/tty logging
You bootstrap like following:
from buvar import plugin
plugin.stage("some.module.with.plugin.function")# some.module.with.plugin.function
from buvar import context, plugin
class Foo:
...
async def task():
asyncio.sleep(1)
async def server():
my_component = context.get(Foo)
await asyncio.Future()
# you may omit include in arguments
async def prepare(load: plugin.Loader):
await load('.another.plugin')
# create some long lasting components
my_component = context.add(Foo())
# you may run simple tasks
yield task()
# you may run server tasks
yield server()a components and dependency injection solution
Dependency injection relies on registered adapters, which may be a function, a method, a class, a classmethod or a generic classmthod.
Dependencies are looked up in components or may be provided via, arguments.
from buvar import di
class Bar:
pass
class Foo:
def __init__(self, bar: Bar = None):
self.bar = bar
@classmethod
async def adapt(cls, baz: str) -> Foo:
return Foo()
async def adapt(bar: Bar) -> Foo
foo = Foo(bar)
return foo
async def task():
foo = await di.nject(Foo, baz="baz")
assert foo.bar is None
bar = Bar()
foo = await di.nject(Foo, bar=bar)
assert foo.bar is bar
async def prepare():
di.register(Foo.adapt)
di.register(adapt)a config source
buvar.config.ConfigSource is just a dict, which merges arbitrary dicts into one. It serves a the single source of truth for application variability.
You can load a section of config values into your custom attrs class instance. ConfigSource will override values by environment variables if present.
config.toml
log_level = "DEBUG"
show_warnings = "yes"
[foobar]
some = "value"export APP_FOOBAR_SOME=thingimport attr
import toml
from buvar import config
@attr.s(auto_attribs=True)
class GeneralConfig:
log_level: str = "INFO"
show_warnings: bool = config.bool_var(False)
@attr.s(auto_attribs=True)
class FoobarConfig:
some: str
source = config.ConfigSource(toml.load('config.toml'), env_prefix="APP")
general_config = source.load(GeneralConfig)
assert general_config == GeneralConfig(log_level="DEBUG", show_warnings=True)
foobar_config = source.load(FoobarConfig, 'foobar')
assert foobar_config.some == "thing"There is a shortcut to the above approach provided by buvar.config.Config, which requires to be subclassed from it with a distinct section attribute. If one adds a buvar.config.ConfigSource component, he will receive the mapped config in one call.
from buvar import config, plugin
@attr.s(auto_attribs=True)
class GeneralConfig(config.Config):
log_level: str = "INFO"
show_warnings: bool = config.bool_var(False)
@attr.s(auto_attribs=True)
class FoobarConfig(config.Config, section="foobar"):
some: str
async def prepare(load: plugin.Loader):
# this would by typically placed in the main entry point
source = context.add(config.ConfigSource(toml.load('config.toml'), env_prefix="APP"))
# to provide the adapter to di, which could also be done inthe main entry point
await load(config)
foobar_config = await di.nject(FoobarConfig)a structlog
Just structlog boilerplate.
import sys
from buvar import log
log.setup_logging(sys.stdout.isatty(), general_config.log_level)Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distributions
File details
Details for the file buvar-0.33.0.tar.gz.
File metadata
- Download URL: buvar-0.33.0.tar.gz
- Upload date:
- Size: 130.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.23.0 setuptools/46.1.3 requests-toolbelt/0.9.1 tqdm/4.45.0 CPython/3.8.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 0bc855982d777afdc4a2ff3cfa778d4ce8c3395216e5a22ace5202bf67905b02 |
|
| MD5 | 8efe25cadc1ca9d7d9f0c5e6b79edb50 |
|
| BLAKE2b-256 | 54eb3a8d4e8453e138d06de77ec68e33547eb5a97c08e9c26ddf249b086196da |
File details
Details for the file buvar-0.33.0-cp38-cp38-manylinux1_x86_64.whl.
File metadata
- Download URL: buvar-0.33.0-cp38-cp38-manylinux1_x86_64.whl
- Upload date:
- Size: 553.4 kB
- Tags: CPython 3.8
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.23.0 setuptools/46.1.3 requests-toolbelt/0.9.1 tqdm/4.45.0 CPython/3.8.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | eaa0a2f9f1aefe64df4644ba9a4f8f0a73cf1542d479a935e1f04d1941345bb7 |
|
| MD5 | 7a9d66ea444d3aa2bca1a196b4d1f472 |
|
| BLAKE2b-256 | 2674b1e1a54d1f651bb6c26c516ed175395b6451c3c2ef11cb7f3f92a94f4b41 |
File details
Details for the file buvar-0.33.0-cp37-cp37m-manylinux1_x86_64.whl.
File metadata
- Download URL: buvar-0.33.0-cp37-cp37m-manylinux1_x86_64.whl
- Upload date:
- Size: 491.0 kB
- Tags: CPython 3.7m
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.23.0 setuptools/46.1.3 requests-toolbelt/0.9.1 tqdm/4.45.0 CPython/3.8.2
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 91ef5f1c693d53c7a37455a6166c29502fafe348394d2672d44fbfd22a29d9ec |
|
| MD5 | f567a3faf225debce2689caa5346abad |
|
| BLAKE2b-256 | b20e9eee032f8a6fe624f1eee1fb380d2642bdea58bc0d0e23fbd44a386ac003 |
