Skip to main content

A Flask-SQLAlchemy extension for atomically sending messages (signals) over a message bus

Project description

Adds to Flask-SQLAlchemy the capability to atomically send messages (signals) over a message bus.

The processing of each message involves three steps:

  1. The message is recorded in the SQL database as a row in a table.

  2. The message is sent over the message bus (RabbitMQ for example).

  3. Message’s corresponding table row is deleted.

Normally, the sending of the recorded messages (steps 2 and 3) is done automatically after each transaction commit, but when needed, it can also be triggered explicitly with a method call, or through the Flask CLI.

Download files

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

Source Distribution

Flask-SignalBus-0.5.1.tar.gz (23.0 kB view hashes)

Uploaded source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page