簡介本資源是面向 Node-RED 與 InfluxDB 集成開發(fā)者的節(jié)點(diǎn)擴(kuò)展包用于在 Node-RED 流程中向 InfluxDB 時(shí)間序列數(shù)據(jù)庫寫入和查詢數(shù)據(jù)。它同時(shí)兼容 InfluxDB 1.x、1.8 與 2.0 三個(gè)版本通過配置節(jié)點(diǎn)中的版本組合框切換分別調(diào)用 writePoints()、query() 方法或基于 Flux 的客戶端庫完成數(shù)據(jù)交互適合需要搭建物聯(lián)網(wǎng)數(shù)據(jù)采集、監(jiān)控看板或時(shí)序數(shù)據(jù)管道的初中級(jí)開發(fā)者。壓縮包共 18 個(gè)文件約 28KB包含節(jié)點(diǎn)主邏輯 js、界面定義 html、多語言 locales、圖標(biāo) png、依賴清單 package.json 與 package-lock.json以及 docker-compose.yml、influxdb.conf、SSL 證書與測試流 json 等配套文件便于快速部署與驗(yàn)證。目前已有 1638 人學(xué)習(xí)下載。借助該資源讀者可省去從零封裝 InfluxDB 客戶端的成本直接獲得可運(yùn)行的節(jié)點(diǎn)源碼、版本兼容處理思路與測試流示例快速接入現(xiàn)有 Node-RED 工程并完成數(shù)據(jù)寫入與查詢調(diào)試。1. 從一條產(chǎn)線溫度曲線說起node-red-contrib-influxdb 到底解決什么問題去年幫一家做注塑機(jī)的客戶排查數(shù)據(jù)丟失問題他們的架構(gòu)很典型車間里 12 臺(tái)設(shè)備通過 Modbus 把溫度、壓力、節(jié)拍傳到 Node-REDNode-RED 再寫進(jìn) InfluxDB最后用 Grafana 出看板。上線三個(gè)月看板上偶爾出現(xiàn)斷點(diǎn)但重啟 Node-RED 又好了。翻日志才發(fā)現(xiàn)他們用的是influxdb out節(jié)點(diǎn)默認(rèn)配置批量寫沒調(diào)網(wǎng)絡(luò)抖動(dòng)時(shí)整批數(shù)據(jù)被丟棄而節(jié)點(diǎn)本身不報(bào)錯(cuò)。這就是 node-red-contrib-influxdb 這類節(jié)點(diǎn)的真實(shí)處境——它把 InfluxDB 的寫入和查詢封裝成拖拽節(jié)點(diǎn)降低了門檻但也把一堆時(shí)序數(shù)據(jù)庫的細(xì)節(jié)藏進(jìn)了黑匣子不調(diào)參數(shù)就會(huì)在某個(gè)深夜翻車。node-red-contrib-influxdb 是 Node-RED 的一個(gè)社區(qū)節(jié)點(diǎn)包提供influxdb out和influxdb in兩類節(jié)點(diǎn)分別負(fù)責(zé)把消息寫入 InfluxDB、從 InfluxDB 查詢數(shù)據(jù)。它面向的是用 Node-RED 做 IoT 數(shù)據(jù)采集、邊緣計(jì)算、設(shè)備監(jiān)控的工程師尤其是那些不想在 Node-RED 里手寫 HTTP 請求或 InfluxDB 客戶端代碼的人。你只要在流里拖一個(gè)節(jié)點(diǎn)填上數(shù)據(jù)庫地址、bucket、measurement上游 msg.payload 就能落庫查詢節(jié)點(diǎn)則把 Flux 或 InfluxQL 查詢結(jié)果轉(zhuǎn)成 msg.payload 往下游送。適合誰適合已經(jīng)用 Node-RED 做協(xié)議轉(zhuǎn)換和規(guī)則引擎、需要把時(shí)序數(shù)據(jù)持久化并做歷史查詢的團(tuán)隊(duì)。不適合誰不適合需要毫秒級(jí)高頻寫入、或者要做復(fù)雜降采樣和連續(xù)查詢的場景那種情況直接上 Telegraf 或自研寫入服務(wù)更穩(wěn)。這一章先把邊界劃清楚后面幾章拆配置、拆查詢、拆踩坑。2. 裝節(jié)點(diǎn)、連庫、跑通第一條寫入流node-red-contrib-influxdb 的最小閉環(huán)2.1 安裝方式與版本選擇別在 Node-RED 的 palette 里盲目點(diǎn)安裝常見做法有兩種在 Node-RED 編輯器右上角菜單里選「節(jié)點(diǎn)管理」搜node-red-contrib-influxdb點(diǎn)安裝或者進(jìn)到 Node-RED 用戶目錄用 npm 裝。我一般用后者因?yàn)槟芸辞灏姹竞鸵蕾嚦鰡栴}也好回滾。# 進(jìn)入 Node-RED 的用戶目錄通常是 ~/.node-red cd ~/.node-red # 安裝指定版本避免拉到不兼容的最新版 npm install node-red-contrib-influxdb3.6.0 # 查看已安裝版本和依賴樹 npm ls node-red-contrib-influxdb邏輯說明Node-RED 加載節(jié)點(diǎn)包是從用戶目錄的 node_modules 里找的直接 npm 裝能保證路徑正確。參數(shù)說明版本號(hào)不是隨便寫的3.x 系列主要適配 InfluxDB 2.x 的 Flux 查詢和 Token 認(rèn)證如果你還在用 InfluxDB 1.8 的 InfluxQL要確認(rèn)節(jié)點(diǎn)版本是否還保留 v1 兼容模式。裝完重啟 Node-RED左側(cè)節(jié)點(diǎn)欄會(huì)出現(xiàn) influxdb 分類。注意不要同時(shí)裝多個(gè)來源的 influxdb 節(jié)點(diǎn)包命名沖突會(huì)讓編輯器加載失敗。2.2 配置 InfluxDB 連接URL、Token、Org、Bucket 四個(gè)字段怎么填在 Node-RED 里雙擊任意 influxdb 節(jié)點(diǎn)點(diǎn)服務(wù)器配置那一欄的鉛筆圖標(biāo)新建一個(gè)連接。以 InfluxDB 2.x 為例需要填四個(gè)關(guān)鍵字段。字段填什么常見錯(cuò)誤URLhttp://127.0.0.1:8086寫成 https 但服務(wù)沒開 TLSTokenInfluxDB 里生成的 API Token用了只讀 Token 卻要寫入Organization組織名或組織 ID填了顯示名但實(shí)際要 IDBucket存儲(chǔ)桶名桶不存在寫入靜默失敗配置完點(diǎn)「測試」或直接部署Node-RED 日志里如果出現(xiàn)Connected to InfluxDB就說明通了。如果報(bào) 401九成是 Token 或 Org 不對報(bào) 404檢查 URL 后面有沒有多寫/api/v2節(jié)點(diǎn)內(nèi)部會(huì)自己拼路徑。2.3 用 function 節(jié)點(diǎn)構(gòu)造行協(xié)議寫入節(jié)點(diǎn)的 msg.payload 到底要什么格式influxdb out節(jié)點(diǎn)對 msg.payload 的期望是 InfluxDB 的行協(xié)議字符串或者一個(gè)包含measurement、fields、tags、timestamp的對象。新手最容易在這里卡住直接扔一個(gè) JSON 對象進(jìn)去結(jié)果寫了個(gè)空。// function 節(jié)點(diǎn)里構(gòu)造行協(xié)議字符串 // 假設(shè)上游 msg.payload 是 {deviceId: press-01, temp: 186.5, pressure: 12.3} var p msg.payload; // 方式一拼行協(xié)議字符串measurement,tagvalue fieldvalue timestamp var line injection_machine,device p.deviceId temperature p.temp ,pressure p.pressure Date.now() 000000; msg.payload line; return msg;邏輯說明行協(xié)議格式是measurement,tag_keytag_value field_keyfield_value timestamptag 和 field 之間用空格分隔多個(gè) field 用逗號(hào)。參數(shù)說明時(shí)間戳單位是納秒Date.now()返回毫秒所以要乘 1000000上面用字符串拼了000000是等價(jià)寫法。如果不想手拼也可以傳對象msg.payload { measurement: injection_machine, tags: { device: p.deviceId }, fields: { temperature: p.temp, pressure: p.pressure }, timestamp: new Date() }; return msg;節(jié)點(diǎn)會(huì)自動(dòng)轉(zhuǎn)成行協(xié)議。兩種方式都行手拼性能略好對象方式可讀性高。寫入節(jié)點(diǎn)還有一個(gè)「Precision」選項(xiàng)默認(rèn)納秒如果你傳的是秒級(jí)時(shí)間戳要改成秒否則數(shù)據(jù)會(huì)跑到 1970 年。2.4 部署后驗(yàn)證用 influxdb in 節(jié)點(diǎn)或 CLI 確認(rèn)數(shù)據(jù)真的落庫寫完別急著接看板先用查詢節(jié)點(diǎn)或命令行確認(rèn)。InfluxDB 2.x 的 CLI 命令# 查詢最近 5 分鐘寫入的數(shù)據(jù) influx query from(bucket:iot) | range(start: -5m) | filter(fn:(r) r._measurement injection_machine) --org myorg --token $INFLUX_TOKEN如果返回空先看 Node-RED 調(diào)試窗口有沒有報(bào)錯(cuò)再看 InfluxDB 的_monitoring桶里有沒有寫入失敗記錄。常見原因是 bucket 名拼錯(cuò)、Token 權(quán)限不足、或者時(shí)間戳精度不匹配。這一步跑通最小閉環(huán)就成了。3. 查詢節(jié)點(diǎn)怎么用Flux 查詢、時(shí)間范圍與結(jié)果解析3.1 influxdb in 節(jié)點(diǎn)的三種查詢模式Query、Query With Params、Raw Outputinfluxdb in節(jié)點(diǎn)在 InfluxDB 2.x 模式下支持幾種查詢方式。最常用的是直接寫 Flux 查詢語句節(jié)點(diǎn)把結(jié)果轉(zhuǎn)成數(shù)組塞進(jìn) msg.payload。第二種是帶參數(shù)的查詢可以在流里動(dòng)態(tài)傳時(shí)間范圍或過濾條件。第三種是 Raw Output返回原始響應(yīng)適合自己解析。// 在 influxdb in 節(jié)點(diǎn)里寫 Flux 查詢 from(bucket: iot) | range(start: -1h) | filter(fn: (r) r._measurement injection_machine) | filter(fn: (r) r._field temperature) | aggregateWindow(every: 1m, fn: mean)邏輯說明range決定時(shí)間窗口filter按 measurement 和 field 過濾aggregateWindow做降采樣。參數(shù)說明every: 1m表示每分鐘一個(gè)聚合點(diǎn)fn: mean取平均。如果查詢結(jié)果要往下游送節(jié)點(diǎn)輸出的 msg.payload 是一個(gè)對象數(shù)組每個(gè)元素包含_time、_value、_field等字段。注意Flux 查詢默認(rèn)返回的是表結(jié)構(gòu)節(jié)點(diǎn)會(huì)做扁平化如果結(jié)果集很大建議在查詢里就做 limit 或 aggregateWindow別把原始點(diǎn)全拉回來。3.2 動(dòng)態(tài)時(shí)間范圍用 msg 參數(shù)替換硬編碼的 range硬編碼-1h只能看固定窗口實(shí)際項(xiàng)目里經(jīng)常要根據(jù)用戶選擇或告警觸發(fā)查不同時(shí)間段。做法是在 influxdb in 節(jié)點(diǎn)里勾選「Query With Params」然后在查詢里用params.start這類占位。// 上游 function 節(jié)點(diǎn)設(shè)置查詢參數(shù) msg.query from(bucket:iot) | range(start: params.start, stop: params.stop) | filter(fn:(r) r._measurement injection_machine); msg.params { start: -24h, stop: now() }; return msg;邏輯說明節(jié)點(diǎn)會(huì)把 msg.params 里的鍵值對注入到 Flux 查詢的 params 命名空間。參數(shù)說明start 和 stop 可以是相對時(shí)間字符串也可以是 RFC3339 時(shí)間戳。注意如果 params 里傳了用戶輸入要做校驗(yàn)別直接拼進(jìn)查詢Flux 雖然不像 SQL 那樣容易注入但錯(cuò)誤的時(shí)間格式會(huì)讓查詢直接失敗。3.3 查詢結(jié)果轉(zhuǎn)圖表msg.payload 到 ECharts 或 Dashboard 的中間處理查詢節(jié)點(diǎn)吐出來的數(shù)組不能直接喂給圖表通常要在后面接一個(gè) function 節(jié)點(diǎn)做轉(zhuǎn)換。// 把 influxdb in 的輸出轉(zhuǎn)成 ECharts 需要的格式 var rows msg.payload; var times []; var values []; rows.forEach(function (row) { times.push(new Date(row._time).toLocaleTimeString()); values.push(row._value); }); msg.payload { xAxis: times, series: values }; return msg;邏輯說明遍歷查詢結(jié)果把時(shí)間字段和值字段拆成兩個(gè)數(shù)組。參數(shù)說明_time是 InfluxDB 返回的標(biāo)準(zhǔn)時(shí)間字段_value是默認(rèn)值字段名如果你查詢里用了rename或自定義列字段名要對應(yīng)改。這一步做完接 node-red-dashboard 的 chart 節(jié)點(diǎn)或自定義 UI 都能直接用。4. 避坑與排查node-red-contrib-influxdb 最常見的 5 個(gè)翻車現(xiàn)場4.1 寫入成功但查不到數(shù)據(jù)時(shí)間戳精度和時(shí)區(qū)在作怪現(xiàn)象Node-RED 調(diào)試窗口顯示寫入成功InfluxDB CLI 查最近一小時(shí)卻是空的。原因?qū)懭牍?jié)點(diǎn) Precision 設(shè)成了納秒但上游傳的是秒級(jí)時(shí)間戳數(shù)據(jù)被寫到了 1970 年或者服務(wù)器時(shí)區(qū)是 UTC查詢時(shí)用了本地時(shí)間范圍。解決統(tǒng)一時(shí)間戳精度寫入節(jié)點(diǎn) Precision 和上游時(shí)間戳單位保持一致查詢時(shí)用range(start: -1h)這種相對時(shí)間別硬編碼本地時(shí)間字符串。4.2 批量寫入丟數(shù)據(jù)沒開批處理網(wǎng)絡(luò)一抖就整批丟現(xiàn)象看板偶爾斷點(diǎn)Node-RED 日志沒有明顯報(bào)錯(cuò)。原因influxdb out節(jié)點(diǎn)默認(rèn)逐條寫入網(wǎng)絡(luò)抖動(dòng)時(shí)單條失敗被靜默吞掉。解決在節(jié)點(diǎn)配置里開啟批量寫入設(shè)置 batch size 和 flush interval比如 100 條或 1 秒刷一次。同時(shí)在下游接一個(gè) catch 節(jié)點(diǎn)把寫入失敗的消息轉(zhuǎn)到重試隊(duì)列或本地緩存。4.3 Token 權(quán)限不足只讀 Token 拿去寫入報(bào)錯(cuò)信息還很模糊現(xiàn)象寫入節(jié)點(diǎn)報(bào)unauthorized access或直接超時(shí)。原因InfluxDB 2.x 的 Token 分讀寫權(quán)限創(chuàng)建時(shí)如果只勾了讀寫入會(huì)被拒。解決在 InfluxDB 界面重新生成 Token確保對目標(biāo) bucket 有寫權(quán)限。注意Token 不要寫死在流里用環(huán)境變量或 Node-RED 的憑據(jù)存儲(chǔ)。4.4 查詢結(jié)果字段名對不上Flux 返回的列名和 InfluxQL 不一樣現(xiàn)象從 InfluxDB 1.x 遷到 2.x 后原來解析value字段的代碼全失效。原因Flux 查詢返回的默認(rèn)列名是_value、_time、_field而 InfluxQL 返回的是value、time。解決在 function 節(jié)點(diǎn)里做字段名映射或者查詢里用rename函數(shù)把列名改回舊格式。遷移時(shí)這一步最容易漏。4.5 Node-RED 重啟后連接失效連接池沒釋放舊連接占著端口現(xiàn)象重啟 Node-RED 后influxdb 節(jié)點(diǎn)報(bào)連接超時(shí)但 InfluxDB 本身正常。原因節(jié)點(diǎn)內(nèi)部維護(hù)了 HTTP 連接池異常退出時(shí)舊連接沒釋放新進(jìn)程復(fù)用端口沖突。解決在 Node-RED 的 settings.js 里配置httpNodeKeepAlive相關(guān)參數(shù)或者重啟前先停流再停服務(wù)。更穩(wěn)妥的做法是給 influxdb 節(jié)點(diǎn)配置里加上重試間隔讓它自己恢復(fù)。5. 進(jìn)階用 node-red-contrib-influxdb 做降采樣與告警聯(lián)動(dòng)的兩個(gè)實(shí)用技巧第一個(gè)技巧是寫入時(shí)直接做降采樣別等查詢時(shí)再算。很多團(tuán)隊(duì)把原始點(diǎn)全量寫入 InfluxDB查詢時(shí)用aggregateWindow現(xiàn)算數(shù)據(jù)量一大查詢就慢。更好的做法是在 Node-RED 里用join節(jié)點(diǎn)攢一批數(shù)據(jù)算好分鐘均值再寫入InfluxDB 里存的就是降采樣后的結(jié)果。具體做法join節(jié)點(diǎn)按時(shí)間窗口聚合后面接 function 算均值再進(jìn)influxdb out。這樣寫入量降一個(gè)數(shù)量級(jí)查詢幾乎秒回。參數(shù)上join 節(jié)點(diǎn)的timeout設(shè)成和降采樣窗口一致比如 60 秒。第二個(gè)技巧是把查詢節(jié)點(diǎn)和告警聯(lián)動(dòng)。用influxdb in定時(shí)查詢最近 5 分鐘的最大值如果超過閾值直接觸發(fā)通知流。關(guān)鍵是查詢里用| max()而不是把原始點(diǎn)拉回來自己算讓 InfluxDB 做它擅長的事。// 定時(shí)查詢最近5分鐘最大值并判斷告警 var rows msg.payload; if (rows.length 0 rows[0]._value 200) { msg.payload { alert: true, device: rows[0].device, value: rows[0]._value, time: rows[0]._time }; return [msg, null]; // 第一路輸出告警 } return [null, msg]; // 第二路輸出正常邏輯說明查詢節(jié)點(diǎn)返回的數(shù)組按時(shí)間排序取第一條就是最新值。參數(shù)說明閾值 200 按實(shí)際業(yè)務(wù)改device字段來自查詢結(jié)果里的 tag 列。這個(gè)流跑起來后告警延遲基本在秒級(jí)比輪詢數(shù)據(jù)庫再判斷快得多。我自己踩過最深的坑是早期沒開批量寫入產(chǎn)線網(wǎng)絡(luò)一抖就丟一批數(shù)據(jù)客戶半夜打電話說看板斷了。后來把 batch size 設(shè)成 50、flush interval 設(shè)成 2 秒再?zèng)]出過整批丟的情況。時(shí)序數(shù)據(jù)這東西寫入路徑上的每個(gè)參數(shù)都值得摳一遍別等丟了數(shù)據(jù)才后悔。希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取