ObloqMqttPublish

from microbit import *
import Obloq

SERVER = "iot.dfrobot.com.cn"
PORT = "1883"
SSID = "dfrobotYanfa"
PASSWORD = "hidfrobot"
IOT_ID = "SyWPtKo_Kz"
IOT_PWD = "HJfwKFjdtz"
IOT_TOPIC1 = "BysFYi_FM"
IOT_TOPIC2 = "SkmigyM5z"

uart.init(baudrate=9600, bits=8, parity=None, stop=1, tx=pin2, rx=pin1)

def ConnectWifi():  
  while Obloq.connectWifi(SSID,PASSWORD,10000) != True:
    display.show(".")
  display.scroll(Obloq.ifconfig()) 
def event(e,param):
  if e == "MqttConneted":
    display.scroll("OK")  
ConnectWifi()

Obloq.mqttConfig(event,SERVER,PORT)

Obloq.connectMqtt(IOT_ID,IOT_PWD)
while True:
  sleep(10000)
  Obloq.publish(IOT_TOPIC1,"hello")
  sleep(10000)
  Obloq.publish(IOT_TOPIC2,"HELLO")

第1行和第2行:导入需要的包和模块。

第4行到第11行:设置服务器的地址和端口号,wifi的用户名和密码,IOT的用户名和密码以及TOPIC。

第13行:串口初始化。

第15行到第18行:定义连接wifi函数,连接超时显示'.',连接成功显示wifi的IP。

第19行到第21行:设置MQTT的回调函数,连接MQTT成功,显示'OK'。

第22行:连接wifi。

第24行:初始化MQTT设置。

第26行:连接MQTT。

第27行到第31行:分别向TOPIC1,TOPIC2发送消息,时间间隔为10秒。

results matching ""

    No results matching ""