跳转至

订阅数据

功能介绍

客户通过创建订阅用户订阅设备数据，设备数据将会推送到Kafka队列中，开发人员通过SASL_SSL连接Kafka，并订阅用户主题，达到接收数据的目的。SASL_SSL 验证需使用用户名、密码和证书来连接Kafka。

注：

  • 暂不支持传动链设备

  • 目前预测性维护计划目前只支持订阅等级为标准版、高级版，设备类型为ACS800、ACS880设备

设备数据类型消息格式定义

1. 订阅设备数据消息格式定义

{
    "AssetDataType": "AssetEvent",
    "TimeStamp": 1630480604000,
    "AssetDataCollection":[]
}
DeviceDataType类型 描述
AssetEvent 设备实时事件
AssetState 设备状态（每间隔一个小时推送一次所有的设备的离线、在线的状态）
AssetReport 设备报告（当用户设备报告生成时，推送设备的报告的生成结果）
AssetCBM 设备预测性维护分析结果（每天推送设备前一天的预测性维护分析结果）

2. 订阅设备事件数据消息格式定义

{
    "AssetDataType": "AssetEvent",
    "AssetDataCollection": [
        {
            "Id": 789,
            "AssetId": 456,
            "EUOrgId": 123,
            "SerialNumber": "xxxxxxx",
            "DeviceTimestampString": "2023-03-10T12:30:29.79+08:00",
            "Message": "Warning: 编码器1 - 编码器1出现问题 deactivated - Base:0XA7E1 Aux:0X0 ",
            "Code": "a7e1",
            "DeviceEventType": "Warning",
            "Timestamp": "2023-03-10T04:30:30Z"
        },
        {
            "Id": 790,
            "AssetId": 456,
            "EUOrgId": 123,
            "SerialNumber": "xxxxxxx",
            "DeviceTimestampString": "2023-03-10T12:30:58.149+08:00",
            "Message": "Warning: 编码器1 - 编码器1出现问题 activated - Base:0XA7E1 Aux:0X1010001 ",
            "Code": "a7e1",
            "DeviceEventType": "Warning",
            "Timestamp": "2023-03-10T04:30:58Z"
        }
    ],
    "TimeStamp": 1678422710663
}
事件实体属性 数据类型 参数
Id Long 事件Id
AssetId Integer 设备ID
EUOrgId Integer EU组织ID
SerialNumber String 设备序列号
DeviceTimestampString String 事件在设备发生的时间
Message String 事件内容
Code String 事件代码
DeviceEventType String 事件类型[Fault-故障|Warning-告警|Notification-通知]
Timestamp String 事件上报到服务器时间 ISO 8601标准时间

3. 订阅设备状态数据消息格式定义

{
    "AssetDataType": "AssetState",
    "TimeStamp": 1630480604000,
    "AssetDataCollection": [{
            "EUOrgId": 13,
            "Online": [{
                    "AssetId": 125,
                    "SerialNumber": "xxxxxx",
                    "AssetType":"Drive"
                }
            ],
            "Offline": [{
                    "AssetId": 126,
                    "SerialNumber": "xxxxxx",
                    "AssetType":"Drive"
                }
            ],
            "Unkonwn": [{
                    "AssetId": 127,
                    "SerialNumber": "xxxxxx",
                    "AssetType":"Drive"
                }
            ]
        }
    ]
}
设备状态实体属性 数据类型 描述
EUOrgId Integer EU组织ID
Online List 在线设备列表
Offline List 离线设备列表
Unkonwn List 未知设备列表
设备实体属性 数据类型 描述
AssetId Integer 设备ID
SerialNumber String 设备序列号
AssetType String 设备类型[Drive-传动|Motor|电机]（暂不支持传动链）

4.订阅设备报告数据消息格式定义

{
    "AssetDataType": "AssetReport",
    "TimeStamp": 1630480604000,
    "AssetDataCollection":[{
        "Id": 200,
        "AssetIds":[123],
        "EUOgrId": 32,
        "Title": "xxxxxxxxxxx",
        "SubTitle": "xxxxx",
        "ReportType": "UserFleetReport",
        "StartDateTime": "2021-07-01",
        "EndDateTime": "2021-08-01",
        "Status":"Created",
        "CreatedUser": "ABB专家",
        "CreatedOn": "2021-08-25T05:22:56.804388"
    }]
}
报告实体属性 数据类型 描述
Id Integer 报告ID
AssetIds List 设备ID List
EUOrgId Integer EU组织ID
Title String 报告标题
SubTitle String 报告副标题
ReportType String 报告类型[UserDriveReport-传动报告|UserFleetReport-传动编组报告]
StartDateTime String 报告开始时间 ISO 8601标准时间
EndDateTime String 报告结束时间 ISO 8601标准时间
Status String 报告状态[Failed|Creating|Created]
CreatedOn String 报告创建时间 ISO 8601标准时间
CreatedUser String 报告创建人

5.订阅设备预测性维护分析数据消息格式定义

{
    "AssetDataType": "AssetCBM",
    "TimeStamp": 1630480604000,
    "AssetDataCollection": [{
            "AssetId": 123,
            "SerialNumber": "xxxxxxx",
            "EUOrgId": 33,
            "DateTime": "2021-09-01",
            "Units": [{
                    "DeviceUnitType": "fan",
                    "DeviceUnitStatus": "good",
                    "PredictedNoPlanDate": "2020-12-18",
                    "PredictedStartPlanDate": "2029-08-28",
                    "PredictedRunPlanDate": "2030-08-28",
                    "DeviceKPI": 0.01
                }, {
                    "DeviceUnitType": "capacitor",
                    "DeviceUnitStatus": "good",
                    "PredictedNoPlanDate": "2020-12-18",
                    "PredictedStartPlanDate": "2029-08-28",
                    "PredictedRunPlanDate": "2030-08-28",
                    "DeviceKPI": 0.01
                }, {
                    "DeviceUnitType": "igbt",
                    "DeviceUnitStatus": "good",
                    "PredictedNoPlanDate": "2020-12-18",
                    "PredictedStartPlanDate": "2029-08-28",
                    "PredictedRunPlanDate": "2030-08-28",
                    "DeviceKPI": 0.01
                }
            ]
        }
    ]
}
预测性维护分析实体属性 数据类型 描述
AssetId Integer 设备ID
EUOrgId Integer EU组织ID
SerialNumber String 设备序列号
DateTime DateTime 预测性维护分析的设备数据的日期（东八区标准时间）
Units List 设备部件列表
设备部件实体属性 数据类型 描述
DeviceUnitType String 设备部件类型[fan-冷却|capacitor-直流母线电容|igbt-变流单元]
DeviceUnitStatus String 设备部件的状态[gray|good|yellow|red]
PredictedNoPlanDate DateTime 预计无需计划性维护开始时间（东八区标准时间）
PredictedStartPlanDate DateTime 开始计划预防性维护开始时间（东八区标准时间）
PredictedRunPlanDate DateTime 建议执行预防性维护开始时间（东八区标准时间）
DeviceKPI Double 设备的日常寿命影响的KPI数值
Back to top