ibm-cloud - 用于发布和订阅主题的 IBM IOT 代码
问题描述
嘿,我是 IBM IOT 的新手,但我没有使用 paho-mqtt 轻松发布和订阅主题的方法。如果有任何好的文档,请告诉我。
解决方案
我建议使用 ibm iot python sdk。您可以在此处找到安装说明: https ://ibm-watson-iot.github.io/iot-python/
以下是有关如何连接和发布事件的示例代码
https://ibm-watson-iot.github.io/iot-python/device/#sample-code
import wiotp.sdk.device
def myCommandCallback(cmd):
print("Command received: %s" % cmd.data)
# Configure
myConfig = wiotp.sdk.device.parseConfigFile("device.yaml")
client = wiotp.sdk.device.DeviceClient(config=myConfig, logHandlers=None)
client.commandCallback = myCommandCallback
# Connect
client.connect()
# Send Data
myData={'name' : 'foo', 'cpu' : 60, 'mem' : 50}
client.publishEvent(eventId="status", msgFormat="json", data=myData, qos=0, onPublish=None)
# Disconnect
client.disconnect()
device.yaml 的示例是
myConfig = {
"identity": {
"orgId": "org1id",
"typeId": "raspberry-pi-3"
"deviceId": "00ef08ac05"
}.
"auth" {
"token": "Ab$76s)asj8_s5"
}
}
client = wiotp.sdk.device.DeviceClient(config=myConfig)
以上信息可从物联网平台界面获取
推荐阅读
- cypress - Apple Mac M1 - 尝试运行 docker run 命令来运行 cypress 测试会引发错误
- python - 如何使用flutter实时运行python作为后端
- python - 加载大型 XML 文件时导致“内存错误”
- ssl - Netty:握手失败
- android - 错误:[storage/unknown] Permission Denial:读取需要导出提供程序,或 grantUriPermission()
- java - 在 VSCode 中启动 tomcat 服务器时出现问题
- perl - 关于 Crypt::OpenSSL::RSA->verify 方法的问题
- java - Firebase 未从 Android Studio 接收数据
- python - asyncio 2 工作人员 RuntimeWarning:从未等待协程“睡眠”
- typescript - Svelte:在焦点上选择输入元素的文本