本發(fā)明公開了一種消費數(shù)據(jù)的訂閱方法、裝置及存儲介質(zhì)。其中，該方法包括：在訂閱平臺接收到目標(biāo)用戶客戶端觸發(fā)的訂閱請求之后，接收訂閱平臺根據(jù)訂閱請求觸發(fā)的訂閱指令；響應(yīng)訂閱指令，確定目標(biāo)消費數(shù)據(jù)對應(yīng)的目標(biāo)數(shù)據(jù)屬性信息，其中，目標(biāo)數(shù)據(jù)屬性信息用于指示目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)類型、目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)數(shù)量、目標(biāo)消費數(shù)據(jù)的目標(biāo)推送對象；根據(jù)目標(biāo)數(shù)據(jù)類型、目標(biāo)數(shù)據(jù)數(shù)量，以及目標(biāo)推送對象對已存儲的消費數(shù)據(jù)進(jìn)行過濾，以得到目標(biāo)消費數(shù)據(jù)，并將目標(biāo)消費數(shù)據(jù)推送至目標(biāo)用戶客戶端。本發(fā)明解決了消費數(shù)據(jù)的訂閱效率較低的技術(shù)問題。

技術(shù)領(lǐng)域

本發(fā)明涉及計算機(jī)領(lǐng)域，具體而言，涉及一種消費數(shù)據(jù)的訂閱方法、 裝置及存儲介質(zhì)。

背景技術(shù)

Kafka是一種高吞吐量分布式發(fā)布訂閱消息系統(tǒng)，可以處理消費者在 網(wǎng)站中的所有動作流數(shù)據(jù)。

而現(xiàn)有技術(shù)中，為了能使得不同的人訂閱Kafka里面不同的消費數(shù)據(jù)， 消費者需訂閱不同的topic來訂閱這些消費數(shù)據(jù)，且需事先通過topic來實 現(xiàn)數(shù)據(jù)隔離。換言之，在消費數(shù)據(jù)的訂閱需基于訂閱不同的topic來實現(xiàn)， 而在消費者需訂閱的消費數(shù)據(jù)復(fù)雜程度較高的情況下，如多種組合的消費 數(shù)據(jù)，就需要消費者訂閱多種相同或不同的topic實現(xiàn)對上述消費數(shù)據(jù)的 訂閱，進(jìn)而導(dǎo)致消費數(shù)據(jù)的訂閱效率較低。

即，相關(guān)技術(shù)中存在消費數(shù)據(jù)的訂閱效率較低的問題。

針對上述的問題，目前尚未提出有效的解決方案。

發(fā)明內(nèi)容

本發(fā)明實施例提供了一種消費數(shù)據(jù)的訂閱方法、裝置及存儲介質(zhì)，以 至少解決消費數(shù)據(jù)的訂閱效率較低的技術(shù)問題。

根據(jù)本發(fā)明實施例的一個方面，提供了一種消費數(shù)據(jù)的訂閱方法，包 括：在訂閱平臺接收到目標(biāo)用戶客戶端觸發(fā)的訂閱請求之后，接收上述訂 閱平臺根據(jù)上述訂閱請求觸發(fā)的訂閱指令，其中，上述訂閱請求用于請求 為上述目標(biāo)用戶客戶端推送所訂閱的目標(biāo)消費數(shù)據(jù)；響應(yīng)上述訂閱指令， 確定上述目標(biāo)消費數(shù)據(jù)對應(yīng)的目標(biāo)數(shù)據(jù)屬性信息，其中，上述目標(biāo)數(shù)據(jù)屬 性信息用于指示上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)類型、上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)數(shù)量、上述目標(biāo)消費數(shù)據(jù)的目標(biāo)推送對象；根據(jù)上述目標(biāo)數(shù)據(jù)屬 性信息對已存儲的消費數(shù)據(jù)進(jìn)行過濾，以得到上述目標(biāo)消費數(shù)據(jù)，并將上 述目標(biāo)消費數(shù)據(jù)推送至上述目標(biāo)用戶客戶端。

根據(jù)本發(fā)明實施例的另一個方面，提供了一種消費數(shù)據(jù)的訂閱方法， 包括：接收目標(biāo)用戶客戶端觸發(fā)的訂閱請求，其中，上述訂閱請求用于請 求為上述目標(biāo)用戶客戶端推送所訂閱的目標(biāo)消費數(shù)據(jù)；響應(yīng)上述訂閱請求， 解析上述目標(biāo)消費數(shù)據(jù)，以獲取上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)屬性信息， 其中，上述目標(biāo)數(shù)據(jù)屬性信息用于指示上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)類型、 上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)數(shù)量、上述目標(biāo)消費數(shù)據(jù)的目標(biāo)推送對象； 根據(jù)上述目標(biāo)消費數(shù)據(jù)的上述目標(biāo)數(shù)據(jù)屬性信息，生成訂閱指令，并將上 述訂閱指令發(fā)送至消息推送平臺，其中，上述消息推送平臺用于將獲取到 的上述目標(biāo)消費數(shù)據(jù)推送至上述目標(biāo)用戶客戶端。

根據(jù)本發(fā)明實施例的另一方面，還提供了一種消費數(shù)據(jù)的訂閱裝置， 包括：第一接收單元，用于在訂閱平臺接收到目標(biāo)用戶客戶端觸發(fā)的訂閱 請求之后，接收上述訂閱平臺根據(jù)上述訂閱請求觸發(fā)的訂閱指令，其中， 上述訂閱請求用于請求為上述目標(biāo)用戶客戶端推送所訂閱的目標(biāo)消費數(shù) 據(jù)；第一響應(yīng)單元，用于響應(yīng)上述訂閱指令，確定上述目標(biāo)消費數(shù)據(jù)對應(yīng) 的目標(biāo)數(shù)據(jù)屬性信息，其中，上述目標(biāo)數(shù)據(jù)屬性信息用于指示上述目標(biāo)消 費數(shù)據(jù)的目標(biāo)數(shù)據(jù)類型、上述目標(biāo)消費數(shù)據(jù)的目標(biāo)數(shù)據(jù)數(shù)量、上述目標(biāo)消 費數(shù)據(jù)的目標(biāo)推送對象；過濾單元，用于根據(jù)上述目標(biāo)數(shù)據(jù)屬性信息對已 存儲的消費數(shù)據(jù)進(jìn)行過濾，以得到上述目標(biāo)消費數(shù)據(jù)，并將上述目標(biāo)消費 數(shù)據(jù)推送至上述目標(biāo)用戶客戶端。