|
|
马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。
您需要 登录 才可以下载或查看，没有账号？立即注册
x
mqtt
- # -*- coding: UTF-8 -*-
- # MindPlus
- # Python
- import time
- import siot
- import random
- # from pinpong.board import Board,Pin
- # from pinpong.extension.unihiker import *
- # 自定义函数
- def F_init_MQTT(SERVER="i.37ck.cn",PORT=1883,USER="37ck",PASSWORD="20200808"):
- siot.init(client_id="",server=SERVER,port=PORT,user=USER,password=PASSWORD)
- siot.connect()
- siot.loop()
- siot.set_callback(on_message_callback)
- def F_RUN(TOPIC):
-
- F_FS(TOPIC, (ZhiLing[(random.randint(1, 10))]))
- def F_INIT():
- ZhiLing = ["","前进","后退","左转","右转","停止"]
- ZhiLing.extend(["开灯","关灯","红灯","绿灯","黄灯"])
- def HY():
- F_RUN('37ck/wtzx')
- def F_MQTT(TOPIC, TITLE):
- F_DY(TOPIC)
- F_DY('37ck/wtzx')
- F_DY('37ck/718')
- siot.publish(topic=TOPIC, data=TITLE)
- def F_DY(TOPIC):
- siot.getsubscribe(topic=TOPIC)
- def _37ck():
- F_RUN('37ck/2025')
- def F_FS(topic, msg):
- siot.publish(topic=topic, data=msg)
- def HYJ():
- F_RUN('37ck/718')
- # 事件回调函数
- def on_message_callback(client, userdata, msg):
- print((str((str(msg.topic) + str(":"))) + str(msg.payload.decode())))
- # Board().begin()
- # F_init_MQTT()
- F_init_MQTT(SERVER="192.168.3.153")
- # F_init_MQTT(1883,"37ck","i.37ck.cn","20200808")
- # F_init_MQTT("i.37ck.cn",1883,"37ck","20200808")
- # F_init_MQTT(SERVER="i.37ck.cn",PORT=1883,USER="37ck",PASSWORD="20200808")
- # F_init_MQTT(PORT=1883,USER="37ck",SERVER="i.37ck.cn",PASSWORD="20200808")
- # F_init_MQTT(SERVER="192.168.3.137",PORT=1883,USER="37ck",PASSWORD="20200808")
- global ZhiLing
- F_MQTT('37ck/2025', '37创客')
- F_INIT()
- while True:
- # print(light.read())
- print(time.strftime("%H:%M:%S"))
|
|
发表于 2025-7-24 10:45:39
