Kafka消息队列数据接口

Topic

MeasurePoints 和 PogoPoints

Message 为Set类型，内容为当前时间点有数据更新的设备的相关Json信息，Json内容和Redis数据库中的Value值相同，右图为一条Message的示例

[
  {
    "LabelGroup": "Pogo",
    "No": "02",
    "Axis": "Z",
    "NodeId": "ns=2;s=0PC_DA.Ce115.Pogo.Pogo02_Axis1_ExtEncoderRelPos",
    "DataType": "Float",
    "Value": 1315,
    "MeasureName": "RelPos",
    "InsertDateTime": "2023-08-15 18:12:44",
    "TimeStamp": 1692094364914
  },
  {
    "LabelGroup": "Pogo",
    "No": "12",
    "Axis": "Z",
    "NodeId": "ns=2;s=0PC_DA.Ce115.Pogo.Pogo12_Axis1_ForceSensorRelValue",
    "DataType": "Float",
    "Value": 7919,
    "MeasureName": "ForceValue",
    "InsertDateTime": "2023-08-15 18:12:44",
    "TimeStamp": 1692094364914
  },
  {
    "LabelGroup": "Pogo",
    "No": "02",
    "Axis": "Z",
    "NodeId": "ns=2;s=0PC_DA.Ce115.Pogo.Pogo02_Axis1_ForceSensorRelValue",
    "DataType": "Float",
    "Value": 489,
    "MeasureName": "ForceValue",
    "InsertDateTime": "2023-08-15 18:12:44",
    "TimeStamp": 1692094364979
  }
]

Last modified: 27 October 2024