[發(fā)明專利]一種基于任務(wù)分配獲取目標(biāo)車流量的數(shù)據(jù)處理系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 202310093407.2
• 申請(qǐng)日: 2023-02-03
• 公開(kāi)（公告）號(hào): CN116071924B
• 公開(kāi)（公告）日: 2023-09-22
• 發(fā)明（設(shè)計(jì)）人: 曾智穎;李凡平;石柱國(guó)
• 申請(qǐng)（專利權(quán)）人: 以薩技術(shù)股份有限公司
• 主分類號(hào): G08G1/01
• 分類號(hào): G08G1/01;G08G1/065;G06F9/50
• 代理公司: 北京鍾維聯(lián)合知識(shí)產(chǎn)權(quán)代理有限公司 11579
• 代理人: 郝姍姍

1.一種基于任務(wù)分配獲取目標(biāo)車流量的數(shù)據(jù)處理系統(tǒng)，其特征在于，所述系統(tǒng)包括：處理器和存儲(chǔ)有計(jì)算機(jī)程序的存儲(chǔ)器，當(dāng)所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)，實(shí)現(xiàn)以下步驟：

S100，接收車流量獲取請(qǐng)求，獲取第一數(shù)據(jù)平臺(tái)發(fā)送的初始任務(wù)列表A＝{A₁，A₂，……，A_i，……，A_n}和A對(duì)應(yīng)的初始時(shí)間列表A⁰＝{A⁰₁，A⁰₂，……，A⁰_i，……，A⁰_n}，A_i為第i個(gè)初始任務(wù)，A_i為A_i對(duì)應(yīng)的初始時(shí)間，i＝1……n，n為初始任務(wù)的數(shù)量，其中，所述第一數(shù)據(jù)平臺(tái)為初始任務(wù)的獲取方對(duì)應(yīng)的數(shù)據(jù)平臺(tái)，其中，所述數(shù)據(jù)平臺(tái)為接收數(shù)據(jù)并存儲(chǔ)數(shù)據(jù)的平臺(tái)，所述初始任務(wù)列表包括若干個(gè)初始任務(wù)，所述初始任務(wù)為預(yù)測(cè)目標(biāo)車道的車流量，其中，所述目標(biāo)車道為用戶提供的需被檢測(cè)的車道，所述初始時(shí)間為完成初始任務(wù)所需的時(shí)間；

S200，獲取第一數(shù)據(jù)處理平臺(tái)列表B＝{B₁，B₂，……，B_j，……，B_N}和B對(duì)應(yīng)的候選時(shí)間列表B⁰＝{B⁰₁，B⁰₂，……，B⁰_j，……，B⁰_N}，B_j為第j個(gè)第一數(shù)據(jù)處理平臺(tái)，B⁰_j為B_j對(duì)應(yīng)的候選時(shí)間，其中，所述第一數(shù)據(jù)處理平臺(tái)為用于接收初始任務(wù)并根據(jù)初始任務(wù)生成候選函數(shù)的數(shù)據(jù)處理平臺(tái)，所述候選時(shí)間為第一數(shù)據(jù)處理平臺(tái)執(zhí)行一次任務(wù)所能承載的最大時(shí)間；

S300，當(dāng)n≤N時(shí)，將A發(fā)送至B中以獲取B對(duì)應(yīng)的目標(biāo)任務(wù)集B'＝{B'₁，B'₂，……，B'_j，……，B'_N}，B'_j＝A_j且A⁰_j≤B⁰_j，其中，A_j為第j個(gè)初始任務(wù)，A⁰_j為A_j對(duì)應(yīng)的初始時(shí)間；

S400，當(dāng)n＞N時(shí)，將A發(fā)送至B中以獲取B對(duì)應(yīng)的目標(biāo)任務(wù)集B'＝{B'₁，B'₂，……，B'_j，……，B'_N}，B'_j為B_j對(duì)應(yīng)的目標(biāo)任務(wù)列表，其中，在S400中還包括如下步驟：

