IoT传感器数据清理器 + InfluxDB日志记录器 n8n工作流 | Webhook Function InfluxDB
n8n,IoT传感器,InfluxDB,数据清理,时间序列数据,Webhook,自动化,环境监测

此工作流通过Webhook接收来自IoT设备的原始传感器数据,应用基本清理和转换逻辑,并将清理后的数据写入InfluxDB实例进行时间序列跟踪。非常适合使用Grafana或Chronograf等仪表板的可再生能源站点、智能农场和环境监测设置。

⚡ 快速实施步骤
将工作流JSON导入您的n8n实例。
编辑Set Config节点以包含您的InfluxDB凭据和测量名称。
在您的IoT设备或表单中使用Webhook URL (/webhook/sensor-data)发送传感器数据。
直接在InfluxDB中开始监控您的数据!

🎯 适用对象
IoT开发人员和集成商。
可再生能源和环境监测团队。
处理时间序列数据的数据工程师。
智能农业和公用事业自动化平台。

🛠 要求
工具 用途
n8n实例 用于自动化
InfluxDB (v1或v2) 存储时间序列传感器数据
IoT设备或平台 POST传感器数据
Function节点 过滤和转换数据

🧠 功能描述
通过HTTP POST接受JSON格式的传感器数据。
验证数据(移除无效或噪声读数)。
应用转换(四舍五入、时间戳格式化)。
将清理后的数据推送到InfluxDB进行实时可视化。

🧩 工作流组件
Webhook节点:暴露HTTP端点以接收传感器数据。
Function节点:过滤超出范围的值,格式化时间戳,四舍五入数据。
Set节点:存储可配置值,如InfluxDB主机、用户/密码和测量名称。
InfluxDB节点:将有效记录写入指定的数据库桶。

🔧 设置步骤 – 逐步指南

导入工作流:
将提供的.json文件上传到您的n8n工作区。

编辑配置节点:
在Set Config节点中更新InfluxDB连接信息:
influxDbHost, influxDbDatabase, influxDbUsername, influxDbPassword
measurement:您想要命名的数据集(例如,sensor_readings)

发送数据到Webhook:
Webhook URL:https://your-n8n/webhook/sensor-data
示例有效载荷:
{
“temperature”: 78.3,
“humidity”: 44.2,
“voltage”: 395.7,
“timestamp”: “2024-06-01T12:00:00Z”
}

在InfluxDB中查看:
登录您的InfluxDB/Grafana仪表板并查询新的测量。

✨ 如何自定义
自定义 方法
添加更多字段(例如,wind_speed) 更新Function和InfluxDB节点
添加字段/单位转换 在Function节点中使用数学
在异常时发送电子邮件警报 在Function节点后添加IF → Email分支
并行存储在Google Sheets中 添加Google Sheets节点进行混合日志记录

➕ 附加功能(高级)
附加功能 描述
📊 Grafana集成 使用InfluxDB的实时图表
📧 故障数据电子邮件通知 如果电压 < 0或温度过高则通知
🧠 AI过滤 添加OpenAI或TensorFlow进行异常检测
🗃 双重日志记录 将数据同时保存到InfluxDB和BigQuery/Sheets

📈 用例示例
远程太阳能逆变器通过Webhook发送温度和电压。
环境传感器中心每分钟记录湿度和空气质量数据。
智能温室记录气候控制传感器指标。
边缘IoT设备定期远程报告健康和诊断信息。

🧯 故障排除指南
问题 原因 解决方案
InfluxDB中无数据记录 无效凭据或数据库名称 重新检查配置中的InfluxDB值
Webhook未触发 错误的方法或端点 确认是POST到/webhook/sensor-data
数据被过滤 读数超出有效范围 检查Function节点中的逻辑
数据未出现在仪表板中 Influx写入格式错误 检查InfluxDB日志和字段名称

📞 需要帮助?
需要将此工作流集成到您的能源监测系统中,或需要为您构建InfluxDB仪表板?

👉 联系WeblineIndia | 工作流自动化和时间序列分析专家。

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。