本申请提出了一种基于分布式架构的非结构化文件的流处理方法，该方法包括如下步骤：获取非结构化文件，将所述非结构化文件放入到FTP或MinIO中；设计基于Flink架构的FTP连接器或者MinIO连接器读取所述非结构化文件；基于Flink的分布式部署对所述非结构化文件进行动态处理，并将处理所述非结构化文件的进度信息记录并保存；在所述FTP连接器或者MinIO连接器中集成Format处理器，对所述非结构化文件进行解析及处理；编写Flink SQL将处理后的数据写入存储库。通过采用Flink的分布式架构，以流的形式读取大量并不断产生的非结构化文件，将流处理中的特性应用到非结构化文件的处理中，不影响整体的同时提高可扩展性，保证架构稳定性；利用编写SQL实现对文件的处理，降低开发门槛及成本。