动态流标识处理方法、装置、设备、存储介质和程序产品与流程

本技术实施例涉及直播流媒体处理，尤其涉及一种动态流标识处理方法、装置、计算机设备、计算机可读存储介质和计算机程序产品。

背景技术：

1、在网络直播场景中，推流端通常通过推流地址将直播流推送至边缘节点，播放端可以通过拉流地址获取对应直播内容。推流地址和拉流地址中通常包括用于标识直播流来源和归属的流标识。随着加密直播、资源权限直播、专属权限直播、企业内部直播等特殊直播场景的增加，直播流标识除用于区分不同直播流之外，还可能需要与直播场景、处理属性、权限状态和时效状态等信息协同使用。在相关直播流管理方式中，流标识通常与直播间存在绑定关系，业务属性可以通过附加标签或外部权限信息进行管理。在特殊直播场景下，若边缘节点不能及时感知流标识的状态变化，或者不同场景下直播流处理逻辑不一致，可能影响直播流处理链路中标识、属性和状态信息之间的协同处理。

2、需要说明的是，上述内容并不必然是现有技术，也不用于限制本技术的专利保护范围。

技术实现思路

1、本技术实施例提供一种动态流标识处理方法、装置、计算机设备、计算机可读存储介质和计算机程序产品，以解决或缓解上述技术问题中的一项或多项。

2、本技术实施例的一个方面提供了一种动态流标识处理方法，应用于直播流管理系统，所述方法包括：

3、获取目标直播间对应的特殊直播场景信息以及与所述特殊直播场景信息对应的业务属性信息；

4、基于所述特殊直播场景信息，生成目标动态流标识；

5、建立所述目标动态流标识与所述业务属性信息之间的关联关系；

6、为所述目标动态流标识配置生命周期状态信息；

7、生成并输出目标动态流标识管理信息，所述目标动态流标识管理信息包括所述目标动态流标识、所述关联关系以及所述生命周期状态信息。

8、可选地，基于所述特殊直播场景信息，生成目标动态流标识，包括：

9、确定与所述特殊直播场景信息对应的场景标识信息；

10、获取所述目标直播间的直播间标识信息和流标识生成时间信息；

11、生成随机标识信息；

12、基于所述场景标识信息、所述直播间标识信息、所述流标识生成时间信息和所述随机标识信息，生成待校验流标识；

13、基于所述待校验流标识生成校验信息；

14、将所述校验信息与所述待校验流标识进行组合，得到所述目标动态流标识。

15、可选地，建立所述目标动态流标识与所述业务属性信息之间的关联关系，包括：

16、从所述业务属性信息中确定轻量属性信息和全量属性信息；

17、将所述轻量属性信息配置为能够由所述目标动态流标识解析得到的信息；

18、建立所述目标动态流标识与所述全量属性信息之间的映射关系；

19、基于所述目标动态流标识和所述全量属性信息生成映射校验信息；

20、将所述映射校验信息与所述映射关系关联存储，所述映射校验信息用于对所述目标动态流标识与所述全量属性信息之间的对应关系进行一致性校验。

21、可选地，为所述目标动态流标识配置生命周期状态信息，包括：

22、获取与所述特殊直播场景信息对应的生命周期规则；

23、基于所述生命周期规则，确定所述目标动态流标识的有效期信息和失效触发条件；

24、基于所述有效期信息和所述失效触发条件，生成所述生命周期状态信息；

25、其中，所述失效触发条件包括所述目标动态流标识超出对应有效期、所述目标直播间对应的直播结束、所述目标直播间的直播场景发生切换以及与所述业务属性信息对应的属性状态发生变更中的至少一种。

26、可选地，所述方法还包括：

27、在检测到所述目标直播间的直播场景由第一直播场景切换为第二直播场景的情况下，生成与所述第二直播场景对应的新动态流标识；

28、建立所述新动态流标识与所述第二直播场景对应的业务属性信息之间的关联关系；

29、将所述目标动态流标识的生命周期状态信息更新为失效状态；

30、输出所述新动态流标识以及所述目标动态流标识的失效状态信息。

31、可选地，所述方法还包括：

32、接收场景配置数据，所述场景配置数据包括场景标识配置数据、流标识结构配置数据、属性字段配置数据、鉴权规则配置数据和生命周期规则配置数据中的至少一种；

33、基于所述场景配置数据生成场景流标识管理规则；

34、基于所述场景流标识管理规则，执行对应特殊直播场景下的动态流标识生成、属性关联和生命周期状态配置。

35、可选地，所述方法还包括：

36、在所述目标动态流标识的生命周期状态信息表征失效状态的情况下，将所述目标动态流标识加入失效流标识队列；

