Compare commits
2 Commits
9591653e43
...
062d483880
Author | SHA1 | Date | |
---|---|---|---|
062d483880 | |||
35e6136f70 |
@ -3,7 +3,7 @@ import os
|
|||||||
|
|
||||||
cwd = GetCurrentDir()
|
cwd = GetCurrentDir()
|
||||||
src = [
|
src = [
|
||||||
'filesystem.c',
|
'mqtt.c',
|
||||||
]
|
]
|
||||||
|
|
||||||
CPPPATH = [cwd]
|
CPPPATH = [cwd]
|
||||||
|
13
Day5/mqtt.c
13
Day5/mqtt.c
@ -23,6 +23,7 @@ int HAL_Snprintf(char *str, const int len, const char *fmt, ...);
|
|||||||
|
|
||||||
//定义接受文件内容的缓冲区
|
//定义接受文件内容的缓冲区
|
||||||
char buffer[100] = {};
|
char buffer[100] = {};
|
||||||
|
char tmp[256];
|
||||||
|
|
||||||
#define GPIO_LED_B GET_PIN(F,11)
|
#define GPIO_LED_B GET_PIN(F,11)
|
||||||
#define GPIO_LED_R GET_PIN(F,12)
|
#define GPIO_LED_R GET_PIN(F,12)
|
||||||
@ -100,19 +101,19 @@ static int example_subscribe(void *handle)
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
void make_file(char *String)
|
void make_file()
|
||||||
{
|
{
|
||||||
//文件描述符
|
//文件描述符
|
||||||
int fd;
|
int fd;
|
||||||
String[] = "Hello, RT-Thread.Welcom to RSOC!\n temp: 123, humi: 789";
|
// String = "Hello, RT-Thread.Welcom to RSOC!\n temp: 123, humi: 789";
|
||||||
//用只写方式打开文件,如果没有该文件,则创建一个文件
|
//用只写方式打开文件,如果没有该文件,则创建一个文件
|
||||||
fd = open("/fal/test/Data.txt", O_WRONLY | O_CREAT);
|
fd = open("/fal/test/Data.txt", O_APPEND | O_CREAT);
|
||||||
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,String);
|
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,String);
|
||||||
//如果打开成功
|
//如果打开成功
|
||||||
if (fd >= 0)
|
if (fd >= 0)
|
||||||
{
|
{
|
||||||
//写入文件
|
//写入文件
|
||||||
write(fd, String, sizeof(String));
|
write(fd, tmp, sizeof(tmp));
|
||||||
|
|
||||||
// rt_kprintf("Write done.\n");
|
// rt_kprintf("Write done.\n");
|
||||||
|
|
||||||
@ -150,14 +151,14 @@ void make_file(char *String)
|
|||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
char tmp[256];
|
|
||||||
int cnt = 0;
|
int cnt = 0;
|
||||||
void tmp_payload(void)
|
void tmp_payload(void)
|
||||||
{
|
{
|
||||||
// 读取温湿度值
|
// 读取温湿度值
|
||||||
Humi = aht10_read_humidity(Dev);
|
Humi = aht10_read_humidity(Dev);
|
||||||
Temp = aht10_read_temperature(Dev);
|
Temp = aht10_read_temperature(Dev);
|
||||||
sprintf(tmp, "Temp:%f;Humi:%f;Count:%d", Temp, Humi,++cnt);
|
memset(tmp, 0, sizeof(tmp));
|
||||||
|
sprintf(tmp, "Temp: %f;Humi: %f;Count: %d\n", Temp, Humi,++cnt);
|
||||||
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,tmp);
|
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,tmp);
|
||||||
make_file(tmp);
|
make_file(tmp);
|
||||||
sprintf(tmp, "{\"params\":{\"temperature\":%.2f,\"humidity\":%.2f}}", Temp, Humi);
|
sprintf(tmp, "{\"params\":{\"temperature\":%.2f,\"humidity\":%.2f}}", Temp, Humi);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user