This action will force synchronization from 小熊派开源社区/BearPi-HM_Nano, which will overwrite any changes that you have made since you forked the repository, and can not be recovered!!!
Synchronous operation will process in the background and will refresh the page when finishing processing. Please be patient.
本示例将演示如何在BearPi-HM_Nano开发板上使用MQTT协议连接OneNet,使用的是E53_IA1 智慧农业扩展板与 BearPi-HM_Nano 开发板。
int onenet_mqtt_init(void);
OneNET 初始化函数,需要在使用 OneNET 功能前调用。
参数 | 描述 |
---|---|
无 | 无 |
返回 | 描述 |
0 | 成功 |
-1 | 获得设备信息失败 |
-2 | mqtt 客户端初始化失败 |
void onenet_set_cmd_rsp_cb(void(*cmd_rsp_cb)(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size));
设置命令响应回调函数。
参数 | 描述 |
---|---|
recv_data | 接收到的数据 |
recv_size | 数据的长度 |
resp_data | 响应数据 |
resp_size | 响应数据的长度 |
返回 | 描述 |
无 | 无 |
int onenet_mqtt_publish(const char *topic, const uint8_t *msg, size_t len);
利用 mqtt 向指定 topic 发送消息。
参数 | 描述 |
---|---|
topic | 主题 |
msg | 要上传的数据 |
len | 数据长度 |
返回 | 描述 |
0 | 上传成功 |
-1 | 上传失败 |
int onenet_mqtt_upload_string(const char *ds_name, const char *str);
利用 mqtt 向 OneNET 平台发送字符串数据。
参数 | 描述 |
---|---|
ds_name | 数据流名称 |
str | 要上传的字符串 |
返回 | 描述 |
0 | 上传成功 |
-5 | 内存不足 |
int onenet_mqtt_upload_digit(const char *ds_name, const double digit);
利用 mqtt 向 OneNET 平台发送数字数据。
参数 | 描述 |
---|---|
ds_name | 数据流名称 |
digit | 要上传的数字 |
返回 | 描述 |
0 | 上传成功 |
-5 | 内存不足 |
int onenet_mqtt_upload_bin(const char *ds_name, const uint8_t *bin, size_t len);
利用 mqtt 向 OneNET 平台发送二进制文件。会动态申请内存来保存二进制文件,使用前请确保有足够的内存。
参数 | 描述 |
---|---|
ds_name | 数据流名称 |
bin | 二进制文件 |
len | 二进制文件大小 |
返回 | 描述 |
0 | 上传成功 |
-1 | 上传失败 |
int onenet_mqtt_upload_bin_by_path(const char *ds_name, const char *bin_path);
利用 mqtt 向 OneNET 平台发送二进制文件。
参数 | 描述 |
---|---|
ds_name | 数据流名称 |
bin_path | 二进制文件路径 |
返回 | 描述 |
0 | 上传成功 |
-1 | 上传失败 |
在 ENV 里面已经配置好了连接云平台需要的各种信息,直接调用onenet_mqtt_init
函数进行初始化即可,设备会自动连接 OneNET 平台。
当需要上传数据时,可以按照数据类型选择对应的 API 来上传数据。代码示例如下:
char str[] = { "hello world" };
/* 获得温度值 */
temp = get_temperature_value();
/* 将温度值上传到 temperature 数据流 */
onenet_mqtt_upload_digit("temperature",temp);
/* 将hello world上传到 string 数据流 */
onenet_mqtt_upload_string("string",str);
除了支持上传数字和字符串外,软件包还支持上传二进制文件。
可以通过onenet_mqtt_upload_bin
或onenet_mqtt_upload_bin_by_path
来上传二进制文件。代码示例如下
uint8_t buf[] = {0x01, 0x02, 0x03};
/* 将根目录下的1.bin文件上传到 bin 数据流 */
onenet_mqtt_upload_bin_by_path("bin", "/1.bin");
/* 将 buf 中的数据上传到 bin 数据流 */
onenet_mqtt_upload_bin(("bin", buf, 3);
OneNET 支持下发命令,命令是用户自定义的。用户需要自己实现命令响应回调函数,然后利用onenet_set_cmd_rsp_cb
将回调函数装载上。当设备收到平台下发的命令后,会调用用户实现的命令响应回调函数,等待回调函数执行完成后,将回调函数返回的响应内容再发给云平台。保存响应的内存必须是动态申请出来的,在发送完响应后,程序会自动释放申请的内存。代码示例如下:
static void onenet_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size,uint8_t **resp_data,
size_t *resp_size)
{
/* 申请内存 */
/* 解析命令 */
/* 执行动作 */
/* 返回响应 */
}
int main()
{
/* 用户代码 */
onenet_mqtt_init();
onenet_set_cmd_rsp_cb(onenet_cmd_rsp_cb);
/* 用户代码 */
}
用户可以通过onenet_http_get_datastream
来获取数据流的信息,包括数据流 id,数据流最后更新时间,数据流单位,数据流当前值等等,获取的数据流信息会保存在传入的 datastream 结构体指针所指向的结构体中。代码示例如下
struct rt_onenet_ds_info ds_temp;
/* 获取到 temperature 数据流的信息后保存到 ds_temp 结构体中 */
onenet_http_get_datastream("temperature",ds_temp);
数据点信息可以通过以下 3 个 API 来获取
cJSON *onenet_get_dp_by_limit(char *ds_name, size_t limit);
cJSON *onenet_get_dp_by_start_end(char *ds_name, uint32_t start, uint32_t end, size_t limit);
cJSON *onenet_get_dp_by_start_duration(char *ds_name, uint32_t start, size_t duration, size_t limit);
这三个 API 返回的都是 cJSON 格式的数据点信息,区别只是查询的方法不一样,下面通过示例来讲解如何使用这 3 个 API。
/* 获取 temperature 数据流的最后10个数据点信息 */
dp = onenet_get_dp_by_limit("temperature",10);
/* 获取 temperature 数据流2018年7月19日14点50分0秒到2018年7月19日14点55分20秒的前10个
数据点信息 */
/* 第二、三个参数是Unix时间戳 */
dp = onenet_get_dp_by_start_end("temperature",1531983000,1531983320,10);
/* 获取 temperature 数据流2018年7月19日14点50分0秒往后50秒内的前10个数据点信息 */
/* 第二个参数是Unix时间戳 */
dp = onenet_get_dp_by_start_end("temperature",1531983000,50,10);
onenet_mqtt_init
函数,在初始化函数里会将回调函数指向NULL。设备接入 OneNET 云之前,需要在平台注册用户账号,OneNET 云平台地址:https://open.iot.10086.cn
通过左边栏产品导航进入 多协议接入
点击右上角的 添加产品,在弹出页面中按照提示填写产品的基本信息,进行产品创建;请您按照提示尽可能完整、全面地填写相应内容,这样更方便您后期对产品进行管理接入协议选择 MQTT
协议,如下图所示:
点击产品列表中产品信息,进入产品详情
点击左侧 设备列表,进入设备列表,点击右侧 添加设备
编辑设备名称 与 设备描述,点击 添加,完成添加设备
点击设备右侧的详情,进入设备详情页面,点击 添加APIKey,输入自定义的APIKey完成添加。
修改 applications\BearPi\BearPi-HM_Nano\sample\D7_iot_cloud_onenet
路径下 iot_cloud_onenet_sample.c
文件,
其中ONENET_INFO_PROID
和ONENET_MASTER_APIKEY
修改为产品的产品ID和Master-APIkey
#define ONENET_INFO_PROID "383575"
#define ONENET_MASTER_APIKEY "GNQeLPioqBVpndus2KABmdOVZZI="
ONENET_INFO_DEVID
修改为设备ID;ONENET_INFO_AUTH
修改为鉴权信息;ONENET_INFO_APIKEY
修改为APIKey。
#define ONENET_INFO_DEVID "648900765"
#define ONENET_INFO_AUTH "2020123456789"
#define ONENET_INFO_APIKEY "JHr7UCOXy2tbHkHqWTSwIlU3NzQ="
Wifi_SSID
修改为Wifi热点名称;Wifi_PASSWORD
修改为Wifi热点密码。
#define Wifi_SSID "TP-LINK_65A8"
#define Wifi_PASSWORD "0987654321"
修改 applications\BearPi\BearPi-HM_Nano\sample
ifi路径下 BUILD.gn 文件,指定 onenet_mqtt
参与编译。
#"D1_iot_wifi_sta:wifi_sta",
#"D2_iot_wifi_sta_connect:wifi_sta_connect",
#"D3_iot_udp_client:udp_client",
#"D4_iot_tcp_server:tcp_server",
#"D5_iot_mqtt:iot_mqtt",
#"D6_iot_cloud_oc:oc_mqtt",
"D7_iot_cloud_onenet:onenet_mqtt",
示例代码编译烧录代码后,按下开发板的RESET按键,通过串口助手查看日志,会打印温湿度及光照强度信息。
=======================================
***********IoT_OneNET_example**********
=======================================
******************************Lux Value is 40.83
******************************Humidity is 54.76
******************************Temperature is 24.43
=======================================
***********IoT_OneNET_example**********
=======================================
******************************Lux Value is 41.67
******************************Humidity is 54.77
******************************Temperature is 24.43
点击平台设备右侧的数据流,查看上报上来的数据。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。