37、基于失效时间信息，对所述失效流标识队列中的动态流标识进行排序；

38、基于预设清理批量和数据存储负载状态，从所述失效流标识队列中确定待清理动态流标识；

39、对所述待清理动态流标识执行清理处理或备份后清理处理。

40、可选地，输出目标动态流标识管理信息，包括：

41、向直播调度系统输出所述目标动态流标识和所述生命周期状态信息，以供所述直播调度系统生成包含所述目标动态流标识的推流地址；

42、其中，所述推流地址包括边缘节点地址信息、端口信息、所述目标动态流标识、鉴权信息和流标识时效信息。

43、可选地，输出目标动态流标识管理信息，包括：

44、将所述目标动态流标识对应的当前活跃数据写入第一数据存储单元；

45、将所述目标动态流标识对应的全量数据写入第二数据存储单元；

46、将所述目标动态流标识对应的日志数据写入第三数据存储单元；

47、将所述目标动态流标识与所述业务属性信息对应的映射校验信息写入第四数据存储单元。

48、可选地，所述特殊直播场景信息包括加密直播场景信息、资源权限直播场景信息、专属权限直播场景信息、企业内部直播场景信息、临时授权直播场景信息和多清晰度直播场景信息中的至少一种。

49、本技术实施例的另一个方面提供了一种动态流标识处理方法，应用于边缘节点，所述方法包括：

50、接收携带目标动态流标识的直播流处理事件；

51、解析所述目标动态流标识，得到所述目标动态流标识对应的场景标识信息；

52、获取所述目标动态流标识对应的状态信息和业务属性信息；

53、基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权；

54、根据所述流标识鉴权的鉴权结果，对所述直播流处理事件执行接入处理、分发处理、终止处理或告警处理。

55、可选地，解析所述目标动态流标识，得到所述目标动态流标识对应的场景标识信息之后，所述方法还包括：

56、基于所述场景标识信息，确定所述直播流处理事件对应的直播场景类型；

57、基于所述直播场景类型，确定所述直播流处理事件对应的处理通道；

58、将所述直播流处理事件分配至所述处理通道。

59、可选地，获取所述目标动态流标识对应的状态信息和业务属性信息，包括：

60、查询所述边缘节点的本地流标识状态缓存；

61、在所述本地流标识状态缓存中存在所述目标动态流标识对应的可用缓存数据的情况下，基于所述可用缓存数据确定所述状态信息和/或所述业务属性信息；

62、在所述本地流标识状态缓存中不存在所述可用缓存数据的情况下，向中心机房数据系统发送数据查询请求；

63、接收所述中心机房数据系统返回的查询结果，并基于所述查询结果确定所述状态信息和/或所述业务属性信息。

64、可选地，基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权，包括：

65、基于所述直播流处理事件的事件类型和处理阶段，确定所述目标动态流标识对应的目标鉴权阶段；

66、基于所述目标鉴权阶段，确定所述流标识鉴权所需的鉴权数据；

67、基于所述鉴权数据，对所述直播流处理事件进行阶段鉴权；

68、其中，所述目标鉴权阶段包括推流前鉴权阶段、推流中鉴权阶段、拉流前鉴权阶段、拉流中鉴权阶段和传输中鉴权阶段中的至少一种。

69、可选地，基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权，包括：

70、确定所述目标动态流标识是否属于黑名单流标识；

71、在所述目标动态流标识属于黑名单流标识的情况下，拒绝所述直播流处理事件并生成异常请求告警信息；

72、在所述目标动态流标识不属于黑名单流标识的情况下，基于所述场景标识信息、所述状态信息和所述业务属性信息继续执行所述流标识鉴权。

73、可选地，基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权，包括：

74、在所述直播流处理事件为推流接入事件的情况下，获取所述推流接入事件携带的推流地址鉴权信息和时效信息，并基于所述目标动态流标识、所述推流地址鉴权信息和所述时效信息，对所述推流接入事件进行推流前鉴权；

75、在所述直播流处理事件为推流传输事件的情况下，获取所述推流传输事件对应的推流端标识信息，并基于所述推流端标识信息和所述目标动态流标识之间的绑定关系，对所述推流传输事件进行推流中鉴权。

76、可选地，基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权，包括：

77、在所述直播流处理事件为拉流接入事件的情况下，获取所述拉流接入事件对应的观看端标识信息，确定与所述场景标识信息对应的权限校验方式，并基于所述观看端标识信息、所述权限校验方式和所述业务属性信息，对所述拉流接入事件进行拉流前鉴权；

