Skip to main content
Warning: You are using the test version of PyPI. This is a pre-production deployment of Warehouse. Changes made here affect the production instance of TestPyPI (
Help us improve Python packaging - Donate today!

A message broker to create software bus over the network

Project Description


ReactOBus is a message broker that helps to create software bus over the network and to react to some messages.


ReactOBus is able to:

  • collect events (as network messages) from different sources
  • publish the stream of events
  • store the events in a database
  • launch specific commands when an event match some conditions

In a near future, ReactOBus will be able to:

  • filter-out some events
  • modify on-the-fly event format

Using ReactOBus


ReactOBus is known to work with Python3.4 and Python3.5 under Linux.

It depends on (see requirements.txt):

  • pyzmq
  • pyYAML
  • SQLAlchemy (if you wish to store events in a database)
  • setproctitle


ReactOBus is available on pypi and can be installed with:

pip install ReactOBus

By default, pip will not install SQLAlchemy. If need, install it manually afterward or ask pip to include the right ReactOBus variant with:

pip install ReactOBus[db]

It’s also possible to execute ReactOBus directly from the sources:

git clone
cd ReactOBus
virtualenv -p python3.5 venv
source venv/bin/activate
pip install -r requirements.txt
python reactobus --level DEBUG --conf share/examples/reactobus.yaml


The configuration file is a YAML dictionary with:

  • inputs: a list of input streams
  • outputs: a list of output streams
  • core: configuration of the internal sockets
  • reactor: the reacting part of ReactOBus
  • db: the database configuration

All keys except core and inputs are optional. If the optional keys are not found in the configuration, the corresponding modules won’t be loaded.

Message format

For the moment, ReactOBus only accepts one type of messages. The messages should be multipart ZMQ messages with the following meaning:

  • topic
  • uuid (as generated by uuid.uuid1() in Python)
  • datetime when the message was generated (isoformat)
  • username of the sending process or user
  • data as JSON

Testing ReactOBus

In order to run ReactOBus automatic tests, you will have to install py.test:

pip install pytest

Then run the tests using:

py.test tests -v
tests/ PASSED
tests/ PASSED
tests/ PASSED

On each push, the tests and the coverage are computed on:

Release History

Release History

This version
History Node


History Node


History Node


History Node


Download Files

Download Files

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

File Name & Checksum SHA256 Checksum Help Version File Type Upload Date
ReactOBus-0.1.3.tar.gz (22.5 kB) Copy SHA256 Checksum SHA256 Source Nov 17, 2016

Supported By

WebFaction WebFaction Technical Writing Elastic Elastic Search Pingdom Pingdom Monitoring Dyn Dyn DNS Sentry Sentry Error Logging CloudAMQP CloudAMQP RabbitMQ Heroku Heroku PaaS Kabu Creative Kabu Creative UX & Design Fastly Fastly CDN DigiCert DigiCert EV Certificate Rackspace Rackspace Cloud Servers DreamHost DreamHost Log Hosting