一种基于流式计算引擎的实时数据处理方法及装置

摘要

本发明提供一种基于流式计算引擎的实时数据处理方法及装置，方法包括：创建Storm的消息队列；将数据存入数据库中，并备份至所述Storm的消息队列；Storm中的Spout实时监听所述消息队列，在监听到有数据被存入所述Storm的消息队列时，拉取所述Storm的消息队列中当前被存入的数据，并将拉取的数据发送给Storm中的Bolt；Bolt根据预先获取的逻辑规则，对所述拉取的数据进行逻辑处理，以将逻辑处理后的数据更新到所述数据库中。根据本方案，至少能够实现数据处理的实时性。