提交 c755ce7f authored 作者: 陈泽健's avatar 陈泽健

输出富创项目的MQTT人脸签到订阅测试脚本,输出富创项目两个MQTT相关服务的README文档。

上级 7c675220
......@@ -98,4 +98,5 @@
28. 2024-12-12
- 处理模拟器无纸化无法读取PAK问题,实现通过模拟器进行app自动化巡检流程。
- 处理appium自动化截屏。
- 输出富创项目的MQTT会议推送相关代码处理。
\ No newline at end of file
- 输出富创项目的MQTT会议推送相关代码处理。
- 输出富创项目的MQTT人脸签到订阅测试脚本,输出富创项目两个MQTT相关服务的README文档。
\ No newline at end of file
from 预定系统.Base.Mqtt_Send import *
from 预定系统.Base.base import *
if __name__ == "__main__":
broker_address = "192.168.5.218"
port = 1883
num_repeats = 1000 # 重复执行的次数
interval_between_repeats = 0.2 # 每次重复之间的间隔时间(秒)
face_signin_topic = "face_signin_topic" # 替换为你需要订阅的主题
# 创建 MQTT 客户端实例
mqtt_client = Mqtt(broker_address, port)
try:
# 连接到 MQTT 服务器
mqtt_client.connect()
logging.info("已连接到MQTT服务器")
# 订阅主题
mqtt_client.subscribe(face_signin_topic)
logging.info(f"已订阅主题: {face_signin_topic}")
# 循环等待消息
for _ in range(num_repeats):
received_message = mqtt_client.wait_for_message(face_signin_topic, timeout=5)
if received_message:
logging.info(f"接收到消息: {received_message}")
# 在这里处理接收到的消息
else:
logging.warning("超时时间内未接收到消息。")
# 等待一段时间后再次尝试
time.sleep(interval_between_repeats)
except Exception as e:
logging.error(f"发送消息时发生错误: {e}")
finally:
# 断开与 MQTT 服务器的连接
mqtt_client.disconnect()
## 富创项目MQTT服务
### MQTT人脸签到推送
- 业务逻辑:当该项目的人脸签到成功后,会往主题:“”发布消息,消息内容是签到成功的人脸信息以及会议信息。
- 代码处理:
3. 验证人脸签到MQTT是否接收到消息体推送,先运行MQTT人脸签到推送脚本文件,然后进行人脸签到,查看控制台是否输出人脸签到推送的消息日志。
- 环境变更:
1. 测试环境变更:若测试环境变更,请替换代码中的服务器地址broker_address、端口port。
2. 订阅主题变更:若项目人脸发布的主题变更,请替换代码中的主题face_signin_topic。
### MQTT会议推送
- 业务逻辑:当OA创建会议后会通过MQTT向预定系统推送会议消息,预定系统收到消息后,会向预定系统创建会议。
- 代码处理:
1. 通过代码进行模拟OA推送会议数据,先修改会议数据的对应参数,参数通过读取:D:\GithubData\自动化测试\ubains-module-test\预定系统\测试数据\MQTT模块\富创项目_会议推送.csv文件,模拟OA创建会议。
2. 其中action为会议动作,分为:add、delete、update。thirdPartyMeetingId不能重复,thirdPartyRoomId为第三方会议室的ID,companyNumber为测试环境公司编号。conferenceName、messageName、startTimeendTime按格式填写即可。
- 环境变更:
1. 测试环境变更:若测试环境变更,请替换代码中的服务器地址broker_address、端口port。
2. 订阅主题变更:若项目人脸发布的主题变更,请替换代码中的主题/meeting/message/sync。
\ No newline at end of file
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论