Skip to main content

Scaffolding for BrewBlox backend services

Project description

Scaffolding for BrewBlox service applications

In order to reduce code duplication between services, generic functionality is implemented here.

For an example on how to implement your own service based on brewblox-service, see

brewblox-service can technically be launched as a standalone application, but will not be very useful.


Small generic tools are defined here.

brewblox_logger can be used for creating module-specific loggers. It is not required, but will play a bit nicer with default formatting of the log.


from brewblox_service import brewblox_logger

LOGGER = brewblox_logger(__name__)'hello')

Parses commandline arguments, creates an aiohttp app, and runs it.

The shortest implementation is:

app = service.create_app(default_name='my_service')

This will get you a working web application, but it will only support the /_service/status health check endpoint.

Applications can configure their own features, and add new commandline arguments.


# Separately creating the parser allows adding arguments to the default set
parser = service.create_parser(default_name='my_service')

# Now create the app
app = service.create_app(parser=create_parser())

# Add features for this service

# Furnish and run

Many service features are application-scoped. Their lifecycle should span multiple requests, either because they are not request-driven, or because they manage asynchronous I/O operations (such as listening to AMQP messages).

The ServiceFeature class offers an abstract base class for this behavior. Implementing classes should define startup(app) and shutdown(app) functions, and those will be automatically called when the application starts up and shuts down.

Both startup() and shutdown() are called in an async context, making them the async counterparts of __init__() and __del__() functions.

Features must be constructed after the app is created, but before it starts running. (service.create_app() and

The add() and get() functions make it easy to centrally declare a feature, and then use it in any function that has a reference to the aiohttp app.

Both incoming and outgoing communication with the AMQP eventbus is handled here.

EventListener allows subscribing to eventbus messages. It will fire a callback when one is received. Subscriptions can be set at any time (also before the app starts running).

The listener is designed to gracefully degrade when the eventbus can't be reached. No errors will be raised, and it will periodically attempt to reconnect and restore its subscriptions.

For a practical implementation of EventListener, see brewblox_history

EventPublisher is responsible for sending new messages to the eventbus. A single publisher per application is sufficient.

In contrast with EventListener, the publisher will raise an exception when attempting to publish to an unreachable eventbus host. It will attempt to reconnect for each subsequent message - no explicit connection management is required.

Project details

Release history Release notifications

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for brewblox-service, version 0.20.0
Filename, size File type Python version Upload date Hashes
Filename, size brewblox-service-0.20.0.tar.gz (48.7 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page