通过消息总线原子发送消息(信号)的flask sqlalchemy扩展
Flask-SignalBus的Python项目详细描述
向flask sqlalchemy添加原子发送消息的功能 (信号)通过消息总线。
每条消息的处理包括三个步骤:
- The message is recorded in the SQL database as a row in a table.
- The message is sent over the message bus (RabbitMQ for example).
- Message’s corresponding table row is deleted.
正常情况下,已记录消息的发送(步骤2和3)完成 在每次事务提交后自动执行,但在需要时,它可以 也可以通过方法调用或通过烧瓶显式触发 克利。