[發明專利]引擎查詢控制方法、系統、設備及存儲介質

在審

• 申請號: 202011289165.7
• 申請日: 2020-11-17
• 公開（公告）號: CN112269808A
• 公開（公告）日: 2021-01-26
• 發明（設計）人: 楊洋;洪傳強
• 申請（專利權）人: 攜程旅游網絡技術（上海）有限公司
• 主分類號: G06F16/2457
• 分類號: G06F16/2457;G06F16/248;G06F16/2453;G06F9/54
• 代理公司: 上海隆天律師事務所 31282
• 代理人: 夏彬

本發明提供了一種引擎查詢控制方法、系統、設備及存儲介質，該方法包括：通過消息隊列實時采集查詢引擎的查詢日志；根據所述查詢日志，采用數據流計算引擎判斷是否滿足預設的查詢禁售條件；如果是，則拒絕將接收到的查詢請求發送至所述查詢引擎。本發明根據實時分析各個引擎的查詢日志的分析結果，自動判斷是否發送本次查詢請求，從而實現根據需要的引擎查詢自動控制。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種引擎查詢控制方法、系統、設備及存儲介質。

背景技術

GDS(Global Distribution System，全球分銷系統)Shopping(購買)引擎請求外部API(Application Programming Interface，應用程序接口)是有成本的，計算成本的方式是L2B(Look to book，搜索量與實際預訂的比例)低于某個預設閾值時不收費，超過某個閾值時則按單次訪問收費，因此，無轉化率的查詢會帶來查詢成本的增加。Travelfusion和CSD引擎雖然沒有查詢成本，但是由于航司和供應商的服務不穩定，當外部服務出現異常時，會影響查詢功能的正常使用。

發明內容

針對現有技術中的問題，本發明的目的在于提供一種引擎查詢控制方法、系統、設備及存儲介質，根據實時分析各個引擎的查詢日志的分析結果，自動判斷是否發送本次查詢請求，從而實現根據需要的引擎查詢自動控制。

本發明實施例提供一種引擎查詢控制方法，包括如下步驟：

通過消息隊列實時采集查詢引擎的查詢日志；

根據所述查詢日志，采用數據流計算引擎判斷是否滿足預設的查詢禁售條件；

如果是，則拒絕將接收到的查詢請求發送至所述查詢引擎。

可選地，所述消息隊列為Kafka消息隊列。

可選地，所述數據流計算引擎為Flink數據流計算引擎。

可選地，所述查詢日志包括查詢數據和預訂數據，所述數據流計算引擎配置為采用如下步驟判斷是否滿足預設的查詢禁售條件：

所述數據流計算引擎從所述消息隊列中獲取所述查詢引擎的查詢數據和預訂數據；

所述數據流計算引擎計算所述查詢引擎在過去預設時間段內的有效查詢率，所述有效查詢率等于過去預設時間段內的預訂量與查詢量的比值；

所述數據流計算引擎判斷所述有效查詢率是否小于第一閾值；

如果是，則所述數據流計算引擎判斷滿足預設的查詢禁售條件。

可選地，所述數據流計算引擎配置為采用如下步驟判斷是否滿足預設的查詢禁售條件：

所述數據流計算引擎從所述消息隊列中獲取所述查詢引擎的查詢日志；

所述數據流計算引擎計算所述查詢引擎在過去預設時間段內的查詢成功率，所述查詢成功率為過去預設時間段內的查詢成功量與查詢總量的比值；

所述數據流計算引擎判斷所述查詢成功率是否小于第二閾值；

如果是，則所述數據流計算引擎判斷滿足預設的查詢禁售條件。

可選地，所述拒絕將接收到的查詢請求發送至所述查詢引擎，包括設定禁售時間，于所述禁售時間內拒絕將接收到的查詢請求發送至所述查詢引擎。

可選地，所述數據流計算引擎配置為采用如下步驟判斷是否滿足預設的查詢禁售條件：

所述數據流計算引擎判斷所述查詢日志的類別；

所述數據流計算引擎判斷是否滿足所述查詢日志的類別所對應的預設的查詢禁售條件。