I think it is hard to say without a a lot more context. If you are a talking about generating a pipeline for every incoming message, that seems like a lot of overhead to me, and you should probably just be doing that type of thing in vanilla python.