华体会科技有限公司_华体会体育官方网站_华体会HTH数据服务

　　1、在直播过程中，为了方便在业务层面上对最新的直播推流数据进行处理，一般会通过采集系统从流媒体服务器中采集直播推流数据，然后通过消息队列组件存储从流媒体服务器中采集到的直播推流数据，之后，可以对消息队列组件中存储的直播推流数据进行业务层面上的处理。通过上述方式，可以实现对最新的直播推流数据的数据采集和数据存储的组件解耦。

　　2、然而，发明人发现，一旦消息队列组件出现故障，在业务层上将无法再对最新的直播推流数据进行处理。

　　2、本技术提供了一种直播数据处理平台，所述直播数据处理平台包括流媒体服务器、流媒体数据采集系统、消息队列、第一数据处理系统、第二数据处理系统、第一数据存储系统及第二数据存储系统，其中：

　　4、所述流媒体数据采集系统，用于从所述流媒体服务器中采集所述直播推流数据，并在每采集到一条直播推流数据后，在采集到的直播推流数据中添加采集时间戳；

　　5、所述流媒体数据采集系华体会统，还用于将添加有采集时间戳的直播推流数据投递至所述消息队列中，以及通过预设投递方式将添加有采集时间戳的直播推流数据投递至所述第一数据存储系统中；

　　6、所述第一数据处理系统，用于从所述消息队列中消费数据，并将消费到的数据存储至所述第二数据存储系统中，以及根据消费到的数据中包含的第一直播流名以及采集时间戳对所述第二数据存储系统中存储的与所述第一直播流名匹配的直播流的在推时间进行更新；

　　7、所述第二数据处理系统，用于消费通过所述预设投递方式投递的数据，并将消费到的数据存储至所述第一数据存储系统中，以及根据消费到的数据中包含的第二直播流名以及采集时间戳对所述第一数据存储系统中存储的与所述第二直播流名匹配的直播流的在推时间进行更新。

　　8、可选地，所述直播数据处理平台还包括数据汇聚系统，所述数据汇聚系统用于：

　　9、从所述第一数据存储系统与所述第二数据存储系统中获取各个直播流的在推时间；

　　10、根据从所述第一数据存储系统与所述第二数据存储系统获取到的各个直播流的在推时间确定各个所述直播流的最新在推时间。

　　11、可选地，所述流媒体数据采集系统包括数据采集指令发送模块，数据采集模块及采集时间戳添加模块，其中：

　　12、数据采集指令发送模块，用于向所述流媒体服务器发送数据采集指令，所述数据采集指令中携带有待采集直播流的第三直播流名，其中，所述流媒体服务器在接收到所述数据采集指令后，将与所述第三直播流名匹配的直播推流数据传输至所述流媒体数据采集系统；

　　14、所述采集时间戳添加模块，用于在所述数据采集模块每采集到一条直播推流数据后，在采集到的直播推流数据中添加采集时间戳。

　　15、可选地，所述采集时间戳添加模块，还用于在所述数据采集模块每采集到一条直播推流数据后，获取ntp时间，并将所述ntp时间作为所述采集时间戳添加至采集到的直播推流数据中。

　　16、可选地，所述预设投递方式为远程过程调用的方式，所述流媒体数据采集系统，还用于通过远程过程调用的方式将添加有采集时间戳的直播推流数据投递至所述第一数据存储系统中。

　　17、可选地，所述第一数据存储系统与所述第二数据存储系统皆为redis数据库。

　　18、可选地，所述流媒体服务器具有多个，所述流媒体数据采集系统，还用于从多个所述流媒体服务器中采集所有处于直播状态中的主播的直播推流数据。

　　19、本技术还提供了一种直播数据处理方法，应用于直播数据处理平台中，所述直播数据处理平台包括流媒体服务器、流媒体数据采集系统、消息队列、第一数据处理系统、第二数据处理系统、第一数据存储系统及第二数据存储系统，所述方法包括：

　　20、所述流媒体数据采集系统从所述流媒体服务器中采集其中存储的主播的直播推流数据，并在每采集到一条直播推流数据后，在采集到的直播推流数据中添加采集时间戳；

　　21、所述流媒体数据采集系统将添加有采集时间戳的直播推流数据投递至所述消息队列中，以及所述流媒体数据采集系统通过预设投递方式将添加有采集时间戳的直播推流数据投递至所述第一数据存储系统中；

　　22、所述第一数据处理系统从所述消息队列中消费数据，并将消费到的数据存储至所述第二数据存储系统中，以及所述第一数据处理系统根据消费到的数据中包含的第一直播流名以及采集时间戳对所述第二数据存储系统中存储的与所述第一直播流名匹配的直播流的在推时间进行更新；

　　23、所述第二数据处理系统消费通过所述预设投递方式投递的数据，并将消费到的数据存储至所述第一数据存储系统中，以及所述第二数据处理系统根据消费到的数据中包含的第二直播流名以及采集时间戳对所述第一数据存储系统中存储的与所述第二直播流名匹配的直播流的在推时间进行更新。

　　25、所述数据汇聚系统从所述第一数据存储系统与所述第二数据存储系统中获取各个直播流的在推时间；

　　26、所述数据汇聚系统根据从所述第一数据存储系统与所述第二数据存储系统获取到的各个直播流的在推时间确定各个所述直播流的最新在推时间。

　　27、可选地，所述流媒体数据采集系统从所述流媒体服务器中采集其中存储的主播的直播推流数据，并在每采集到一条直播推流数据后，在采集到的直播推流数据中添加采集时间戳包括：

　　28、所述流媒体数据采集系统向所述流媒体服务器发送数据采集指令，所述数据采集指令中携带有待采集直播流的第三直播流名，其中，所述流媒体服务器在接收到所述数据采集指令后，将与所述第三直播流名匹配的直播推流数据传输至所述流媒体数据采集系统；

　　30、所述流媒体数据采集系统每采集到一条直播推流数据后，在采集到的直播推流数据中添加采集时间戳。

　　31、本技术中的直播数据处理平台，通过将流媒体数据采集系统采集到的流媒体数据通过双数据链路传递，实现了最新的直播推流数据的双链路生产，这样即使消息队列组件出现故障，也可以对最新的直播推流数据进行处理，保障了最新的直播推流数据的高可用性和稳定性。此外，本技术中的直播数据处理平台通过在将直播推流数据存储至第一数据存储系统与第二数据存储系统时，都会对直播流最新的在推时间进行更新，这样，当需要获取最新的直播推流数据时，可以根据第一数据存储系统与第二数据存储系统中存储的直播流的在推时间来确定最新的直播推流数据存储至哪个数据存储系统中，后续需要对最新的直播推流数据进行处理时，可以及时获取到该最新的直播推流数据。