开源paho mqtt接入物联网平台【python】

简介: 通过开源的paho mqtt库,接入阿里云物联网平台,通过python语言实现。
import hmac
from hashlib import sha1
import paho.mqtt.client as mqtt
import json
import time

product_key = "****"
device_name = "****"
device_secret = "****"

#旧版公共实例的host
host = product_key + ".iot-as-mqtt.cn-shanghai.aliyuncs.com"
#新版公共实例的host,控制台查看开发配置中的mqtt接入域名
#instance_id = "***"
#host = instance_id + ".mqtt.iothub.aliyuncs.com"

port = 1883

#以下参数的含义,具体请参考:https://help.aliyun.com/document_detail/73742.html
client_id = "12345"
content = "clientId" + client_id + "deviceName" + device_name + "productKey" + product_key

mqttClientId = client_id + "|securemode=2,signmethod=hmacsha1|"
mqttUsername = device_name + '&' + product_key
mqttPassword = hmac.new(device_secret.encode(), content.encode(), sha1).hexdigest()


def connect_mqtt():
    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("connect success!")
        else:
            print("connect failed...")

    client = mqtt.Client(mqttClientId)
    client.username_pw_set(username=mqttUsername, password=mqttPassword)
    client.on_connect = on_connect
    client.connect(host, port)
    return client

#消息回调
def on_message(client, userdata, msg):
    topic = msg.topic
    payload = msg.payload.decode()

    print("收到消息!    topic:" + topic)
    print("收到消息!    payload:" + payload)
    print("     ")

    if ("thing/service/property/set" in topic):
        on_thing_prop_changed(client, msg.topic, msg.payload)


#属性设置的处理函数
def on_thing_prop_changed(client,topic,payload):
    post_topic = topic.replace("service","event")
    post_topic = post_topic.replace("set","post")

    Msg = json.loads(payload)
    params = Msg['params']
    post_payload = "{\"params\":" + json.dumps(params) + "}"

    print("收到属性设置的指令,需要主动上报属性变化的topic:" + post_topic)
    print("收到属性设置的指令,需要主动上报属性变化的payload:" + post_payload)
    print("    ")
    client.publish(post_topic, post_payload)


client = connect_mqtt()
client.loop_start()
client.on_message = on_message

#订阅topic
#client.subscribe("${topic}")

#发布消息
#client.publish("${topic}", "${payload}")

while True:
    time.sleep(1)


相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
4月前
|
人工智能 自然语言处理 数据可视化
中国版“Manus”开源?AiPy:用Python重构AI生产力的通用智能体
AiPy是LLM大模型+Python程序编写+Python程序运行+程序可以控制的一切。
|
5月前
|
程序员 测试技术 开发工具
怎么开发Python第三方库?手把手教你参与开源项目!
大家好,我是程序员晚枫。本文将分享如何开发Python第三方库,并以我维护的开源项目 **popdf** 为例,指导参与开源贡献。Popdf是一个PDF操作库,支持PDF转Word、转图片、合并与加密等功能。文章涵盖从fork项目、本地开发、单元测试到提交PR的全流程,适合想了解开源贡献的开发者。欢迎访问[popdf](https://gitcode.com/python4office/popdf),一起交流学习!
187 21
怎么开发Python第三方库?手把手教你参与开源项目!
|
7月前
|
人工智能 程序员 测试技术
我的开源项目达成1000 star里程碑!python-office招募开源小伙伴
大家好,这里是程序员晚枫。我的首个开源项目 **python-office** 在GitHub上达到了1000星!该项目始于2022年初,旨在帮助更多人快速入门Python。历经多个里程碑,包括被开源中国推荐、发布官网和操作视频等。目前下载量已达26万+,并被评为GitCode毕业项目。未来计划包括统一代码风格、增加功能、完善文档和单元测试,以及招募开源小伙伴共同维护。欢迎感兴趣的朋友私信我:**开源**。 ![Stargazers over time](https://starchart.cc/CoderWanFeng/python-office.svg)
108 11
我的开源项目达成1000 star里程碑!python-office招募开源小伙伴
|
8月前
|
人工智能 开发者 Python
Chainlit:一个开源的异步Python框架,快速构建生产级对话式 AI 应用
Chainlit 是一个开源的异步 Python 框架,帮助开发者在几分钟内构建可扩展的对话式 AI 或代理应用,支持多种工具和服务集成。
671 9
|
10月前
|
人工智能 API 开发工具
aisuite:吴恩达发布开源Python库,一个接口调用多个大模型
吴恩达发布的开源Python库aisuite,提供了一个统一的接口来调用多个大型语言模型(LLM)服务。支持包括OpenAI、Anthropic、Azure等在内的11个模型平台,简化了多模型管理和测试的工作,促进了人工智能技术的应用和发展。
482 1
aisuite:吴恩达发布开源Python库,一个接口调用多个大模型
|
10月前
|
机器学习/深度学习 算法 编译器
Python程序到计算图一键转化,详解清华开源深度学习编译器MagPy
【10月更文挑战第26天】MagPy是一款由清华大学研发的开源深度学习编译器,可将Python程序一键转化为计算图,简化模型构建和优化过程。它支持多种深度学习框架,具备自动化、灵活性、优化性能好和易于扩展等特点,适用于模型构建、迁移、部署及教学研究。尽管MagPy具有诸多优势,但在算子支持、优化策略等方面仍面临挑战。
294 3
|
11月前
|
存储 JSON Ubuntu
时序数据库 TDengine 支持集成开源的物联网平台 ThingsBoard
本文介绍了如何结合 Thingsboard 和 TDengine 实现设备管理和数据存储。Thingsboard 中的“设备配置”与 TDengine 中的超级表相对应,每个设备对应一个子表。通过创建设备配置和设备,实现数据的自动存储和管理。具体操作包括创建设备配置、添加设备、写入数据,并展示了车辆实时定位追踪和车队维护预警两个应用场景。
403 3
|
10月前
|
存储 算法 安全
FreeMQTT:一款Python语言实现的开源MQTT Server
FreeMQTT 是一款用 Python 语言并基于 Tornado 开发的开源 MQTT 服务器,支持 MQTT3.1.1 和 MQTT5.0 协议,提供多租户安全隔离、高效 Topic 匹配算法及实时上下线通知等功能,适用于 IoT 场景。快速启动仅需克隆仓库、安装依赖并运行服务。
1113 0
|
12月前
|
Linux Android开发 iOS开发
开源的Python库,用于开发多点触控应用程序
Kivy是一款开源Python库,专为开发多点触控应用设计,支持Android、iOS、Linux、OS X和Windows等平台。本文将指导你使用Kivy创建“Hello World”应用并打包成Android APK。首先通过`pip install kivy`安装Kivy,然后创建并运行一个简单的Python脚本。接着,安装Buildozer并通过`buildozer init`生成配置文件,修改相关设置后,运行`buildozer -v android debug`命令打包应用。完成构建后,你将在`./bin/`目录下找到类似`your-app-debug.apk`的文件。
266 2
|
存储 Python 容器
python中的h5py开源库的使用
python中的h5py开源库的使用
168 1

相关产品

  • 物联网平台
  • 推荐镜像

    更多