1.一种数据写入的方法,其特征在于,所述方法应用于直播平台服务器,包括:持续监测客户端用户播放视频的事件,如果监测到用户播放视频,则获取所述视频的播放数据,并将所述播放数据存入统计队列,其中,所述统计队列中的数据按照存入的先后顺序排列;
通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道;
通过第二异步协程监控所述管道中的数据,如果所述管道中的数据满足预设要求,则将所述管道中的所述播放数据按所述先后顺序依次写入数据库;
所述通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道,包括:
如果所述统计队列所占用的存储空间达到预设空间,则通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道;
所述如果所述管道中的数据满足预设要求,包括:如果所述管道中的数据量大于预设数据量;或者,如果所述管道中导入数据的频率大于预设频率;或者,如果距上次所述管道将所述播放数据写入数据库的时长大于预设时长。
2.如权利要求1所述的方法,其特征在于,所述播放数据包括以下任意一种或多种:播放次数、播放视频的用户信息、播放视频的主播信息或播放视频的时间信息。
3.如权利要求1所述的方法,其特征在于,所述将所述管道中的所述播放数据按所述先后顺序依次写入数据库,包括:
将所述管道中的所述播放数据按所述先后顺序依次写入数据库,其中,在所述写入数据库的过程中,主协程通过监听信号量来判断所述写入是否完成,并在所述主协程确定所述写入完成后,控制所述主协程、所述第一异步协程和所述第二异步协程退出。
4.如权利要求1所述的方法,其特征在于:在所述通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道之后,还包括:删除所述统计队列中存储的所述播放数据;
在所述将所述管道中的所述播放数据按所述先后顺序依次写入数据库之后,还包括:删除所述管道中存储的所述播放数据。
5.一种数据写入的装置,其特征在于,所述装置为直播平台服务器,包括:监测模块,用于持续监测客户端用户播放视频的事件,如果监测到用户播放视频,则获取所述视频的播放数据,并将所述播放数据存入统计队列,其中,所述统计队列中的数据按照存入的先后顺序排列;
导入模块,用于通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道;
所述通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道,包括:
如果所述统计队列所占用的存储空间达到预设空间,则通过第一异步协程将所述统计队列中的所述播放数据按所述先后顺序导入管道;
写入模块,用于通过第二异步协程监控所述管道中的数据,如果所述管道中的数据满足预设要求,则将所述管道中的所述播放数据按所述先后顺序依次写入数据库;
所述如果所述管道中的数据满足预设要求,包括:如果所述管道中的数据量大于预设数据量;或者,如果所述管道中导入数据的频率大于预设频率;或者,如果距上次所述管道将所述播放数据写入数据库的时长大于预设时长。
6.如权利要求5所述的装置,其特征在于,还包括:监听模块,用于在所述写入数据库的过程中,主协程通过监听信号量来判断所述写入是否完成,并在所述主协程确定所述写入完成后,控制所述主协程、所述第一异步协程和所述第二异步协程退出。
7.一种直播平台服务器,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,其特征在于,所述处理器执行所述程序时实现权利要求1‑4任一所述的方法。
8.一种计算机可读存储介质,其上存储有计算机程序,其特征在于,该程序被处理器执行时实现权利要求1‑4任一所述的方法。