[發(fā)明專利]實(shí)體熱度的確定方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201810322486.9
• 申請(qǐng)日: 2018-04-11
• 公開（公告）號(hào): CN108492150B
• 公開（公告）日: 2020-06-09
• 發(fā)明（設(shè)計(jì)）人: 章宸
• 申請(qǐng)（專利權(quán)）人: 口碑(上海)信息技術(shù)有限公司
• 主分類號(hào): G06Q30/02
• 分類號(hào): G06Q30/02
• 代理公司: 北京市浩天知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11276
• 代理人: 宋菲;劉蘭蘭

1.一種實(shí)體熱度的確定方法，包括：

通過流式計(jì)算框架實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果；其中，所述日志數(shù)據(jù)信息為流式數(shù)據(jù)信息；

每當(dāng)預(yù)設(shè)的時(shí)間周期到達(dá)時(shí)，獲取本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果；其中，通過主線程實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果，并在預(yù)設(shè)的時(shí)間周期到達(dá)時(shí)，將本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果發(fā)送給與所述主線程同步的各個(gè)子線程，以供各個(gè)子線程獲取本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果；其中，子線程的數(shù)量根據(jù)主線程實(shí)時(shí)處理的數(shù)據(jù)量大小確定；

根據(jù)所述本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果以及預(yù)設(shè)的熱度計(jì)算規(guī)則，確定本次時(shí)間周期內(nèi)實(shí)體的實(shí)時(shí)熱度數(shù)值；其中，各個(gè)子線程根據(jù)所述本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果以及預(yù)設(shè)的熱度計(jì)算規(guī)則，確定本次時(shí)間周期內(nèi)實(shí)體的實(shí)時(shí)熱度數(shù)值，并上報(bào)給所述主線程；其中，所述子線程為多個(gè)并行運(yùn)行的子線程。

2.根據(jù)權(quán)利要求1所述的方法，其中，所述預(yù)設(shè)的熱度計(jì)算規(guī)則包括：結(jié)合所述實(shí)體的靜態(tài)屬性信息計(jì)算該實(shí)體的實(shí)時(shí)熱度數(shù)值；

其中，所述靜態(tài)屬性信息包括：商圈信息、地域信息、和/或歷史交易信息。

3.根據(jù)權(quán)利要求1所述的方法，其中，所述方法進(jìn)一步包括：當(dāng)下一個(gè)時(shí)間周期到達(dá)時(shí)，所述主線程判斷是否存在處理進(jìn)度異常的子線程；

若是，向所述處理進(jìn)度異常的子線程發(fā)送停止消息，以使所述處理進(jìn)度異常的子線程中止本次時(shí)間周期的處理，并開啟下一個(gè)時(shí)間周期的處理。

4.根據(jù)權(quán)利要求1所述的方法，其中，所述通過主線程實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟具體包括：將所述實(shí)時(shí)統(tǒng)計(jì)結(jié)果持久化存儲(chǔ)到預(yù)設(shè)存儲(chǔ)設(shè)備中；

則所述方法進(jìn)一步包括：當(dāng)所述主線程出現(xiàn)異常時(shí)，通過所述預(yù)設(shè)存儲(chǔ)設(shè)備恢復(fù)已統(tǒng)計(jì)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果。

5.根據(jù)權(quán)利要求4所述的方法，其中，當(dāng)所述主線程進(jìn)一步包括多個(gè)并行運(yùn)行的主線程時(shí)，所述預(yù)設(shè)存儲(chǔ)設(shè)備中進(jìn)一步包括多個(gè)與各個(gè)主線程分別對(duì)應(yīng)的數(shù)據(jù)分桶，則所述通過所述預(yù)設(shè)存儲(chǔ)設(shè)備恢復(fù)已統(tǒng)計(jì)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟具體包括：

根據(jù)預(yù)設(shè)的線程分桶映射關(guān)系，確定與出現(xiàn)異常的主線程相對(duì)應(yīng)的數(shù)據(jù)分桶，根據(jù)所述與出現(xiàn)異常的主線程相對(duì)應(yīng)的數(shù)據(jù)分桶恢復(fù)已統(tǒng)計(jì)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果。

6.根據(jù)權(quán)利要求1-5任一所述的方法，其中，所述實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟進(jìn)一步包括：

實(shí)時(shí)判斷預(yù)設(shè)的時(shí)間周期是否到達(dá)，若是，則執(zhí)行所述獲取本次時(shí)間周期內(nèi)統(tǒng)計(jì)的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟及其后續(xù)步驟。

7.根據(jù)權(quán)利要求1-5任一所述的方法，其中，所述實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟之前，進(jìn)一步包括：

根據(jù)所述實(shí)體的類型，實(shí)時(shí)獲取與該類型的實(shí)體相關(guān)的日志數(shù)據(jù)信息；其中，所述日志數(shù)據(jù)信息包括：券核銷日志、訪問日志和/或交易日志。

8.根據(jù)權(quán)利要求1-5任一所述的方法，其中，所述實(shí)時(shí)統(tǒng)計(jì)與實(shí)體相關(guān)的日志數(shù)據(jù)信息中包含的各個(gè)實(shí)體熱度指標(biāo)的實(shí)時(shí)統(tǒng)計(jì)結(jié)果的步驟具體包括：

根據(jù)所述實(shí)體的類型，確定與該類型的實(shí)體相對(duì)應(yīng)的實(shí)體熱度指標(biāo)；

從所述日志數(shù)據(jù)信息中實(shí)時(shí)提取與該類型的實(shí)體相對(duì)應(yīng)的實(shí)體熱度指標(biāo)，并分別針對(duì)提取出的各個(gè)實(shí)體熱度指標(biāo)進(jìn)行統(tǒng)計(jì)；

其中，所述實(shí)體的類型包括：店鋪類型、和/或電子券類型；所述實(shí)體熱度指標(biāo)包括：交易金額指標(biāo)、優(yōu)惠金額指標(biāo)、券核銷指標(biāo)、和/或券領(lǐng)取指標(biāo)。