S401，當(dāng)時(shí)，獲取B對(duì)應(yīng)的目標(biāo)任務(wù)集B'＝{B'₁，B'₂，……，B'_j，……，B'_N}，B'_j＝{{B'_j1，B'_j2，……，B'_jr，……，B'_js(j)}，其中，TB'_jr為B'_jr對(duì)應(yīng)的初始時(shí)間，B'_jr為B_j對(duì)應(yīng)的目標(biāo)任務(wù)列表中的第r個(gè)目標(biāo)任務(wù)，所述目標(biāo)任務(wù)為從初始任務(wù)列表中獲取到的初始任務(wù)；

S403，當(dāng)時(shí)，獲取B對(duì)應(yīng)的第一目標(biāo)任務(wù)集FB＝{FB₁，F(xiàn)B₂，……，F(xiàn)B_j，……，F(xiàn)B_N}和第二目標(biāo)任務(wù)集DB＝{DB₁，DB₂，……，DB_j，……，DB_N}，F(xiàn)B_j為B_j對(duì)應(yīng)的第一目標(biāo)任務(wù)列表，DB_j為B_j對(duì)應(yīng)的第二目標(biāo)任務(wù)列表，其中，所述第一目標(biāo)任務(wù)列表包括若干個(gè)第一目標(biāo)任務(wù)，所述第一目標(biāo)任務(wù)為從初始任務(wù)列表中獲取到的初始任務(wù)，其中，在S403中通過(guò)如下步驟獲取DB：

S4031，根據(jù)FB，獲取候選任務(wù)列表C＝{C₁，C₂，……，C_e，……，C_t}，C_e為第e個(gè)候選任務(wù)，e＝1……t，t為候選任務(wù)的數(shù)量，其中，所述候選任務(wù)為從初始任務(wù)列表中刪除第一目標(biāo)任務(wù)列表后的初始任務(wù)；

S4033，當(dāng)C⁰_e≤B⁰_jg-T⁰時(shí)，將C_e插入至DB_j且B_j采用第一執(zhí)行方式對(duì)DB_j進(jìn)行處理，其中，B⁰_jg為FB_j中第g個(gè)第一目標(biāo)任務(wù)對(duì)應(yīng)的初始時(shí)間，C⁰_e為C_e對(duì)應(yīng)的初始時(shí)間，T⁰為預(yù)設(shè)的時(shí)間閾值；

S4035，當(dāng)C⁰_e＞B⁰_jg-T⁰時(shí)，將C中的候選任務(wù)按照候選原則插入至DB中且B采用第二執(zhí)行方式對(duì)DB進(jìn)行處理；

S405，根據(jù)FB和DB，獲取B對(duì)應(yīng)的目標(biāo)任務(wù)集B'＝{B'₁，B'₂，……，B'_j，……，B'_N}，其中，B'_j＝{FB_j，DB_j}；

S500，根據(jù)B'，獲取第一數(shù)據(jù)處理平臺(tái)發(fā)送的候選函數(shù)集并將候選函數(shù)集發(fā)送至第二數(shù)據(jù)平臺(tái)，其中，在S500中還包括如下步驟：

S501，根據(jù)B'，獲取第j個(gè)第一數(shù)據(jù)處理平臺(tái)中的第x個(gè)目標(biāo)任務(wù)B'_jx；

S503，根據(jù)樣本交通道路信息數(shù)據(jù)庫(kù)和B'_jx，獲取B'_jx對(duì)應(yīng)的候選函數(shù)D_jx且將D_jx插入至D_j中，所述樣本交通道路信息數(shù)據(jù)庫(kù)包括樣本車道編碼列表及樣本車道編碼列表對(duì)應(yīng)的樣本車道信息集，其中，在S503中通過(guò)如下步驟獲取D_jx：

S5031，獲取B'_jx對(duì)應(yīng)的目標(biāo)車道編碼EB'_jx；

S5033，根據(jù)樣本車道交通信息數(shù)據(jù)庫(kù)，獲取樣本車道編碼列表E＝{E₁，E₂，……，E_μ，……，E_ζ}，E_μ為第μ個(gè)樣本車道編碼，μ＝1……ζ，ζ為樣本車道編碼的數(shù)量；

S5035，當(dāng)EB'_jx與E_μ一致時(shí)，獲取E_μ對(duì)應(yīng)的樣本車道信息集FE_μ；

S5037，根據(jù)FE_μ，調(diào)用樣本模型數(shù)據(jù)庫(kù)以獲取D_jx；

S505，將生成的D_j發(fā)送至第二數(shù)據(jù)平臺(tái)；

S600，根據(jù)候選函數(shù)集，獲取A對(duì)應(yīng)的目標(biāo)車流量列表，其中，在S600中還包括如下步驟：

S601，將初始任務(wù)列表發(fā)送至M個(gè)第二數(shù)據(jù)處理平臺(tái)，獲取第二數(shù)據(jù)處理平臺(tái)對(duì)應(yīng)的指定任務(wù)集；

S603，根據(jù)指定任務(wù)集，調(diào)用D以獲取到第二數(shù)據(jù)處理平臺(tái)發(fā)送的初始任務(wù)列表對(duì)應(yīng)的目標(biāo)車流量列表。