I'm developing an application to simulate the vehicle HMI, which has the main functionality of interacting with the ECU module which basically sends and receives the raw CAN data. In the application, I'm using the "python-can" library to create a CAN bus instance on which it sends and receives the CAN data. The other flow is to parse the received raw CAN data and publish it to the MQTT broker. The application has to also subscribe to certain topics from the MQTT broker.

I tried creating a new thread for all different modules and wrote the CAN module with the help of asyncio library. It would be a great help if there is a good and ideal architecture for the above problem.