如何利用 ChatGPT 和 MQTTX 模拟物联网场景数据

• 使用  -c  参数可以调整模拟的设备客户端数量。

• 通过  -im  参数，您可以设置数据发送的频率。

• 确保  --file  参数指向脚本文件的正确位置，无论是绝对路径还是相对路径。
  

/**
 * MQTTX 车联网场景文件示例
 * 
 * 此脚本生成汽车速度、位置、油箱容量、轮胎压力、车门状态和温度等信息，模拟车辆的实时状态。
 */
function generator (faker, options) {
  const randomElement = (arr) => arr[Math.floor(Math.random() * arr.length)];


  return {
    message: JSON.stringify({
      speed: faker.datatype.number({ min: 0, max: 220 }),          // 模拟速度，从0到220km/h。
      position: {
        lat: faker.address.latitude(),
        lng: faker.address.longitude()
      },                                                          // 模拟车辆的GPS位置。
      fuelLevel: faker.datatype.float({ min: 0, max: 100 }),      // 模拟油箱容量，百分比。
      tirePressure: {
        frontLeft: faker.datatype.number({ min: 30, max: 40 }),   // 轮胎压力 (psi)。
        frontRight: faker.datatype.number({ min: 30, max: 40 }),
        rearLeft: faker.datatype.number({ min: 30, max: 40 }),
        rearRight: faker.datatype.number({ min: 30, max: 40 }),
      },
      doorStatus: {
        driver: randomElement(['Open', 'Closed']),                // 车门状态。
        passenger: randomElement(['Open', 'Closed']),
        rearLeft: randomElement(['Open', 'Closed']),
        rearRight: randomElement(['Open', 'Closed']),
      },
      internalTemperature: faker.datatype.float({ min: 15, max: 30 }),  // 车内温度 (摄氏度)。
      engineStatus: randomElement(['Running', 'Off']),                 // 发动机状态。
    })
  }
}


// 导出场景模块
module.exports = {
  name: 'vehicleNetworkScenario',   // 场景名称
  generator,                               // 生成器函数
}

mqttx simulate --file vehicle_network.js -c 1 -h 127.0.0.1 -t mqttx/chatgpt/vechicle

mqttx sub -t mqttx/chatgpt/# -h 127.0.0.1 --format json
[8/9/2023] [5:49:58 PM] › …  Connecting...
[8/9/2023] [5:49:58 PM] › ✔  Connected
[8/9/2023] [5:49:58 PM] › …  Subscribing to mqttx/chatgpt/#...
[8/9/2023] [5:49:58 PM] › ✔  Subscribed to mqttx/chatgpt/#
[8/9/2023] [5:49:59 PM] › payload: {
  "speed": 81,
  "position": {
    "lat": "-58.7571",
    "lng": "-57.4411"
  },
  "fuelLevel": 83.26,
  "tirePressure": {
    "frontLeft": 32,
    "frontRight": 35,
    "rearLeft": 34,
    "rearRight": 36
  },
  "doorStatus": {
    "driver": "Closed",
    "passenger": "Open",
    "rearLeft": "Open",
    "rearRight": "Open"
  },
  "internalTemperature": 17.25,
  "engineStatus": "Off"
}

在现代制造工厂中，各种机器的状态被持续监控，以优化性能和避免故障。传感器实时监测机器的温度、压力和运行时间。 基于这种需求，请设计一个模拟数据脚本。

/**
 * MQTTX 工业场景文件示例
 * 
 * 此脚本生成随机的机器详细状态数据，包括温度、压力、运行时间、轴承温度、电机转速、润滑油水平和故障代码。
 */
function generator (faker, options) {
  const randomElement = (arr) => arr[Math.floor(Math.random() * arr.length)];


  return {
    message: JSON.stringify({
      temperature: faker.datatype.number({ min: 20, max: 100 }),    // 模拟机器温度，从20°C到100°C。
      pressure: faker.datatype.number({ min: 1, max: 10 }),         // 模拟机器内部压力，从1bar到10bar。
      runtime: faker.datatype.number({ min: 0, max: 240 }),         // 模拟机器运行时间，单位为小时。
      bearingTemperature: faker.datatype.number({ min: 20, max: 90 }),  // 轴承温度。
      motorRPM: faker.datatype.number({ min: 1000, max: 5000 }),        // 电机转速。
      lubricationOilLevel: faker.datatype.float({ min: 0.5, max: 1.5 }), // 润滑油水平，单位为liters。
      faultCodes: randomElement(['None', 'Overheat', 'High Pressure', 'Low Oil']),  // 机器故障代码。
    })
  }
}


// 导出场景模块
module.exports = {
  name: 'advancedIndustrialScenario',   // 场景名称
  generator,                            // 生成器函数
}

mqttx simulate --file industrial.js -c 1 -h 127.0.0.1 -t mqttx/chatgpt/industrial

mqttx sub -t mqttx/chatgpt/# -h 127.0.0.1 --format json
[8/9/2023] [5:56:56 PM] › …  Connecting...
[8/9/2023] [5:56:56 PM] › ✔  Connected
[8/9/2023] [5:56:56 PM] › …  Subscribing to mqttx/chatgpt/#...
[8/9/2023] [5:56:56 PM] › ✔  Subscribed to mqttx/chatgpt/#
[8/9/2023] [5:56:56 PM] › payload: {
  "temperature": 55,
  "pressure": 6,
  "runtime": 144,
  "bearingTemperature": 36,
  "motorRPM": 4395,
  "lubricationOilLevel": 0.53,
  "faultCodes": "High Pressure"
}