数据接收:实时接收和解码消息文件(.txt)

在我们的项目中,我们有一个实时读取和解码消息文本文件的要求。这些文件由使用MQ设置的第三方接收。需求是从MQ服务器中提取文件,将其存储在我们的系统中,使用spec进行解码,并将数据存储在数据库表中。

消息文件(.txt)-->MQ服务器-->??-->解码-->存储在数据库中

问题:

2. 我们已经有了一个Python的源代码来解码文件,但是不确定如何在文件被推送到我们这边时实时地进行端到端的处理。