本文以采集樓層中傳感器數(shù)據(jù)為例,介紹將數(shù)據(jù)轉(zhuǎn)發(fā)至?xí)r序數(shù)據(jù)庫(kù)(TSDB)的數(shù)據(jù)流轉(zhuǎn)規(guī)則設(shè)置。

前提條件

在物聯(lián)網(wǎng)平臺(tái)控制臺(tái)創(chuàng)建傳感器產(chǎn)品和設(shè)備,并將設(shè)備連接到物聯(lián)網(wǎng)平臺(tái)。具體操作,請(qǐng)參見(jiàn)快速入門(mén)
說(shuō)明 本示例未使用物模型,設(shè)備使用自定義Topic上報(bào)數(shù)據(jù)。

背景信息

在No-1大廈的兩個(gè)樓層中(例如,F(xiàn)1和F2層),每層分布2個(gè)傳感器來(lái)記錄該樓層的溫度、濕度、PM2.5、甲醛含量等環(huán)境信息。

傳感器每5秒采集一次環(huán)境數(shù)據(jù)并上報(bào)至物聯(lián)網(wǎng)平臺(tái),物聯(lián)網(wǎng)平臺(tái)通過(guò)設(shè)置好的數(shù)據(jù)流轉(zhuǎn)規(guī)則將環(huán)境數(shù)據(jù)轉(zhuǎn)發(fā)到TSDB。您可以利用TSDB的空間聚合和降采樣能力輕松實(shí)現(xiàn)數(shù)據(jù)統(tǒng)計(jì)與分析。

上報(bào)數(shù)據(jù)說(shuō)明

  • 數(shù)據(jù)上報(bào)頻率:1次/5s。
  • 數(shù)據(jù)上報(bào)自定義Topic:/${productKey}/${deviceName}/user/data
  • payload格式:
    {"temperature":25,"humidity":24,"pm25":11,"hcho":0.02}

配置規(guī)則

配置規(guī)則引擎數(shù)據(jù)流轉(zhuǎn)規(guī)則,將設(shè)備上報(bào)的數(shù)據(jù)轉(zhuǎn)發(fā)至TSDB。

  1. 登錄物聯(lián)網(wǎng)平臺(tái)控制臺(tái)
  2. 實(shí)例概覽頁(yè)面,找到對(duì)應(yīng)的實(shí)例,單擊實(shí)例進(jìn)入實(shí)例詳情頁(yè)面。
    重要 目前華東2(上海)、華北2(北京)、華南1(深圳)地域開(kāi)通了企業(yè)版實(shí)例服務(wù)。其他地域,請(qǐng)?zhí)^(guò)此步驟。
    實(shí)例概覽
  3. 在左側(cè)導(dǎo)航欄選擇消息轉(zhuǎn)發(fā) > 云產(chǎn)品流轉(zhuǎn),然后單擊創(chuàng)建規(guī)則,創(chuàng)建JSON數(shù)據(jù)格式規(guī)則。
    重要 若當(dāng)前頁(yè)面顯示新版功能,先單擊右上角返回舊版,進(jìn)入舊版功能頁(yè)面,再單擊創(chuàng)建規(guī)則
  4. 編寫(xiě)處理數(shù)據(jù)的SQL。本示例中的SQL如下:
    具體操作,請(qǐng)參見(jiàn)設(shè)置數(shù)據(jù)流轉(zhuǎn)規(guī)則
    SELECT deviceName() as deviceName, timestamp() as time, attribute('floor') as floor, attribute('building') as building, temperature, humidity, pm25, hcho FROM "/${productKey}/+/user/data"
  5. 單擊轉(zhuǎn)發(fā)數(shù)據(jù)一欄的添加操作,設(shè)置數(shù)據(jù)轉(zhuǎn)發(fā)目的地。

    設(shè)置參數(shù),將數(shù)據(jù)轉(zhuǎn)發(fā)到一個(gè)VPC實(shí)例下的TSDB。

    設(shè)備數(shù)據(jù)流轉(zhuǎn)

查詢(xún)時(shí)序數(shù)據(jù)

查詢(xún)物聯(lián)網(wǎng)平臺(tái)發(fā)送到TSDB的數(shù)據(jù)。

  1. 登錄TSDB控制臺(tái)
  2. 實(shí)例列表中找到存儲(chǔ)數(shù)據(jù)的VPC實(shí)例,并單擊右側(cè)管理
  3. 在左側(cè)導(dǎo)航欄單擊時(shí)序數(shù)據(jù)管理 > 慢查詢(xún)?nèi)罩?/span>,查詢(xún)物聯(lián)網(wǎng)平臺(tái)發(fā)送到實(shí)例中的數(shù)據(jù)。具體操作,請(qǐng)參見(jiàn)慢查詢(xún)?nèi)罩?/a>。