[發(fā)明專(zhuān)利]數(shù)據(jù)分發(fā)方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202011399583.1
• 申請(qǐng)日: 2020-12-02
• 公開(kāi)（公告）號(hào): CN112600883B
• 公開(kāi)（公告）日: 2022-09-23
• 發(fā)明（設(shè)計(jì)）人: 徐立偉
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京拓世寰宇網(wǎng)絡(luò)技術(shù)有限公司
• 主分類(lèi)號(hào): H04L67/1396
• 分類(lèi)號(hào): H04L67/1396;H04L67/55;G06F16/9535;G06Q30/06
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 李偉

1.一種數(shù)據(jù)分發(fā)方法，其特征在于，包括：

確定已設(shè)立的各個(gè)分發(fā)批次，每個(gè)所述分發(fā)批次對(duì)應(yīng)一個(gè)的數(shù)據(jù)分發(fā)條件；

獲取每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，并通過(guò)每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，獲得屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)；

確定各個(gè)所述分發(fā) 批次對(duì)應(yīng)的分發(fā)順序，并按照所述分發(fā)順序依次對(duì)屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)進(jìn)行預(yù)處理，將已處理的每個(gè)用戶行為數(shù)據(jù)發(fā)送至預(yù)先設(shè)置的數(shù)據(jù)池中；

確定需要接收用戶行為數(shù)據(jù)的各個(gè)接收端，并獲取每個(gè)所述接收端預(yù)先設(shè)置的數(shù)據(jù)接收條件；

基于每個(gè)所述接收端的數(shù)據(jù)接收條件，確定每個(gè)所述分發(fā)批次對(duì)應(yīng)的至少一個(gè)接收端；

基于各個(gè)所述分發(fā)批次對(duì)應(yīng)的分發(fā)順序，依次將所述數(shù)據(jù)池中屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)發(fā)送至該分發(fā)批次對(duì)應(yīng)的各個(gè)接收端。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，設(shè)立各個(gè)所述分發(fā)批次的過(guò)程，包括：

獲取預(yù)先設(shè)置的配置信息；

對(duì)所述配置信息進(jìn)行解析，獲得對(duì)不同用戶行為數(shù)據(jù)進(jìn)行分發(fā)的數(shù)據(jù)分發(fā)規(guī)則；

確定每個(gè)所述數(shù)據(jù)分發(fā)規(guī)則對(duì)應(yīng)的數(shù)據(jù)分發(fā)條件，按照每個(gè)所述數(shù)據(jù)分發(fā)條件設(shè)立其對(duì)應(yīng)的分發(fā)批次。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述通過(guò)每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，獲得屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)，包括：

基于所述數(shù)據(jù)分發(fā)規(guī)則，對(duì)每個(gè)所述分發(fā)批次建立至少一個(gè)執(zhí)行線程；

將每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，發(fā)送至該數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的分發(fā)批次的各個(gè)執(zhí)行線程中，觸發(fā)每個(gè)所述執(zhí)行線程鏈接至已輸入該執(zhí)行線程的數(shù)據(jù)鏈接對(duì)應(yīng)的數(shù)據(jù)源，以獲得各個(gè)所述數(shù)據(jù)源中已存儲(chǔ)的各個(gè)用戶行為數(shù)據(jù)。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述按照所述分發(fā)順序依次對(duì)屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)進(jìn)行預(yù)處理，將已處理的每個(gè)用戶行為數(shù)據(jù)發(fā)送至預(yù)先設(shè)置的數(shù)據(jù)池中，包括：

基于所述分發(fā)順序，依次檢測(cè)屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)是否存在信息缺失的用戶行為數(shù)據(jù)；

若存在信息缺失的用戶行為數(shù)據(jù)，則將信息缺失的用戶行為數(shù)據(jù)進(jìn)行清洗，并將已清洗的用戶行為數(shù)據(jù)發(fā)送至所述數(shù)據(jù)池；

若不存在信息缺失的用戶行為數(shù)據(jù)，則將各個(gè)用戶行為數(shù)據(jù)按照其所屬的分發(fā)批次對(duì)應(yīng)的分發(fā)順序發(fā)送至所述數(shù)據(jù)池。

5.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述依次將所述數(shù)據(jù)池中屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)發(fā)送至該分發(fā)批次對(duì)應(yīng)的各個(gè)接收端，包括：

當(dāng)每次從所述數(shù)據(jù)池中提取屬于當(dāng)前的分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)時(shí)，確定所述當(dāng)前的分發(fā)批次對(duì)應(yīng)的數(shù)據(jù)分發(fā)條件為目標(biāo)數(shù)據(jù)分發(fā)條件；

解析所述配置信息，并獲取所述配置信息中所述目標(biāo)數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)分發(fā)規(guī)則，及該數(shù)據(jù)分發(fā)規(guī)則對(duì)應(yīng)的程序邏輯和流程；

應(yīng)用所述目標(biāo)數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)分發(fā)規(guī)則，及該數(shù)據(jù)分發(fā)規(guī)則對(duì)應(yīng)的程序邏輯和流程，將屬于所述當(dāng)前的分發(fā)批次對(duì)應(yīng)的各個(gè)用戶行為數(shù)據(jù)，發(fā)送至所述當(dāng)前的分發(fā)批次對(duì)應(yīng)的各個(gè)接收端。

6.一種數(shù)據(jù)分發(fā)裝置，其特征在于，包括：

第一確定單元，用于確定已設(shè)立的各個(gè)分發(fā)批次，每個(gè)所述分發(fā)批次對(duì)應(yīng)一個(gè)的數(shù)據(jù)分發(fā)條件；

第一獲取單元，用于獲取每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，并通過(guò)每個(gè)所述數(shù)據(jù)分發(fā)條件對(duì)應(yīng)的數(shù)據(jù)鏈接，獲得屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)；

處理單元，用于確定各個(gè)所述分發(fā) 批次對(duì)應(yīng)的分發(fā)順序，并按照所述分發(fā)順序依次對(duì)屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)進(jìn)行預(yù)處理，將已處理的每個(gè)用戶行為數(shù)據(jù)發(fā)送至預(yù)先設(shè)置的數(shù)據(jù)池中；

第二獲取單元，用于確定需要接收用戶行為數(shù)據(jù)的各個(gè)接收端，并獲取每個(gè)所述接收端預(yù)先設(shè)置的數(shù)據(jù)接收條件；

第二確定單元，用于基于每個(gè)所述接收端的數(shù)據(jù)接收條件，確定每個(gè)所述分發(fā)批次對(duì)應(yīng)的至少一個(gè)接收端；

分發(fā)單元，用于基于各個(gè)所述分發(fā)批次對(duì)應(yīng)的分發(fā)順序，依次將所述數(shù)據(jù)池中屬于每個(gè)所述分發(fā)批次的各個(gè)用戶行為數(shù)據(jù)發(fā)送至該分發(fā)批次對(duì)應(yīng)的各個(gè)接收端。