I'm looking for a library that does what https://symfony.com/doc/current/messenger.html can do, but in python. We have a setup with fast api and would like to use some message bus setup, that can conveniently be async and delayed when it needs to be. I know about celery of course. I like it, but it's a bit more low level than the Symfony Messenger. I really like the interface and how it's setup in symfony. Is there a library in python that I can add to my setup where I can just have a message bus class where I can .dispatch(Envelope(my_message_class_instance)) and somewhere specify that MyMessageClass should be async. So that it gets handled by some async transport? I am happy to implement the async side myself, but I struggle to find a OOP based message bus library like the default in Symfony. Continue reading...
