[發(fā)明專利]一種時(shí)間序列處理的計(jì)算流圖構(gòu)建方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201811382844.1
• 申請(qǐng)日: 2018-11-20
• 公開(kāi)（公告）號(hào): CN109508412B
• 公開(kāi)（公告）日: 2019-12-20
• 發(fā)明（設(shè)計(jì)）人: 李家軍;江樹(shù)浩;龔施俊;鄢貴海
• 申請(qǐng)（專利權(quán)）人: 中科馭數(shù)(北京)科技有限公司
• 主分類號(hào): G06F16/901
• 分類號(hào): G06F16/901
• 代理公司: 11612 北京金咨知識(shí)產(chǎn)權(quán)代理有限公司
• 代理人: 宋教花

本申請(qǐng)?zhí)峁┝艘环N時(shí)間序列處理的計(jì)算流圖構(gòu)建方法和裝置，其中，該方法包括：獲取待處理的時(shí)間序列處理算法；將所述待處理的時(shí)間序列處理算法拆分為多個(gè)計(jì)算表達(dá)式；為所述多個(gè)計(jì)算表達(dá)式分別構(gòu)造計(jì)算流圖，以得到多個(gè)計(jì)算流圖；將所述多個(gè)計(jì)算流圖進(jìn)行合并，得到所述待處理的時(shí)間序列處理算法對(duì)應(yīng)的流圖模型。利用本申請(qǐng)實(shí)施例提供的技術(shù)方案，可以直觀地展現(xiàn)時(shí)間序列算法的數(shù)據(jù)依賴關(guān)系，利用這種依賴關(guān)系可以優(yōu)化對(duì)時(shí)間序列處理算法中的計(jì)算步驟，可以避免因數(shù)據(jù)依賴導(dǎo)致的處理器阻塞的問(wèn)題，且可以方便地對(duì)計(jì)算流圖根據(jù)計(jì)算系統(tǒng)的特性進(jìn)行劃分以匹配計(jì)算系統(tǒng)的計(jì)算能力，從而提高計(jì)算系統(tǒng)的資源利用率和時(shí)間序列處理算法的運(yùn)行效率。

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

本申請(qǐng)屬于數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種時(shí)間序列處理的計(jì)算流圖構(gòu)建方法和裝置。

背景技術(shù)

時(shí)間序列分析在很多的分析場(chǎng)景都是很重要的技術(shù)，在許多應(yīng)用場(chǎng)景中，一般都需要能夠快速地響應(yīng)基于快速持續(xù)到達(dá)的數(shù)據(jù)流。以股票市場(chǎng)應(yīng)用為例，有多個(gè)客戶端在監(jiān)聽(tīng)股票市場(chǎng)的價(jià)格波動(dòng)，需要這個(gè)系統(tǒng)能夠有效地去響應(yīng)針對(duì)不同客戶端的分析請(qǐng)求。不同客戶端的分析請(qǐng)求是不同的，例如，有些客戶端請(qǐng)求的是每周股價(jià)波動(dòng)率，有些客戶端請(qǐng)求的是每月平均股價(jià)等。除了在金融領(lǐng)域，時(shí)間序列分析在醫(yī)療健康、商業(yè)決策、科學(xué)計(jì)算、社交媒體和網(wǎng)絡(luò)控制等領(lǐng)域，也是廣泛需求的。

一般，時(shí)間序列處理的數(shù)據(jù)量規(guī)模很大，時(shí)間序列數(shù)據(jù)之間存在依賴關(guān)系，這種依賴關(guān)系是由時(shí)間序列處理函數(shù)確定的。然而，時(shí)間序列處理函數(shù)的種類比較多，這也就導(dǎo)致時(shí)間序列數(shù)據(jù)之間的關(guān)聯(lián)關(guān)系非常復(fù)雜。

針對(duì)上述問(wèn)題，目前尚未提出有效的解決方案。

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

本申請(qǐng)目的在于提供一種時(shí)間序列處理的計(jì)算流圖構(gòu)建方法和裝置，可以實(shí)現(xiàn)清楚表征時(shí)間序列數(shù)據(jù)之間的關(guān)聯(lián)性的問(wèn)題，且可以實(shí)現(xiàn)對(duì)數(shù)據(jù)處理過(guò)程優(yōu)化。

本申請(qǐng)?zhí)峁┮环N時(shí)間序列處理的計(jì)算流圖構(gòu)建方法和裝置是這樣實(shí)現(xiàn)的：

一種時(shí)間序列處理的計(jì)算流圖構(gòu)建方法，所述方法包括：

獲取待處理的時(shí)間序列處理算法；

將所述待處理的時(shí)間序列處理算法拆分為多個(gè)計(jì)算表達(dá)式；

為所述多個(gè)計(jì)算表達(dá)式分別構(gòu)造計(jì)算流圖，以得到多個(gè)計(jì)算流圖；

將所述多個(gè)計(jì)算流圖進(jìn)行合并，得到所述待處理的時(shí)間序列處理算法對(duì)應(yīng)的流圖模型。

在一個(gè)實(shí)施方式中，將所述待處理的時(shí)間序列處理算法拆分為多個(gè)計(jì)算表達(dá)式，包括：

對(duì)所述待處理的時(shí)間序列處理算法進(jìn)行拆分，得到輸入數(shù)據(jù)、中間數(shù)據(jù)和輸出數(shù)據(jù)；

對(duì)所述輸入數(shù)據(jù)、中間數(shù)據(jù)和輸出數(shù)據(jù)進(jìn)行數(shù)據(jù)依賴分析，得到所述計(jì)算表達(dá)式。

在一個(gè)實(shí)施方式中，為所述多個(gè)計(jì)算表達(dá)式分別構(gòu)造計(jì)算流圖，包括：

將當(dāng)前的計(jì)算表達(dá)式的輸入時(shí)間序列作為輸入節(jié)點(diǎn)；

將當(dāng)前的計(jì)算表達(dá)式的輸出時(shí)間序列作為輸出節(jié)點(diǎn)；

將輸入節(jié)點(diǎn)到輸出節(jié)點(diǎn)的連線作為有向邊，其中，所述有向邊用于表征當(dāng)前的計(jì)算表達(dá)式對(duì)應(yīng)的時(shí)間序列處理函數(shù)；

以所述輸入節(jié)點(diǎn)、所述輸出節(jié)點(diǎn)和所述有向邊，作為當(dāng)前計(jì)算表達(dá)式的計(jì)算流圖。

在一個(gè)實(shí)施方式中，為所述多個(gè)計(jì)算表達(dá)式分別構(gòu)造計(jì)算流圖，以得到多個(gè)計(jì)算流圖，包括：

將所述多個(gè)計(jì)算表達(dá)式放入表達(dá)式池中；

從所述表達(dá)式池中采用無(wú)放回方式隨機(jī)取出一個(gè)計(jì)算表達(dá)式；

在一個(gè)實(shí)施方式中，將所述多個(gè)計(jì)算流圖進(jìn)行合并，包括：