MQTTDjango公司。我如何实现它?

2024-03-29 07:40:24 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试实现Django Mqtt系统,但是我有点迷路了。我想用从主题中得到的数据不断更新我的模型。你知道吗

我已经设法用这个函数更新了模型数据视图.py地址:

def dhtDetail(request):
    member = request.user.userprofile
    listDHT = member.dht.all()

    for sensor in listDHT:

        topic = sensor.topic

        #This topic (sensor.topic) has temperature and humidity data
        m = subscribe.simple(topic, hostname="Broker IP", retained=False)

        mes = str(m.payload)
        mes = men.replace("'", "")
        mes = men.replace("b", "")
        mes = men.replace("Hum", "")
        mes = men.replace("Temp", "")
        mes = men.split(" ")

        sensor.temp = float(mes[3])
        sensor.hum = float(mes[1])

        sensor.save()
        member.dht.add(sensor)

    listDHT = member.dht.all()

    return render(request, 'web/dhtDetail.html', {'listDHT':listDHT})

显然,这只会连接到代理并在dhtDetail.html文件“重新加载。如何使用Django实现MQTT以不断更新模型?你知道吗


Tags: 数据django模型topicrequestsensorallfloat