本公开的实施例提供了一种数据流处理的方法、电子设备和计算机程序产品，该方法包括：响应于针对输入数据流的查询请求，确定针对输入数据流中的输入数据项的数据标签，数据标签至少指示输入数据项与查询请求的第一查询条件之间的第一匹配关系；确定与输入数据流相对应的输出数据流，输出数据流包括与输入数据项相对应的输出数据项，并且每个输出数据项均具有数据标签；以及基于输出数据流，确定查询请求相对应的查询信息。以此方式，能够响应对于数据流的实时查询请求。