Python participant support for MsgFlo
Python CoffeeScript
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
bin
examples
msgflo
spec
.gitignore
.travis.yml
CHANGES.md
LICENSE
MANIFEST.in
README.md
package.json
requirements.pip
setup.py

README.md

msgflo-python: Python participant support for MsgFlo

MsgFlo is a distributed, polyglot FBP (flow-based-programming) runtime. It integrates with other FBP tools like the Flowhub visual programming IDE. This library makes it easy to create MsgFlo participants in Python.

msgflo-python is built on top of gevent. It uses Haigha for AMQP support and Eclipse Paho for MQTT.

Status

In production

  • Support for MQTT 3.1.1, incl TLS
  • Support for AMQP 0.9.0 / RabbitMQ
  • Support for Python 3.5+ and Python 2.7+

Changelog

License

MIT, see ./LICENSE

Installing

Get it from PyPi

pip install msgflo --user

Usage

See ./examples/repeat.py

wget https://github.com/msgflo/msgflo-python/raw/master/examples/repeat.py
# Set address of broker to connect to. Can also be amqp://...
export MSGFLO_BROKER=mqtt://localhost
python ./repeat.py