[發明專利]基于Lambda框架的直播數據處理方法、系統、服務器及裝置

有效

• 申請號: 201811141860.1
• 申請日: 2018-09-28
• 公開（公告）號: CN110971917B
• 公開（公告）日: 2021-10-22
• 發明（設計）人: 王灼
• 申請（專利權）人: 廣州虎牙信息科技有限公司
• 主分類號: H04N21/2187
• 分類號: H04N21/2187;H04N21/23;H04N21/266;G06F8/60
• 代理公司: 深圳市威世博知識產權代理事務所(普通合伙) 44280
• 代理人: 李慶波

1.一種基于Lambda框架的直播數據處理方法，應用于直播系統中的服務器，所述直播數據處理方法包括：

將預設功能寫入所述Lambda框架；

監測直播系統的直播數據是否發生變更；

若是，將所述直播數據發送至所述Lambda框架以觸發所述Lambda框架，通過所述Lambda框架調用所述預設功能對所述直播數據進行計算處理，得到計算數據；

將經所述Lambda框架處理后的所述計算數據發送到存儲系統中；

響應客戶端的調用接口指令，提取所述存儲系統中的所述計算數據發送至所述客戶端。

2.根據權利要求1所述的直播數據處理方法，其特征在于：所述預設功能包括排序功能，所述直播數據包括人氣數據、直播間類型數據、游戲類型數據；

所述觸發所述Lambda框架，通過Lambda框架調用所述預設功能對所述直播數據進行計算處理，得到計算數據的步驟包括：

通過所述Lambda框架調用所述排序功能對所述人氣數據、所述直播間類型數據、所述游戲類型數據的至少一種進行計算處理，以得到呈Json結構排序的所述計算數據。

3.根據權利要求1所述的直播數據處理方法，其特征在于：所述監測直播系統的直播數據是否發生變更的步驟包括：

將所述直播系統的直播數據與預設訂閱服務關聯，以通過預設訂閱服務監測所述直播數據是否發生變更；

所述觸發所述Lambda框架，通過所述Lambda框架調用所述預設功能對所述直播數據進行計算處理，得到計算數據的步驟包括：

在所述直播數據發生變更時，將變更消息推送到所述預設訂閱服務，所述訂閱服務將所述直播數據的數據流寫入到K inesis框架進行實時數據流計算以觸發所述Lambda框架。

4.根據權利要求3所述的直播數據處理方法，其特征在于：所述預設訂閱服務包括SNS服務和SQS隊列，其中SNS服務包括多個子訂閱主題，所述在所述直播數據發生變更時，將變更消息推送到所述預設訂閱服務，所述訂閱服務將所述直播數據的數據流寫入到K inesis框架進行實時數據流計算以觸發所述Lambda框架的步驟包括：

將所述變更消息發送到所述SNS服務以生成隊列消息，并將所述隊列消息通過相應的所述子訂閱主題推送至所述SQS隊列；

所述SQS隊列將所述直播數據以數據流的形式寫入到所述Kinesis框架進行實時數據流計算以觸發所述Lambda框架。

5.根據權利要求1所述的直播數據處理方法，其特征在于：所述存儲系統是Redis型存儲系統和/或Mysql型存儲系統。

6.一種基于L ambda框架的直播數據處理方法，應用于直播系統，其特征在于，所述直播系統包括服務器、分別與所述服務器連接的存儲系統和客戶端，所述處理方法包括：

所述服務器將預設功能寫入所述Lambda框架；

所述服務器監測所述直播系統的直播數據是否發生變更；

若是，所述服務器將所述直播數據發送至所述Lambda框架以觸發所述Lambda框架，通過所述Lambda框架調用所述預設功能對所述直播數據進行計算處理，得到計算數據；

所述服務器將經所述Lambda框架處理后的所述計算數據發送到存儲系統中；

所述客戶端發送調用接口指令給所述服務器；

所述服務器根據所述調用接口指令提取所述存儲系統中的所述計算數據發送至所述客戶端。