物聯網數據分析提供了SQL分析功能,支持分析設備上報云端的數據,或通過SQL將分析后的決策結果下發至設備進行遠程控制。您也可將SQL數據分析任務封裝成數據API,方便開發者調用,既可直接響應設備端請求,也可用來做服務端數據對接。

數據分析

  1. 登錄數據分析控制臺,在頂部導航欄上選擇分析透視,單擊SQL分析頁簽。
    SQL分析
  2. 單擊新建SQL分析,在新建SQL分析對話框輸入分析名稱和描述信息。
    新建文件夾
  3. 單擊確認
    SQL數據分析工作臺頁面,默認選擇了數據表設備數據源,可修改為外部數據源業務模型數據源
    說明 本文圖片所示為默認主題(亮色)。物聯網數據分析支持設置工作臺主題樣式功能,您可單擊工作臺右上角的設置按鈕設置,修改主題為暗色主題
    SQL分析工作臺

    您也可單擊物標簽,選擇目標產品后,根據物標簽進行SQL數據分析。下面以數據表示例介紹SQL分析過程。

    物標簽
  4. SQL數據分析工作臺,編寫SQL語句。
    編輯SQL語句

    SQL語句中需要使用的表信息,可從相應表目錄下找到并將鼠標移動到目標數據表,單擊右側的復制表名稱預覽數據表圖標來獲取。

    有關系統數據表和外部數據表詳細說明,請參見如何使用數據表

    如果您需要查詢表數據,可選中目標數據表后,在頁面左下方列信息表格中,選中需要查詢的字段,單擊下方的生成查詢SQL,右側SQL編輯框中會快速生成相應的SQL語句。

    SQL數據分析工作臺提供了多種SQL語句模板,單擊SQL編輯框右上角的模板導入,可查看或導入SQL語句。如下圖所示。

    SQL模板
  5. 編寫完成SQL語句后,可根據需要對SQL語句執行如下操作。
    操作說明
    保存保存已編寫的SQL語句。保存不檢驗語法錯誤,會直接保存內容。
    運行運行已編寫的SQL語句。
    說明 保證語句成功運行,建議您在運行語句前進行語法校驗
    • 如果SQL語法正確并且存在查詢結果時,結果信息將會在結果框中展示,其中字段名會展示在第一行。
    • 如果SQL語法存在錯誤,則系統提示執行失敗。
    停止取消已運行的SQL語句。此按鈕在運行SQL語句后可生效。
    定時任務定時執行SQL,運行離線任務。單擊定時任務圖標后,在彈出窗口中打開定時開關。
    • 生效日期:定時運行的生效日期區間。
    • 調度周期:定時運行的調度周期,可以選擇分鐘、小時、周、月。
      您可根據設置的周期單位,進行以下設置。
      • 指定時間:指定定時運行具體在哪個時間運行。
      • 具體時間:定時運行任務在指定時間的具體哪個時間段運行。
    SQL校驗對已編寫的SQL語句進行語法校驗。
    執行SQL語句后:
    • 可在運行日志頁面查看SQL語句運行信息。
      運行日志示例和每一行信息說明如下。
      2019-04-30 17:59:23 -- startPoint:[]   #執行參數信息
      2019-04-30 17:59:23 -- updatePipelineToActive:success   #Pipeline激活狀態
      2019-04-30 17:59:23 -- checkWorkFlow:workflow is INTERACTIVE   #檢查WorkFlow類型
      2019-04-30 17:59:23 -- checkTransformer:transformer is 99d*****724b1a5   #執行的TransformerUid
      2019-04-30 17:59:23 -- dispatchToTaskExecutor:success   #獲取對應計算平臺的執行器
      2019-04-30 17:59:23 -- addMaxLimit:success   #補全分頁限制
      2019-04-30 17:59:23 -- callType:sync   #同步執行/異步執行
      2019-04-30 17:59:25 -- updateWorkflowToStandBy:success   #成功后更新WorkFlow狀態
    • 若執行成功,可在結果頁面查看語句執行結果。結果框中最多返回200條查詢結果,如果您有更多數據查詢需求,請單擊右側CSV下載,下載任務的1000條查詢結果。
    • 若執行失敗,可在運行日志頁面查看錯誤信息。

      錯誤日志示例和每一行信息說明如下。

      2019-04-30 15:31:33 -- startPoint:[]   #執行參數信息
      2019-04-30 15:31:33 -- updatePipelineToActive:success   #Pipeline激活狀態
      2019-04-30 15:31:33 -- checkWorkFlow:workflow is INTERACTIVE   #檢查WorkFlow類型
      2019-04-30 15:31:33 -- checkTransformer:transformer is 426*****5286502   #執行的TransformerUid
      2019-04-30 15:31:33 -- dispatchToTaskExecutor:success   #獲取對應計算平臺的執行器
      2019-04-30 15:31:33 -- addMaxLimit:success   #補全分頁限制
      2019-04-30 15:31:33 -- callType:sync   #同步執行/異步執行
      2019-04-30 15:31:33 -- taskExecuted:engine error, traceId 644*****03d05dd   #提示執行錯誤并輸出了此次調用的traceId
      2019-04-30 15:31:33 -- taskExecuted:INSERT statement has mismatched column types   #具體錯誤原因

生成一個數據API

數據API即數據服務。您可通過SDK調用數據API,將數據嵌入到其他應用程序中進行可視化展示。更多信息請參見如何使用數據服務

  1. SQL數據分析工作臺完成SQL數據分析,詳細內容請參見數據分析
  2. 在頁面右上角單擊配置圖標,如下圖所示。
    SQL分析配置
  3. 在右側頁面中,配置相關參數后單擊應用
    API配置
    參數 說明
    請求參數即在SQL分析作時您自己設定的請求參數

    支持自定義相關配置。

    返回參數所有返回參數都可在SQL分析工作臺下方的結果中看到。

    支持自定義相關配置。

    高級設置展開后:
    • 選中開啟返回結果分頁復選框,當數據量很大時,可以分頁顯示。
    • 清除開啟返回結果分頁復選框,則默認可返回最多2000條記錄。
  4. 單擊SQL數據分析工作臺右上角的測試API圖標測試,在測試數據服務頁面配置請求參數的值后單擊開始測試,測試成功后如下圖所示。
    API測試
  5. 測試成功后,單擊右下角關閉,返回SQL數據分析工作臺頁面。
  6. 單擊頁面右上角的發布按鈕發布,并單擊確定
    完成數據API生成后,單擊查看按鈕查看,可在數據服務詳情頁查看具體的API信息。

    您也可單擊撤回發布,重新編輯SQL語句。

    SQL分析發布后

    SQL分析頁簽,該SQL分析的狀態顯示為已發布

    發布后顯示