一种业务处理的方法、装置及系统

摘要

本发明公开了一种业务处理的方法，工作节点获取主控节点调度的流式计算应用模型中的算子，所述流式计算应用模型中的算子和所述算子之间的数据流走向构成至少一个迭代环，并且每个迭代环的出口算子上都配置有所述每个迭代环对应的迭代次数，所述出口算子为所述每个迭代环中数据流走向上的最后一个算子，接收所述业务的数据，根据所述每个算子所承载的部分处理逻辑对所述业务的数据进行处理，在根据每个出口算子的部分处理逻辑，确定到所述业务的数据的迭代次数已达到所述每个出口算子所在的迭代环的迭代次数时，则将所述业务的数据从所述每个出口算子输出。本发明实施例提供的业务处理的方法，可以降低数据的处理时延，提高数据处理的实时性。

主权项

一种业务处理的方法，其特征在于，所述方法应用于流计算系统中的工作节点，所述流计算系统还包括主控节点，所述主控节点根据流式计算应用模型调度一个或多个算子到所述工作节点，以处理业务的数据，所述方法包括：所述工作节点获取所述主控节点调度的算子，所述流式计算应用模型为针对所述业务预先建立的包含算子和算子间数据流走向的逻辑关系图，每个算子用于承载所述业务对应的处理逻辑中的部分处理逻辑，所述流式计算应用模型中的算子和所述算子之间的数据流走向构成至少一个迭代环，并且每个迭代环的出口算子上都配置有所述每个迭代环对应的迭代次数，所述出口算子为所述每个迭代环中数据流走向上的最后一个算子，所述每个迭代环对应的迭代次数表示所述业务的数据在所述每个迭代环中需要被迭代处理的次数；接收所述业务的数据；根据所述每个算子所承载的部分处理逻辑对所述业务的数据进行处理，在根据每个出口算子的部分处理逻辑，确定到所述业务的数据的迭代次数已达到所述每个出口算子所在的迭代环的迭代次数时，则将所述业务的数据从所述每个出口算子输出。