全部產品
Search
文件中心

IoT Platform:資料轉寄到時序資料庫(TSDB)

更新時間:Jun 30, 2024

您可以配置資料流轉規則,將處理過的資料轉寄到時序資料庫(TSDB)的執行個體中儲存。本文介紹將資料流轉到資料目的地的完整流程。

前提條件

  • 已確認當前物聯網平台執行個體及所在地區支援將資料轉寄到時序資料庫(TSDB)。

  • 已在日本(東京)地區建立專用網路下的TSDB執行個體。詳細內容,請參見時間序列資料庫TSDB文檔
  • 已建立資料轉寄規則和編寫處理資料的SQL。具體操作,請參見設定資料流轉規則

背景資訊

轉寄的資料目的配置完成後,會自動完成以下配置,實現裝置資料通過物聯網平台的規則引擎轉寄到時序資料庫(TSDB)。

  • 物聯網平台佔用TSDB執行個體所在虛擬交換器的2個IP地址;將虛擬交換器的IPv4網段配置到TSDB執行個體的白名單中。
  • 在TSDB執行個體所在的VPC網路下建立託管安全性群組,安全性群組名稱預設以sg-nsm-開頭。

限制說明

  • 僅支援同地區轉寄。例如:日本(東京)的物聯網平台執行個體資料只能轉寄到日本(東京)的TSDB執行個體中。
  • 僅支援轉寄到Virtual Private Cloud下的TSDB執行個體。
  • 僅支援轉寄JSON格式資料。
  • 轉寄的訊息中,除了配置為timestamptag值的欄位外,其他欄位都將作為metric寫入時序資料庫。metric的資料類型支援數值型、字串,其他類型會導致寫入資料庫失敗。

使用說明

目前,新版和舊版雲產品流轉功能均支援將資料流轉到時序資料庫(TSDB)。新版雲產品流轉使用樣本,請參見新版:資料轉寄到時序資料庫(TSDB)

操作步驟

  1. 登入物聯網平台控制台

  2. 執行個體概覽頁簽的全部環境下,找到對應的執行個體,單擊執行個體卡片。

  3. 在左側導覽列,選擇訊息轉寄 > 雲產品流轉

  4. 單擊規則對應的查看,進入資料流轉規則頁面。

    重要

    若當前頁面為雲產品流轉新版頁面,需先單擊右上方返回舊版,再單擊目標規則對應的查看

  5. 單擊轉寄資料一欄對應的添加操作

  6. 添加操作對話方塊中,選擇操作為儲存到時序資料庫(TSDB)中。按照介面提示,設定其他資訊,單擊確認
    參數描述
    選擇操作選擇儲存到時序資料庫(TSDB)中
    地區固定為您的物聯網平台執行個體所在地區:日本(東京)
    TSDB執行個體選擇資料轉寄目標為您已建立的Virtual Private Cloud下的TSDB執行個體。
    metric資料類型選擇metric的資料類型。支援數值型字串

    更多資訊,可單擊協助按鈕協助查看。

    timestamp時間戳記。支援:
    • 使用轉義符${}運算式,例如${time},表示取值為資料來源Topic訊息中time欄位對應的值。
    • 使用資料流轉函數timestamp(),表示取值為資料流轉伺服器的時間戳記。
    • 輸入值,必須為Unix時間戳記,例如1404955893000。
    tag名稱設定標記資料的標籤名。支援中文漢字、英文字母、數字和特殊字元,包括:半形冒號(:)、逗號(,)、英文句號(.)、單引號(')、正斜線(/)、短劃線(-)、底線(_)、圓括弧(())、方括弧([])。
    tag值設定標籤值。支援:
    • 使用轉義符${}運算式。例如,資料來源Topic的訊息結構中,包含一個位置屬性,標識符為city,則可以指定標籤值為${city},表示訊息中city欄位對應的值。建議使用此方式。
    • 使用資料流轉函數規定的一些函數,例如deviceName(),表示標籤值為裝置名稱。支援的函數,請參見函數列表
    • 輸入常量,例如beijing。支援輸入中文漢字、英文字母、數字和特殊字元,包括:半形冒號(:)、逗號(,)、英文句號(.)、單引號(')、正斜線(/)、短劃線(-)、底線(_)、圓括弧(())、方括弧([])。
    說明
    • 最多可添加8個tag名稱、tag值。
    • 需保證TSDB能夠擷取到配置的tag名稱和值,如果擷取不到任意一個tag的名稱和值,會導致寫入資料庫失敗。
    角色授權物聯網平台將資料寫入TSDB。
  7. 回到雲產品流轉頁,單擊規則對應的啟動按鈕啟動規則。

資料流轉樣本

樣本規則的SQL:

SELECT time,city,power,distance FROM "/alprodu****/myDevice/user/update";

規則引擎根據SQL處理資料和寫入資料到TSDB如下。

  1. 根據該SQL,規則引擎從Topic /alprodu****/myDevice/user/update的訊息中,篩選出timecitypower、和distance欄位內容,作為轉寄的訊息內容。

    通過以上SQL處理後的轉寄訊息內容樣本如下:

    {
    "time": 1513677897,
    "city": "beijing",
    "distance": 8545,
    "power": 93.0
    }
  2. 根據已配置的資料流轉操作,規則引擎向TSDB中寫入的兩條資料。

    樣本中寫入TSDB的資料如下:

    • 資料: timestamp:1513677897, [metric:power value:93.0]
      tag: cityName=beijing
    • 資料: timestamp:1513677897, [metric:distance value:8545]
      tag: cityName=beijing

    寫入TSDB的資料說明:

    以上轉寄的訊息中,除了配置為timestamptime欄位和配置為tag值city欄位外,其他欄位(powerdistance)都作為metric寫入時序資料庫。