78、在所述直播流处理事件为拉流传输事件的情况下，基于所述状态信息，对所述拉流传输事件对应的拉流过程进行时效鉴权。

79、可选地，在所述直播流处理事件为属性校验事件的情况下，基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权，包括：

80、获取所述目标动态流标识对应的第一属性校验信息，所述第一属性校验信息基于所述边缘节点本地解析或缓存得到的业务属性信息生成；

81、从中心机房数据系统获取所述目标动态流标识对应的第二属性校验信息，所述第二属性校验信息基于所述中心机房数据系统存储的业务属性信息生成；

82、对所述第一属性校验信息和所述第二属性校验信息进行一致性校验；

83、在所述一致性校验未通过的情况下，终止所述目标动态流标识对应的直播流传输并生成属性异常告警信息。

84、可选地，根据所述流标识鉴权的鉴权结果，对所述直播流处理事件执行接入处理、分发处理、终止处理或告警处理，包括：

85、在所述鉴权结果表征鉴权通过的情况下，基于所述业务属性信息确定直播流处理策略；

86、基于所述直播流处理策略，对所述直播流处理事件对应的直播流执行接入、转码、加密、码率控制或分发中的至少一种处理；

87、在所述鉴权结果表征鉴权未通过的情况下，终止所述直播流处理事件，并生成与鉴权未通过原因对应的告警信息。

88、可选地，获取所述目标动态流标识对应的状态信息和业务属性信息，包括：

89、与中心机房数据系统建立状态同步连接；

90、通过所述状态同步连接获取状态变更信息，所述状态变更信息包括流标识失效状态、属性变更信息和黑名单流标识列表中的至少一种；

91、基于所述状态变更信息，更新本地流标识状态缓存；

92、在检测到所述状态同步连接中断的情况下，基于所述本地流标识状态缓存处理所述直播流处理事件；

93、在所述状态同步连接恢复的情况下，从所述中心机房数据系统获取全量状态信息，并基于所述全量状态信息更新所述本地流标识状态缓存。

94、本技术实施例的另一个方面提供了一种动态流标识处理装置，应用于直播流管理系统，所述装置包括：

95、获取模块，用于获取目标直播间对应的特殊直播场景信息以及与所述特殊直播场景信息对应的业务属性信息；

96、生成模块，用于基于所述特殊直播场景信息，生成目标动态流标识；

97、关联模块，用于建立所述目标动态流标识与所述业务属性信息之间的关联关系；

98、配置模块，用于为所述目标动态流标识配置生命周期状态信息；

99、输出模块，用于生成并输出目标动态流标识管理信息，所述目标动态流标识管理信息包括所述目标动态流标识、所述关联关系以及所述生命周期状态信息。

100、本技术实施例的另一个方面提供了一种动态流标识处理装置，应用于边缘节点，所述装置包括：

101、接收模块，用于接收携带目标动态流标识的直播流处理事件；

102、解析模块，用于解析所述目标动态流标识，得到所述目标动态流标识对应的场景标识信息；

103、获取模块，用于获取所述目标动态流标识对应的状态信息和业务属性信息；

104、鉴权模块，用于基于所述场景标识信息、所述状态信息和所述业务属性信息，对所述直播流处理事件进行流标识鉴权；

105、处理模块，用于根据所述流标识鉴权的鉴权结果，对所述直播流处理事件执行接入处理、分发处理、终止处理或告警处理。

106、本技术实施例的另一个方面提供了一种计算机设备，包括：

107、至少一个处理器；及

108、与所述至少一个处理器通信连接的存储器；

109、其中：所述存储器存储有可被所述至少一个处理器执行的计算机程序，所述计算机程序被所述至少一个处理器执行，以使所述至少一个处理器能够执行上述任一动态流标识处理方法。

110、本技术实施例的另一个方面提供了一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时实现上述任一动态流标识处理方法。

111、本技术实施例的另一个方面提供了一种计算机程序产品，包括计算机程序，所述计算机程序被处理器执行时实现上述任一动态流标识处理方法。

112、本技术实施例采用上述技术方案可以包括如下优势：

113、通过获取特殊直播场景信息和业务属性信息，基于特殊直播场景信息生成目标动态流标识，并建立目标动态流标识与业务属性信息之间的关联关系，使直播流标识能够与对应特殊直播场景及业务属性形成关联；通过为目标动态流标识配置生命周期状态信息并输出目标动态流标识管理信息，使直播调度、边缘处理或数据存储环节能够基于目标动态流标识、关联关系和生命周期状态信息进行后续处理。由此，可以降低直播流标识与特殊直播场景、业务属性和有效状态脱节导致的处理不一致风险，提高了特殊直播场景下直播流管理的稳定性。