# 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_tracker_targets = "/dev/+/tracker_targets" # 设备实时数据(新版V2.1.1, 2025-09-08) 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_plan_update = "/las/alarm_plan_update" # 告警计划变更 las_alarm_event = "/las/alarm_event" # 上报告警事件 las_test = "/las/test" # 测试 las_test_resp = "/las/test_resp" # 测试响应 # 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_tracker_targets = r"^/dev/[^/]+/tracker_targets$" # 设备实时数据(新版V2.1.1, 2025-09-08) 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_plan_update = r"^/las/alarm_plan_update$" # 告警计划变更 las_alarm_event = r"^/las/alarm_eventr$" # 上报告警事件 las_test = r"^/las/test$" # 测试 las_test_resp = r"^/las/test_resp$" # 测试响应