1.一种数据监控方法,其特征在于,包括:
获取待处理数据队列及所述待处理数据队列中待处理数据的时间标识;
根据所述待处理数据的时间标识判断所述待处理数据队列是否满足预先设置的数据预警条件;
若判断出所述待处理数据队列满足所述数据预警条件,则发送数据处理预警信号。
2.根据权利要求1所述的方法,其特征在于,
所述获取待处理数据队列及所述待处理数据队列中待处理数据的时间标识包括:在预定时刻从待处理数据集合中获取所述待处理数据队列,并获取所述待处理数据队列中第一条待处理数据进入所述待处理数据集合的第一时间标识及最后一条待处理数据进入所述待处理数据集合的第二时间标识,其中,所述待处理数据集合用于保存所述待处理数据,以便所述待处理数据被读取处理;
所述根据所述待处理数据的时间标识判断所述待处理数据队列是否满足预先设置的数据预警条件包括:利用所述第一条待处理数据的所述第一时间标识及所述最后一条待处理数据的所述第二时间标识,计算所述第一条待处理数据及所述最后一条待处理数据的时间差;
根据所述时间差判断所述待处理数据队列是否满足所述数据预警条件。
3.根据权利要求2所述的方法,其特征在于,所述根据所述时间差判断所述待处理数据队列是否满足所述数据预警条件包括:判断所述时间差是否大于等于预定阈值,其中,所述预定阈值至少根据所述待处理数据的处理速度配置。
4.根据权利要求2所述的方法,其特征在于,在所述获取待处理数据队列及所述待处理数据队列中待处理数据的时间标识之前,还包括:接收用于获取所述待处理数据队列的获取请求;
响应所述获取请求对所述预定时刻的所述待处理数据集合执行锁定操作,以从所述待处理数据集合中得到所述待处理数据队列,其中,所述锁定操作用于控制所述待处理数据集合在所述预定时刻不再接收更新的待处理数据,且不对所述待处理数据进行读取处理。
5.根据权利要求1所述的方法,其特征在于,在发送数据处理预警信号之后,还包括:调整加快对所述待处理数据的处理速度,以减少所述待处理数据队列中的所述待处理数据。
6.一种数据监控装置,其特征在于,包括:
获取单元,用于获取待处理数据队列及所述待处理数据队列中待处理数据的时间标识;
判断单元,用于根据所述待处理数据的时间标识判断所述待处理数据队列是否满足预先设置的数据预警条件;
发送单元,用于在判断出所述待处理数据队列满足所述数据预警条时件,发送数据处理预警信号。
7.根据权利要求6所述的装置,其特征在于,
所述获取单元包括:获取模块,用于在预定时刻从待处理数据集合中获取所述待处理数据队列,并获取所述待处理数据队列中第一条待处理数据进入所述待处理数据集合的第一时间标识及最后一条待处理数据进入所述待处理数据集合的第二时间标识,其中,所述待处理数据集合用于保存所述待处理数据,以便所述待处理数据被读取处理;
所述判断单元包括:
计算模块,用于利用所述第一条待处理数据的所述第一时间标识及所述最后一条待处理数据的所述第二时间标识,计算所述第一条待处理数据及所述最后一条待处理数据的时间差;
判断模块,用于根据所述时间差判断所述待处理数据队列是否满足所述数据预警条件。
8.根据权利要求7所述的装置,其特征在于,所述判断模块包括:判断子模块,用于判断所述时间差是否大于等于预定阈值,其中,所述预定阈值至少根据所述待处理数据的处理速度配置。
9.根据权利要求7所述的装置,其特征在于,还包括:
接收单元,用于在所述获取待处理数据队列及所述待处理数据队列中待处理数据的时间标识之前,接收用于获取所述待处理数据队列的获取请求;
锁定单元,用于响应所述获取请求对所述预定时刻的所述待处理数据集合执行锁定操作,以从所述待处理数据集合中得到所述待处理数据队列,其中,所述锁定操作用于控制所述待处理数据集合在所述预定时刻不再接收更新的待处理数据,且不对所述待处理数据进行读取处理。
10.根据权利要求6所述的装置,其特征在于,还包括:
调整单元,用于在发送数据处理预警信号之后,调整加快对所述待处理数据的处理速度,以减少所述待处理数据队列中的所述待处理数据。