一种日志处理方法及装置

摘要

本发明公开了一种日志处理方法及装置，对不同的实时性处理需求，采用不同的方式处理相应的日志信息，实现对日志信息的实时快速处理与非实时高效处理的目的。所述日志处理方法包括：将节目播放日志实时记录到Kafka中；根据实时统计指令从所述Kafka中记录的日志中读取所述实时统计指令所指信息并对读取的信息实时处理；并按照预设的时间周期，从所述Kafka中记录的日志中读取离线统计相关信息并将其写入Hadoop分布式文件系统中进行离线处理；其中，所述预设的时间周期小于所述Kafka中日志删除的时间周期。该方法能够根据实际处理需求，读取相应的日志信息，实现对日志信息的实时与非实时的高效处理。

主权项

一种日志处理方法，其特征在于，包括：将节目播放日志实时记录到Kafka中；根据实时统计指令从所述Kafka中记录的日志中读取所述实时统计指令所指信息并对读取的信息实时处理；并按照预设的时间周期，从所述Kafka中记录的日志中读取离线统计相关信息并将其写入Hadoop分布式文件系统中进行离线处理；其中，所述预设的时间周期小于所述Kafka中日志删除的时间周期。