基于分布式流计算的背压处理方法和系统

摘要

本发明涉及一种基于分布式流计算的背压处理方法和系统，该方法包括：接收上游计算节点发送的流数据并存储于流数据池中，流数据池中的流数据在本地进行流计算时被消耗；统计流数据池中的流数据占流数据池的总容量的数据占比；若统计的数据占比大于或等于第一阈值，则执行增加背压标记的操作；增加背压标记的操作用于使上游计算节点降低流数据发送速率；若统计的数据占比小于或等于第二阈值，则执行删除背压标记的操作；第二阈值小于第一阈值；删除背压标记的操作用于使上游计算节点提高流数据发送速率。本发明提供的基于分布式流计算的背压处理方法和系统，可以克服背压问题并保证流计算效率。