reTerminal DM 和 Machinechat JEDI：您的工业物联网强大工具

note

本文档由 AI 翻译。如您发现内容有误或有改进建议，欢迎通过页面下方的评论区，或在以下 Issue 页面中告诉我们：https://github.com/Seeed-Studio/wiki-documents/issues

简介

Machinechat JEDI 是一款功能强大且多用途的物联网 (IoT) 数据管理软件。它旨在简化从各种设备、传感器和机器中收集、可视化、监控和响应实时数据的过程。Seeed 的 reTerminal DM 和 Machinechat JEDI 软件可以让您在 30 分钟内构建自定义仪表板。跟踪操作、分析趋势、提高效率，并接收及时警报以防止代价高昂的中断。

入门指南

在开始此项目之前，您可能需要按照以下说明提前准备好硬件和软件。

硬件准备

reTerminal DM	XIAO ESP32C3

立即购买 🖱️	立即购买 🖱️

软件准备

我们建议从 Raspberry Pi 官方网站安装 Bullseye 版本的 64 位操作系统。

在 reTerminal DM 上安装 Machinechat JEDI

下载 JEDI

访问 Machinechat 网站，选择 JEDI 免费版或 JEDI Lite 试用版。

输入您的电子邮件地址。您将收到一封包含许可证信息和所有支持操作系统的下载链接的电子邮件。点击适合您操作系统的下载链接。本例中为 64 位 Raspberry Pi

解压并启动

下载的文件是一个 ZIP 压缩包。将内容解压到 reTerminal DM 上您选择的位置。

打开终端并执行以下命令。将 /path/to/jedi/folder 替换为文件夹位置。

cd /path/to/jedi/folder

启动 JEDI

./mcjedi.bin

访问 JEDI 的 Web 界面

在 reTerminal DM 上打开一个网页浏览器并输入

http://localhost:9123

设置和激活

阅读并接受最终用户许可协议 (EULA)，然后填写表单，提供用户名、密码以及用于密码恢复的安全问题答案。

使用您新创建的凭据登录。

输入下载邮件中提供的许可证密钥。JEDI 将短暂连接到互联网以验证并激活您的许可证。

快速测试

创建数据管道

在您的笔记本电脑上打开您喜欢的 Python IDE（如 PyCharm/VS Code）。复制并粘贴以下代码。

import requests
import json

url = 'http://<jedi_ip>:8100/v1/data/mc'  # 将 <jedi_ip> 替换为您的 reTerminal DM IP 地址

payload = {
    "context": {
        "target_id": "my_PC",
        "target_ip": "192.168.1.10"  # PC 的 IP 地址
    },
    "data": {
        "temperature": 25.5,
        "humidity": 68
    }
}

headers = {'Content-Type': 'application/json'}
response = requests.post(url, data=json.dumps(payload), headers=headers)

if response.status_code == 200:
    print('数据发送成功')
else:
    print('发送数据时出错:', response.text)

可视化与探索

仪表板时间！在导航面板上点击 Data Dashboard。此仪表板已为您预先创建。我们现在将向此仪表板添加一个仪表图表。

点击 ADD CHART 以向 Data Dashboard 添加新图表。
点击 Name 并为图表输入一个名称。
点击 Chart Type 并选择 Gauge。
点击 Source 并选择随数据一起发送的 target_id。如果您使用了上面提供的示例代码或负载，您将在列表中看到 my_PC。
点击 Property 并选择一个属性（例如 temperature 或 humidity）。
点击 ADD 保存配置并将图表添加到仪表板。

您将在仪表板上看到一个仪表图表。

MQTT 数据采集器

JEDI 提供了一系列预配置的数据采集器，可立即使用。这些采集器适用于典型的物联网场景，包括：

HTTP：通过 HTTP API 接收来自设备、脚本和其他应用程序的数据。
MQTT Broker：通过 MQTT（一种广泛使用的物联网消息协议）从传感器和设备获取数据。
TCP：允许从通过原始 TCP 连接通信的设备中检索数据。
Serial：与通过串口传输数据的设备建立连接（例如 Arduino 板、GPS 接收器等）。

因此，我们将讨论最流行的 MQTT 协议。

准备您的 Xiao

在上传代码之前，请配置 SSID、WiFi 密码、MQTT 服务器 IP（JEDI IP）、MQTT 用户名 和 MQTT 密码。在此示例中，我们将向 Machine Chat JEDI 发送一些虚拟数据。

#include <WiFi.h>
#include <PubSubClient.h>

const char* ssid = "ABC";
const char* password = "XXXXX";
const char* mqtt_server = "192.XXX.X.XXX";  // 替换为您的 MQTT 代理的 IP
const int mqtt_port = 1883;  // 默认 MQTT 端口
const char* mqtt_username = "ABC";
const char* mqtt_password = "ABC123";

WiFiClient espClient;
PubSubClient client(espClient);

void setup() {
  Serial.begin(115200);
  WiFi.begin(ssid, password);
  client.setCallback(callback);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("正在连接到 WiFi...");
  }

  Serial.println("已连接到 WiFi");
  client.setServer(mqtt_server, mqtt_port);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  // 为每个实验室生成随机值：VOC、人类存在、温度和湿度
  for (int lab = 1; lab <= 3; lab++) {
    int voc = random(60, 80);
    int presence = random(0, 3); // 假设 presence 表示为布尔值（0 表示无人，1 表示有人）
    bool acState = false; // 默认空调状态为关闭
    float temperature = random(18, 30); // 假设温度以摄氏度为单位
    int humidity = random(30, 70); // 假设湿度为百分比
    bool fire = false;

    // 检查温度是否大于 25 且有人存在
    if (temperature > 25 && presence) {
      acState = true; // 打开空调
    }

    // 构建负载
    String payload = "{\"lab\":" + String(lab) + ",\"voc\":" + String(voc) + ",\"presence\":" + String(presence) + ",\"acState\":" + String(acState) + ",\"temperature\":" + String(temperature) + ",\"humidity\":" + String(humidity) +",\"fire\":" + String(fire) + "}";

    // 为当前实验室发布负载
    client.publish(("Lab" + String(lab) + "/data").c_str(), payload.c_str());
  }

  delay(10000); // 等待 10 秒后发送下一组数据
}

void reconnect() {
  while (!client.connected()) {
    Serial.println("尝试连接到 MQTT...");
    if (client.connect("ESP32Client", mqtt_username, mqtt_password)) {
      Serial.println("已连接");
      // 如果需要，订阅主题
       client.subscribe("rpi/data");
    } else {
      Serial.print("连接失败，错误代码=");
      Serial.print(client.state());
      Serial.println("，5 秒后重试");
      delay(5000);
    }
  }
}

void callback(char* topic, byte* payload, unsigned int length) {
    Serial.print("收到的主题消息: ");
    Serial.println(topic);

    Serial.print("消息内容:");
    for (int i = 0; i < length; i++) {
        Serial.print((char)payload[i]);
    }
    Serial.println();
}