一種交通信息處理方法和裝置製造方法
2023-09-20 10:28:40
一種交通信息處理方法和裝置製造方法
【專利摘要】本發明的實施例提供一種交通信息處理方法和裝置，涉及信息處理領域，提供了一種對實時動態交通信息的流式處理方式，消除了數據處理過程中的延遲，實現了交通信息的實時更新。其方法為：通過接收源數據，並在進行標準化處理後，將獲取的標準數據送入數據傳輸中間件；周期性的從數據傳輸中間件接收標準數據進行地圖匹配處理，結合歷史匹配結果進行路徑推測處理獲取標準軌跡數據；周期性的接收並對標準軌跡數據與標準數據進行融合處理得到標準交通流信息。本發明的實施例用於實現對實時動態交通信息的流式處理。
【專利說明】一種交通信息處理方法和裝置
【技術領域】
[0001]本發明涉及信息處理領域，尤其涉及一種交通信息處理方法和裝置。
【背景技術】
[0002]隨著經濟的快速發展，中國已逐步成為汽車大國，機動車數量飛速增長，但由於城市的交通供給存在不足，擁堵的問題時有發生。隨著對交通問題研究的深入，人們開始意識到必須採取增加道路基礎設施和提高路網通行能力相結合的方法來解決交通擁擠問題，由此逐漸產生了交通控制技術。
[0003]實現良好的交通控制必須對道路的交通狀態進行實時監測與分析，及時發現道路網中存在的交通問題，這是改善道路交通運行效率、減小路網交通阻塞的前提和基礎。隨著智能交通信息採集技術的發展，包括流量、浮動車、視頻監控等在內的海量數據為智能交通系統(Intelligent Transport System, ITS)提供了豐富的交通信息資源。
[0004]但是，信息的暴漲在為路況的計算提供數據保證的同時，也對ITS的處理性能、擴展能力、可靠性等方面提出了更高的要求。現有技術中，交通信息處理系統多為單機批處理系統，周期性的對信息進行處理與發布，擴展性與可靠性差，且在對交通數據進行處理的過程中，會產生較高的延時，並非真正意義上的實時處理，對發布周期的調整還會導致大量的重複計算，造成系統效率的降低。
【發明內容】
[0005]本發明的實施例提供一種交通信息處理方法和裝置，通過採用流式計算系統對實時接收的交通信息數據進行處理，消除數據處理過程中的延遲，實現交通信息的實時更新，保證系統的擴展性與可靠性，且避免可能出現的重複計算問題，提高系統效率。
[0006]為達到上述目的，本發明的實施例採用如下技術方案:
[0007]第一方面，本發明實施例提供一種交通信息處理方法，該方法包括:
[0008]並行從多個數據源中接收對應源數據接入原數據集合，依次提取所述原數據集合中的源數據，並對所述源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件；所述標準數據包括標準位置信息源數據、標準交通信息源數據；
[0009]按照第一預設時間間隔，周期性的從所述數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條所述標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果，並結合所述目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據；所述目標浮動車為所述標準位置信息源數據對應的浮動車；
[0010]按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從所述數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的所述標註軌跡數據與所述標準信息源數據進行融合，獲取標準交通流信息。[0011]第二方面，提供一種交通信息處理裝置，該裝置包括:
[0012]數據接入單元，用於並行從多個數據源中接收對應源數據接入原數據集合，依次提取所述原數據集合中的源數據，並對所述源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件；所述標準數據包括標準位置信息源數據、標準交通信息源數據；
[0013]數據處理單元，用於按照第一預設時間間隔，周期性的從所述數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條所述標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果，並結合所述目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據；所述目標浮動車為所述標準位置信息源數據對應的浮動車；
[0014]實時融合單元，用於按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從所述數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的所述標註軌跡數據與所述標準信息源數據進行融合，獲取標準交通流信息。
[0015]本發明的實施例提供一種交通信息處理方法和裝置，通過接收源數據，並在進行標準化處理後，將獲取的標準數據送入數據傳輸中間件；周期性的從數據傳輸中間件接收標準數據進行地圖匹配處理，結合歷史匹配結果進行路徑推測處理獲取標準軌跡數據；周期性的接收並對標準軌跡數據與標準數據進行融合處理得到標準交通流信息。這樣，消除了數據處理過程中的延遲，實現了交通信息的實時更新，保證了系統的擴展性與可靠性，且避免了可能出現的重複計算問題，提高了系統效率。
【專利附圖】
【附圖說明】
[0016]為了更清楚地說明本發明實施例或現有技術中的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對於本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。
[0017]圖1為本發明實施例提供的一種交通信息處理方法的流程示意圖；
[0018]圖2為本發明實施例提供的另一種交通信息處理方法的流程示意圖一；
[0019]圖3為本發明實施例提供的另一種交通信息處理方法的流程示意圖二 ；
[0020]圖4為本發明實施例提供的另一種交通信息處理方法的流程示意圖三；
[0021]圖5為本發明實施例提供的另一種交通信息處理方法的流程示意圖四；
[0022]圖6為本發明實施例提供的一種交通信息處理裝置的結構示意圖一；
[0023]圖7為本發明實施例提供的一種交通信息處理裝置的結構示意圖二。
【具體實施方式】
[0024]下面將結合本發明實施例中的附圖，對本發明實施例中的技術方案進行清楚、完整地描述，顯然，所描述的實施例僅僅是本發明一部分實施例，而不是全部的實施例。基於本發明中的實施例，本領域普通技術人員在沒有做出創造性勞動前提下所獲得的所有其他實施例，都屬於本發明保護的範圍。
[0025]本發明的實施例提供一種交通信息處理方法，如圖1所示，該方法包括:[0026]S101、並行從多個數據源中接收對應源數據接入原數據集合，依次提取原數據集合中的源數據，並對源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件；
[0027]其中，標準數據包括標準位置信息源數據、標準交通信息源數據。
[0028]S102、按照第一預設時間間隔，周期性的從數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果，並結合目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據；
[0029]其中，目標浮動車為標準位置信息源數據對應的浮動車。
[0030]S103、按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的標註軌跡數據與標準信息源數據進行融合，獲取標準交通流信息。
[0031]本發明的實施例提供一種交通信息處理方法，通過接收源數據，並在進行標準化處理後，將獲取的標準數據送入數據傳輸中間件；周期性的從數據傳輸中間件接收標準數據進行地圖匹配處理，結合歷史匹配結果進行路徑推測處理獲取標準軌跡數據；周期性的接收並對標準軌跡數據與標準數據進行融合處理得到標準交通流信息。這樣，消除了數據處理過程中的延遲，實現了交通信息的實時更新，保證了系統的擴展性與可靠性，且避免了可能出現的重複計算問題，提高了系統效率。
[0032]為了使本領域技術人員能夠更清楚地理解本發明實施例提供的技術方案，下面通過具體的實施例，對本發明實施例提供的另一種交通信息處理方法進行詳細說明，如圖2所示，該方法包括:
[0033]S201、多源異構數據的接入和標準化處理。
[0034]具體的，並行從多種不同數據源接收多種結構不同的交通信息數據，在保證數據實時、穩定、安全接入的同時，還需要對其進行標準化處理，以滿足後續處理要求。在本實施例中，通過數據接入子系統實現對多源異構數據的實時採集和標準化，如圖3所示，處理流程包括:
[0035]S2011、接收源數據，獲取原數據集合。
[0036]具體的，按照預設接入時間間隔，周期性的從多個數據源接收數據源類型對應的源數據，並將源數據加入原數據集合。
[0037]其中，數據源為提供多種所需交通信息的數據採集模組，根據對交通信息描述方式、標準的不同，分為多種不同的數據源類型；在本實施例中，數據源類型可以為浮動車數據源、二次路況數據源；且上述列舉的數據源類型僅為示例性的，包括但不限於此。
[0038]示例性的，對於不同的數據源類型，存在對應的預設接收策略對源數據進行接收，並將接收到的源數據加入原數據集合；其中，對應的預設接收策略可以為根據數據源類型定製化的接收程序，原數據集合為包括多種源數據的數據集合。
[0039]值得一提的，從多種數據源類型不同的數據源接收源數據，對不同數據源的接收過程是並行進行的，即將從不同數據源接收的對應源數據並行加入原數據集合中；預設接入時間間隔可以為系統預設設定值，也可以為外部輸入給定值，此處不做限定；且當預設接入時間間隔取值為一個極小值時，可實現從多個數據源實時接收源數據。
[0040]S2012、對原數據集合中的源數據進行標準化處理。
[0041]具體的，根據原數據集合中的源數據，通過預設標準化策略，獲取源數據對應的標準數據；
[0042]其中，預設標準化策略用於在依次獲取原數據集合中來自不同類型數據源的源數據後，從每一種源數據中統計並提取對應的預設信息，構成對應的標準數據，且得到的標準數據與原數據集合中的源數據一一對應。
[0043]示例性的,標準數據包括標準位置信息源(Standard Location Raw, STL)數據、標準交通信息源(Standard Traffic Raw, STT)數據；若源數據來自浮動車數據源,則獲取的標準數據為STL數據；或，若源數據來自二次路況數據源，則獲取的標準數據為STT數據；
[0044]其中，STL數據為包含全球定位系統(Global Positioning System, GPS)定位信息的標準浮動車數據，具體數據格式如表I所示；
[0045]表I
【權利要求】
1.一種交通信息處理方法，其特徵在於，所述方法包括: 並行從多個數據源中接收對應源數據接入原數據集合，依次提取所述原數據集合中的源數據，並對所述源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件；所述標準數據包括標準位置信息源數據、標準交通信息源數據； 按照第一預設時間間隔，周期性的從所述數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條所述標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果，並結合所述目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據；所述目標浮動車為所述標準位置信息源數據對應的浮動車； 按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從所述數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的所述標註軌跡數據與所述標準信息源數據進行融合，獲取標準交通流信息。
2.根據權利要求1所述的方法，其特徵在於，所述並行從多個數據源中接收對應源數據接入原數據集合，依次提取所述原數據集合中的源數據，並對所述源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件包括: 根據所述數據源的數據源類型，通過所述數據源類型對應的預設接收策略，按照預設接入時間間隔，周期性的從多個所述數據源接收所述數據源類型對應的所述源數據，並行接入所述原數據集合；所述數據源類型包括浮動車數據源、二次路況數據源； 依次提取所述原數據集合中的所述源數據，通過預設標準化策略，提取預設信息，獲取所述源數據對應的所述標準數據: 若所述源數據來自所述浮動車數據源，則獲取的所述標準數據為所述標準位置信息源數據；所述標準位置信息源數據包括浮動車類型、車輛標示；或， 若所述源數據來自所述二次路況數據源，則獲取的所述標準數據為所述標準交通信息源數據；所述標準交通信息源數據包括路鏈標示、數據時間； 通過數據傳輸接口，將獲取的所述標準數據發送給數據傳輸中間件。
3.根據權利要求2所述的方法，其特徵在於，所述按照第一預設時間間隔，周期性的從所述數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條所述標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果包括: 按照第一預設時間間隔，周期性的通過所述數據傳輸中間件的讀取接口，根據所述標準數據的類型進行分類，並行接收所述標準數據，並統計計算接收任一類型的所述標準數據時的採樣周期； 通過所述流式計算系統的分發接口，根據預設分發策略分發所述標準數據； 通過所述流式計算系統的處理接口接收分發的所述標準數據，並根據所述標準數據對應的所述採樣周期與所述目標浮動車的所述浮動車類型，通過預設匹配策略，獲取每一條所述標準位置信息源數據對應的一組所述候選匹配結果。`
4.根據權利要求3所述的方法，其特徵在於，所述結合所述目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據包括: 在獲取任一條所述標準位置信息源數據對應的一組所述候選匹配結果後，結合所述目標浮動車的歷史匹配結果，根據所述標準數據對應的所述採樣周期與所述目標浮動車的所述浮動車類型，通過預設路徑推測策略，獲取所述標準位置信息源數據對應的一條所述標準軌跡數據； 所述標準軌跡數據包括路鏈標示、數據時間。
5.根據權利要求4所述的方法，其特徵在於，所述預設路徑推測策略包括: 在接收到所述候選匹配結果與所述標準位置信息源數據後，判斷所述標準位置信息源數據是否滿足預設路徑推測條件； 若滿足所述路徑推測條件，則獲取所述目標浮動車的所述歷史匹配結果，並結合所述候選匹配結果獲取所述目標浮動車的最優行駛路徑； 通過對所述最優行駛路徑進行路徑計算，獲取所述標準軌跡數據。
6.根據權利要求4所述的方法，其特徵在於，所述按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從所述數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的所述標註軌跡數據與所述標準信息源數據進行融合包括: 在按照第二預設時間間隔，周期性的接收所述流式計算系統處理獲取並分發的每一條所述標準軌跡數據與從所述數據傳輸中間件獲取的所述標準交通信息源數據後，以所述標準軌跡數據與所述標準交通信息源數據中的所述路鏈標示進行分類，並按照所述數據時間的先後順序存儲在內存資料庫中； 滿足預設觸發條件時，獲取滿足所述預設融合條件的所述標準軌跡數據與所述標準交通信息源數據；所述預設融合條件為在所述內存資料庫中所述標準軌跡數據、所述標準交通信息源數據的所述路鏈標示為目標路鏈、且所述數據時間在預設時間段內；` 通過預設融合模型進行融合，對所述標準軌跡數據與所述標準交通信息源數據中的路鏈交通信息進行提取組合，獲取所述預設時間段的標準交通流信息。
7.—種交通信息處理裝置，其特徵在於，所述裝置包括: 數據接入單元，用於並行從多個數據源中接收對應源數據接入原數據集合，依次提取所述原數據集合中的源數據，並對所述源數據進行標準化處理，將獲取的對應標準數據送入數據傳輸中間件；所述標準數據包括標準位置信息源數據、標準交通信息源數據； 數據處理單元，用於按照第一預設時間間隔，周期性的從所述數據傳輸中間件接收標準數據，通過流式計算系統對接收到的每一條所述標準位置信息源數據依次進行地圖匹配處理，獲取目標浮動車對應的一組候選匹配結果，並結合所述目標浮動車的歷史匹配結果進行路徑推測處理，獲取對應的一條標準軌跡數據；所述目標浮動車為所述標準位置信息源數據對應的浮動車； 實時融合單元，用於按照第二預設時間間隔，周期性的接收並保存流式計算系統處理獲取並分發的每一條標準軌跡數據與從所述數據傳輸中間件獲取的標準交通信息源數據，並在滿足預設觸發條件時，對滿足預設融合條件的所述標註軌跡數據與所述標準信息源數據進行融合，獲取標準交通流信息。
8.根據權利要求7所述的裝置，其特徵在於，所述數據接入單元具體用於: 根據所述數據源的數據源類型，通過所述數據源類型對應的預設接收策略，按照預設接入時間間隔，周期性的從多個所述數據源接收所述數據源類型對應的所述源數據，並行接入所述原數據集合；所述數據源類型包括浮動車數據源、二次路況數據源； 依次提取所述原數據集合中的所述源數據，通過預設標準化策略，提取預設信息，獲取所述源數據對應的所述標準數據: 若所述源數據來自所述浮動車數據源，則獲取的所述標準數據為所述標準位置信息源數據；所述標準位置信息源數據包括浮動車類型、車輛標示；或， 若所述源數據來自所述二次路況數據源，則獲取的所述標準數據為所述標準交通信息源數據；所述標準交通信息源數據包括路鏈標示、數據時間； 通過數據傳輸接口，將獲取的所述標準數據發送給數據傳輸中間件。
9.根據權利要求8所述的裝置，其特徵在於，所述數據處理單元包括: 接入分發單元，用於按照第一預設時間間隔，周期性的通過所述數據傳輸中間件的讀取接口，根據所述標準數據的類型進行分類，並行接收所述標準數據，並統計計算接收任一類型的所述標準數據時的採樣周期； 通過所述流式計算系統的分發接口，根據預設分發策略分發所述標準數據； 地圖匹配單元，用於通過所述流式計算系統的處理接口接收分發的所述標準數據，並根據所述標準數據對應的所述採樣周期與所述目標浮動車的所述浮動車類型，通過預設匹配策略，獲取每一條所述標準位置信息源數據對應的一組所述候選匹配結果。
10.根據權利要求9所述的裝置，其特徵在於，所述數據處理單元還包括路徑推測單元，具體用於: 在獲取任一條所述標準位置信息源數據對應的一組所述候選匹配結果後，結合所述目標浮動車的歷史匹配結果，根據所述標準數據對應的所述採樣周期與所述目標浮動車的所述浮動車類型，通過預設路徑推`測策略，獲取所述標準位置信息源數據對應的一條所述標準軌跡數據； 所述標準軌跡數據包括路鏈標示、數據時間。
11.根據權利要求10所述的裝置，其特徵在於，所述路徑推測單元還具體用於: 執行所述預設路徑推測策略，所述預設路徑推測策略包括: 在接收到所述候選匹配結果與所述標準位置信息源數據後，判斷所述標準位置信息源數據是否滿足預設路徑推測條件； 若滿足所述路徑推測條件，則獲取所述目標浮動車的所述歷史匹配結果，並結合所述候選匹配結果獲取所述目標浮動車的最優行駛路徑； 通過對所述最優行駛路徑進行路徑計算，獲取所述標準軌跡數據。
12.根據權利要求10所述的裝置，其特徵在於，所述實時融合單元具體用於: 在按照第二預設時間間隔，周期性的接收所述流式計算系統處理獲取並分發的每一條所述標準軌跡數據與從所述數據傳輸中間件獲取的所述標準交通信息源數據後，以所述標準軌跡數據與所述標準交通信息源數據中的所述路鏈標示進行分類，並按照所述數據時間的先後順序存儲在內存資料庫中； 滿足預設觸發條件時，獲取滿足所述預設融合條件的所述標準軌跡數據與所述標準交通信息源數據；所述預設融合條件為在所述內存資料庫中所述標準軌跡數據、所述標準交通信息源數據的所述路鏈標示為目標路鏈、且所述數據時間在預設時間段內； 通過預設融合模型進行融合，對所述標準軌跡數據與所述標準交通信息源數據中的路鏈交通信息進 行提取組合，獲取所述預設時間段的標準交通流信息。
【文檔編號】G08G1/01GK103680143SQ201310744246
【公開日】2014年3月26日 申請日期:2013年12月30日 優先權日:2013年12月30日
【發明者】馬三立 申請人:北京世紀高通科技有限公司