mqtt_topics.py 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. # TOPIC 定义
  2. class TOPICS(str):
  3. # 设备 Device
  4. dev_all = "/dev/#" # 设备端消息
  5. dev_login = "/dev/+/login" # 设备注册(请求)
  6. dev_keepalive = "/dev/+/keepalive" # 心跳保活(请求)
  7. dev_rep_dev_info = "/dev/+/report_device_info" # 设备信息
  8. dev_rep_dev_param = "/dev/+/report_device_param" # 设备参数
  9. dev_dsp_data = "/dev/+/dsp_data" # 设备实时数据
  10. dev_tracker_targets = "/dev/+/tracker_targets" # 设备实时数据(新版V2.1.1, 2025-09-08)
  11. dev_cloudpoint = "/dev/+/cloudpoint" # 点云数据
  12. dev_rep_fall_event = "/dev/+/report_falling_event" # 跌倒事件
  13. dev_rep_pres_event = "/dev/+/report_presence_event" # 存在事件
  14. dev_update_firmware = "/dev/+/update_firmware" # OTA固件升级
  15. dev_reboot = "/dev/+/reboot" # 设备软重启
  16. # 设备调试
  17. dev_set_debug = "/dev/+/set_debug_param" # 设置debug配置
  18. dev_get_debug = "/dev/+/get_debug_param" # 获取debug配置
  19. # 设备接入 Device Access Service
  20. das_all = "/das/#" # 设备接入消息
  21. das_login = "/das/+/login" # 设备注册(响应)
  22. das_keepalive = "/das/+/keepalive" # 心跳保活(响应)
  23. das_status = "/das/dev_status" # 设备状态变更
  24. das_cloudpoint = "/das/cloudpoint" # 点云消息
  25. das_realtime_pos = "/das/realtime_pos" # 实时位置姿态
  26. das_event = "/das/event" # 跌倒事件
  27. das_exist_event = "/das/exist" # 存在事件
  28. das_alarm_event = "/das/alarm_event" # 告警事件
  29. das_set_dev_param = "/das/set_device_param" # 设置设备参数(请求)
  30. das_debug_param = "/das/+/debug_param" # debug配置信息(响应)
  31. das_report_alarm_param = "/das/report_alarm_param" # 上报告警参数(响应)
  32. das_set_alarm_param_ack = "/das/set_alarm_param_ack" # 设置告警参数确认(响应)
  33. # 小程序 Mini Program Service
  34. mps_all = "/mps/#" # 小程序服务消息
  35. mps_get_dev_info = "/mps/request_device_info" # 请求设备信息
  36. mps_get_dev_param = "/mps/get_device_param" # 请求设备参数
  37. mps_set_dev_param = "/mps/set_device_param" # 设置设备参数
  38. mps_set_dev_param = "/mps/fall_event/ack" # 跌倒确认
  39. # 运维客户端
  40. opc_all = "/opc/#" # 运维客户端
  41. opc_get_alarm_param = "/opc/get_alarm_param" # 获取告警参数
  42. opc_set_alarm_param = "/opc/set_alarm_param" # 设置告警参数
  43. # 告警联动服务
  44. las_all = "/las/#"
  45. las_alarm_plan_update = "/las/alarm_plan_update" # 告警计划变更
  46. las_alarm_event = "/las/alarm_event" # 上报告警事件
  47. las_test = "/las/test" # 测试
  48. las_test_resp = "/las/test_resp" # 测试响应
  49. # topic匹配规则
  50. class Topic_Pattern(str):
  51. # 设备 Device
  52. dev_all = r"^/dev/.*$" # 设备端消息
  53. dev_login = r"^/dev/[^/]+/login$" # 设备注册(请求)
  54. dev_keepalive = r"^/dev/[^/]+/keepalive$" # 心跳保活(请求)
  55. dev_rep_dev_info = r"^/dev/[^/]+/report_device_info$" # 设备信息
  56. dev_rep_dev_param = r"^/dev/[^/]+/report_device_param$" # 上报设备参数
  57. dev_dsp_data = r"^/dev/[^/]+/dsp_data$" # 设备实时数据(旧版)
  58. dev_tracker_targets = r"^/dev/[^/]+/tracker_targets$" # 设备实时数据(新版V2.1.1, 2025-09-08)
  59. dev_cloudpoint = r"^/dev/[^/]+/cloudpoint$" # 点云数据
  60. dev_rep_fall_event = r"^/dev/[^/]+/report_falling_event$" # 跌倒事件
  61. dev_rep_pres_event = r"^/dev/[^/]+/report_presence_event$" # 存在事件
  62. dev_update_firmware = r"^/dev/[^/]+/update_firmware$" # OTA固件升级
  63. dev_reboot = r"^/dev/[^/]+/reboot$" # 设备软重启
  64. # 设备调试
  65. dev_set_debug = r"^/dev/[^/]+/set_debug_param$" # 设置debug配置
  66. dev_get_debug = r"^/dev/[^/]+/get_debug_param$" # 获取debug配置
  67. # 设备接入 Device Access Service
  68. das_all = r"^/das/.*$" # 设备接入消息
  69. das_login = r"^/das/[^/]+/login$" # 设备注册(响应)
  70. das_keepalive = r"^/das/[^/]+/keepalive$" # 心跳保活(响应)
  71. das_status = r"^/das/dev_status$" # 设备状态变更
  72. das_cloudpoint = r"^/das/cloudpoint$" # 点云消息
  73. das_realtime_pos = r"^/das/realtime_pos$" # 实时位置姿态
  74. das_event = r"^/das/event$" # 跌倒事件
  75. das_exist_event = r"^/das/exist$" # 存在事件
  76. das_alarm_event = r"^/das/alarm_event$" # 告警事件
  77. das_set_dev_param = r"^/das/set_device_param$" # 设置设备参数(请求)
  78. das_debug_param = r"^/das/+/debug_param$" # debug配置信息(响应)
  79. das_report_alarm_param = r"^/das/report_alarm_param$" # 上报告警参数(响应)
  80. das_set_alarm_param_ack = r"^/das/set_alarm_param_ack$" # 设置告警参数确认(响应)
  81. # 小程序 Mini Program Service
  82. mps_all = r"^/mps/.*$" # 小程序服务消息
  83. mps_get_dev_info = r"^/mps/get_device_info$" # 获取设备信息
  84. mps_get_dev_param = r"^/mps/get_device_param$" # 请求设备参数
  85. mps_set_dev_param = r"^/mps/set_device_param$" # 设置设备参数
  86. mps_dev_reboot = r"^/mps/[^/]+/reboot$" # 设备软重启
  87. mps_add_device = r"^/mps/add_device" # 添加设备
  88. mps_del_device = r"^/mps/del_device" # 删除设备
  89. mps_add_group = r"^/mps/add_group" # 添加群组
  90. mps_del_group = r"^/mps/del_group" # 删除群组
  91. mps_fall_event_ack = r"^/mps/fall_event/ack$" # 跌倒确认
  92. # 运维客户端
  93. opc_all = r"^/opc/.*$" # 运维客户端
  94. opc_get_alarm_param = r"^/opc/get_alarm_param$" # 获取告警参数
  95. opc_set_alarm_param = r"^/opc/set_alarm_param$" # 设置告警参数
  96. # 告警联动服务
  97. las_all = r"^/las/.*$"
  98. las_alarm_plan_update = r"^/las/alarm_plan_update$" # 告警计划变更
  99. las_alarm_event = r"^/las/alarm_eventr$" # 上报告警事件
  100. las_test = r"^/las/test$" # 测试
  101. las_test_resp = r"^/las/test_resp$" # 测试响应