本申请涉及一种流式数据处理方法和装置，其中，本申请设置在SQL引擎中，SQL引擎内部不设置任何固定的计算流程，只提供预存的SQL配置来提供模块化的计算机制，SQL引擎的具体计算业务全部由外部的SQL语句输入，SQL引擎内部将根据SQL语句中的SQL命令以及逻辑关键词，利用预存的SQL节点配置进行组合，生成SQL图，用于表达输入的SQL语句的语义；利用SQL图进行待处理流式数据的处理，输出处理后流式数据，极大地提高了计算效率，避免了相关技术由于SQL命令增多利用流式数据去遍历SQL语句造成的计算效率低的问题。