一种数据处理的方法、装置及系统

摘要

本申请公开了一种数据处理的方法、装置及系统，用以解决现有技术中对数据处理的实时性和可扩展性差的问题。该方法处理节点在协调服务器中获取为该处理节点配置的每个数据处理任务，接收上一级处理节点输出的每个数据流，根据获取的数据处理任务对应的输入条件，在接收到的每个数据流包含的数据中，提取符合输入条件的数据，根据该数据处理任务对应的处理逻辑，对提取的数据进行处理，当判断存在下一级处理节点时，将处理后的数据发送给下一级处理节点处理，否则将处理后的数据作为处理结果输出，提高了处理数据的实时性，提高了数据处理的系统的可扩展性。

主权项

一种数据处理的方法，其特征在于，包括：每级处理节点在协调服务器中获取分别为所述每级处理节点配置的每个数据处理任务，其中，数据处理任务包括该数据处理任务对应的输入条件和处理逻辑；所述每级处理节点接收至少一个上一级处理节点输出的每个数据流；并针对获取的每个数据处理任务，根据该数据处理任务对应的输入条件，在接收到的所述至少一个上一级处理节点输出的每个数据流包含的数据中，提取符合该输入条件的数据；以及根据该数据处理任务对应的处理逻辑，对提取的数据进行处理；所述每级处理节点判断是否存在下一级处理节点，若存在，则将处理后的数据发送给下一级处理节点进行处理，否则，将处理后的数据作为处理结果输出；所述根据该数据处理任务对应的输入条件，在接收到的所述至少一个上一级处理节点输出的每个数据流包含的数据中，提取符合所述输入条件的数据，具体包括：根据该数据处理任务对应的输入条件中包含的数据流标识信息，在接收到的所述至少一个上一级处理节点输出的每个数据流中，确定该输入条件中包含的数据流标识信息对应的数据流；并根据该数据处理任务对应的输入条件中包含的数据的属性信息，在确定出的数据流中提取具有所述属性信息的数据。