| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107 |
- # TOPIC 定义
- class TOPICS(str):
- # 设备 Device
- dev_all = "/dev/#" # 设备端消息
- dev_login = "/dev/+/login" # 设备注册（请求）
- dev_keepalive = "/dev/+/keepalive" # 心跳保活（请求）
- dev_rep_dev_info = "/dev/+/report_device_info" # 设备信息
- dev_rep_dev_param = "/dev/+/report_device_param" # 设备参数
- dev_dsp_data = "/dev/+/dsp_data" # 设备实时数据
- dev_cloudpoint = "/dev/+/cloudpoint" # 点云数据
- dev_rep_fall_event = "/dev/+/report_falling_event" # 跌倒事件
- dev_rep_pres_event = "/dev/+/report_presence_event" # 存在事件
- dev_update_firmware = "/dev/+/update_firmware" # OTA固件升级
- dev_reboot = "/dev/+/reboot" # 设备软重启
- # 设备调试
- dev_set_debug = "/dev/+/set_debug_param" # 设置debug配置
- dev_get_debug = "/dev/+/get_debug_param" # 获取debug配置
- # 设备接入 Device Access Service
- das_all = "/das/#" # 设备接入消息
- das_login = "/das/+/login" # 设备注册（响应）
- das_keepalive = "/das/+/keepalive" # 心跳保活（响应）
- das_status = "/das/dev_status" # 设备状态变更
- das_cloudpoint = "/das/cloudpoint" # 点云消息
- das_realtime_pos = "/das/realtime_pos" # 实时位置姿态
- das_event = "/das/event" # 跌倒事件
- das_exist_event = "/das/exist" # 存在事件
- das_alarm_event = "/das/alarm_event" # 告警事件
- das_set_dev_param = "/das/set_device_param" # 设置设备参数（请求）
- das_debug_param = "/das/+/debug_param" # debug配置信息（响应）
- das_report_alarm_param = "/das/report_alarm_param" # 上报告警参数（响应）
- das_set_alarm_param_ack = "/das/set_alarm_param_ack" # 设置告警参数确认（响应）
- # 小程序 Mini Program Service
- mps_all = "/mps/#" # 小程序服务消息
- mps_get_dev_info = "/mps/request_device_info" # 请求设备信息
- mps_get_dev_param = "/mps/get_device_param" # 请求设备参数
- mps_set_dev_param = "/mps/set_device_param" # 设置设备参数
- mps_set_dev_param = "/mps/fall_event/ack" # 跌倒确认
- # 运维客户端
- opc_all = "/opc/#" # 运维客户端
- opc_get_alarm_param = "/opc/get_alarm_param" # 获取告警参数
- opc_set_alarm_param = "/opc/set_alarm_param" # 设置告警参数
- # 告警联动服务
- las_all = "/las/#"
- las_alarm_event = "/las/alarm_event" # 上报告警事件
- # topic匹配规则
- class Topic_Pattern(str):
- # 设备 Device
- dev_all = r"^/dev/.*$" # 设备端消息
- dev_login = r"^/dev/[^/]+/login$" # 设备注册（请求）
- dev_keepalive = r"^/dev/[^/]+/keepalive$" # 心跳保活（请求）
- dev_rep_dev_info = r"^/dev/[^/]+/report_device_info$" # 设备信息
- dev_rep_dev_param = r"^/dev/[^/]+/report_device_param$" # 上报设备参数
- dev_dsp_data = r"^/dev/[^/]+/dsp_data$" # 设备实时数据
- dev_cloudpoint = r"^/dev/[^/]+/cloudpoint$" # 点云数据
- dev_rep_fall_event = r"^/dev/[^/]+/report_falling_event$" # 跌倒事件
- dev_rep_pres_event = r"^/dev/[^/]+/report_presence_event$" # 存在事件
- dev_update_firmware = r"^/dev/[^/]+/update_firmware$" # OTA固件升级
- dev_reboot = r"^/dev/[^/]+/reboot$" # 设备软重启
- # 设备调试
- dev_set_debug = r"^/dev/[^/]+/set_debug_param$" # 设置debug配置
- dev_get_debug = r"^/dev/[^/]+/get_debug_param$" # 获取debug配置
- # 设备接入 Device Access Service
- das_all = r"^/das/.*$" # 设备接入消息
- das_login = r"^/das/[^/]+/login$" # 设备注册（响应）
- das_keepalive = r"^/das/[^/]+/keepalive$" # 心跳保活（响应）
- das_status = r"^/das/dev_status$" # 设备状态变更
- das_cloudpoint = r"^/das/cloudpoint$" # 点云消息
- das_realtime_pos = r"^/das/realtime_pos$" # 实时位置姿态
- das_event = r"^/das/event$" # 跌倒事件
- das_exist_event = r"^/das/exist$" # 存在事件
- das_alarm_event = r"^/das/alarm_event$" # 告警事件
- das_set_dev_param = r"^/das/set_device_param$" # 设置设备参数（请求）
- das_debug_param = r"^/das/+/debug_param$" # debug配置信息（响应）
- das_report_alarm_param = r"^/das/report_alarm_param$" # 上报告警参数（响应）
- das_set_alarm_param_ack = r"^/das/set_alarm_param_ack$" # 设置告警参数确认（响应）
- # 小程序 Mini Program Service
- mps_all = r"^/mps/.*$" # 小程序服务消息
- mps_get_dev_info = r"^/mps/get_device_info$" # 获取设备信息
- mps_get_dev_param = r"^/mps/get_device_param$" # 请求设备参数
- mps_set_dev_param = r"^/mps/set_device_param$" # 设置设备参数
- mps_dev_reboot = r"^/mps/[^/]+/reboot$" # 设备软重启
- mps_add_device = r"^/mps/add_device" # 添加设备
- mps_del_device = r"^/mps/del_device" # 删除设备
- mps_add_group = r"^/mps/add_group" # 添加群组
- mps_del_group = r"^/mps/del_group" # 删除群组
- mps_fall_event_ack = r"^/mps/fall_event/ack$" # 跌倒确认
- # 运维客户端
- opc_all = r"^/opc/.*$" # 运维客户端
- opc_get_alarm_param = r"^/opc/get_alarm_param$" # 获取告警参数
- opc_set_alarm_param = r"^/opc/set_alarm_param$" # 设置告警参数
- # 告警联动服务
- las_all = r"^/las/.*$"
- las_alarm_event = r"^/las/alarm_eventr$" # 上报告警事件
|
