问卷调查[mqtt dht]

任务

this code uses esp32-wroom-32 and dht11 to read the humidty and temperature, besieds,          it will send the meassage to the cloud platform. All communication is conducted through MQTT.

打分标准

您应该对以下代码进行评级，并且必须遵守如下所示的评级规则。

您只能根据以下标准对1、2、3、4或5进行评分：

1.如果只有一个main function 或只有文本注释，甚至没有基本代码，则得1分（如下为1分代码）；

#include <stdio.h>
#include "xtimer.h"// Self Executable: Test basic functionality by printing a message
int main(void) {printf("Starting Riot-OS code generation process...\n");return 0;
}

2.如果仅实现了部分功能，例如仅实现通信（如使用mqtt协议通信）或仅实现外设控制（如传感器读取温湿度），则得分为2（如下为2分代码）；

#include <stdio.h>
#include "ztimer.h"
#include "dht.h"
#include "dht_params.h"// Placeholder for MQTT – we will validate dependencies in the next step#define DELAY (5 * 1000000) // 5 seconds in microsecondsint main(void) {dht_t dev;int16_t temp, hum;puts("Initializing DHT temperature and humidity sensor...");if (dht_init(&dev, &dht_params[0]) != DHT_OK) {puts("Failed to initialize DHT sensor.");return 1;}puts("DHT sensor initialized successfully!");// Placeholder section for MQTT – will be connected after validationwhile (1) {ztimer_sleep(ZTIMER_USEC, DELAY);if (dht_read(&dev, &temp, &hum) != DHT_OK) {puts("Failed to read data from DHT sensor.");continue;}printf("Temperature: %d.%d°C, Humidity: %d.%d%%\n",temp / 10, temp % 10, hum / 10, hum % 10);}return 0;
}

3.如果功能大部分已实现，但缺少一些特定的操作代码或使用注释代替代码（例如，缺少pwm库控制亮度，缺少adc库，LED缺少进行烟雾探测，缺少dht读数），则得分为3；

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include "paho_mqtt.h"
#include "MQTTClient.h"
#include "xtimer.h"
#include "periph/gpio.h"// MQTT Parameters
#define MQTT_SERVER "101.133.196.127"
#define MQTT_PORT 1883
#define MQTT_USER "YOUR_MQTT_USERNAME"
#define MQTT_PASSWORD "YOUR_MQTT_PASSWORD"
#define MQTT_CLIENT_ID "YOUR_MQTT_CLIENT_ID"
#define SUBSCRIBE_TOPIC "YOUR_SUBSCRIBE_TOPIC"
#define REPORT_TOPIC "YOUR_REPORT_TOPIC"// GPIO Configurations for DHT11
#define DHT_GPIO 4  // Assuming GPIO 4 for DHT11 sensor// MQTT Client Buffer Sizes
#define BUF_SIZE 1024
#define COMMAND_TIMEOUT_MS 6000
#define KEEP_ALIVE_INTERVAL 60static MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];// Function prototypes
void mqtt_setup(void);
void init_gpio(void);
int reconnect(void);
void report_property(const char* topic, char* json);
void messageArrived(MessageData* data);// Placeholder for fetching sensor data; real implementation should replace this
float* fetch_sensor_data(void);void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, COMMAND_TIMEOUT_MS, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized\n");
}void init_gpio(void) {if (gpio_init(DHT_GPIO, GPIO_IN) < 0) {printf("Error initializing GPIO for DHT11\n");} else {printf("DHT11 GPIO initialized successfully\n");}
}int reconnect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.clientID.cstring = MQTT_CLIENT_ID;data.username.cstring = MQTT_USER;data.password.cstring = MQTT_PASSWORD;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Failed to connect to network (%d)\n", rc);return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("Failed to connect to broker (%d)\n", rc);return rc;}MQTTSubscribe(&client, SUBSCRIBE_TOPIC, QOS1, messageArrived);printf("Connected to broker and topic subscribed\n");return 0;
}void report_property(const char* topic, char* json) {MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = json;message.payloadlen = strlen(json);if (MQTTPublish(&client, topic, &message) == SUCCESS) {printf("Published: %s\n", json);} else {printf("Failed to publish message\n");}
}void messageArrived(MessageData* data) {char* payload = (char*)data->message->payload;printf("Message arrived [%.*s]: %.*s\n",(int)data->topicName->lenstring.len, data->topicName->lenstring.data,(int)data->message->payloadlen, payload);if (strstr(payload, "\"command\":\"ALARM_ON\"")) {gpio_set(DHT_GPIO);} else if (strstr(payload, "\"command\":\"ALARM_OFF\"")) {gpio_clear(DHT_GPIO);}
}float* fetch_sensor_data(void) {static float sensor_data[2] = {25.0, 60.0};  // Replace with real DHT11 logicreturn sensor_data;
}int main(void) {mqtt_setup();init_gpio();while (1) {if (!client.isconnected) {NetworkDisconnect(&network);reconnect();}float* sensor_data = fetch_sensor_data();char json[256];snprintf(json, sizeof(json), "{\"temperature\": %.1f, \"humidity\": %.1f}",sensor_data[0], sensor_data[1]);report_property(REPORT_TOPIC, json);MQTTYield(&client, 1000);xtimer_sleep(5);}return 0;
}
// Self Executable

4.如果功能大多是在不使用注释代替代码的情况下实现的，但实现尚未完善（例如，缺乏重新连接、缺乏初始化、缺乏关闭等），则得分为4；

#include <stdio.h>
#include "periph/gpio.h"
#include "periph/i2c.h"
#include "dht.h"
#include "xtimer.h"
#include "paho_mqtt.h"
#include "MQTTClient.h"// Definitions
#define DHT_PIN GPIO_PIN(0, 4) // GPIO pin for DHT connection
#define MQTT_SERVER "101.133.196.127"
#define MQTT_PORT 1883
#define MQTT_USER "YOUR_MQTT_USERNAME"
#define MQTT_PASSWORD "YOUR_MQTT_PASSWORD"
#define MQTT_CLIENT_ID "YOUR_MQTT_CLIENT_ID"
#define REPORT_TOPIC "YOUR_REPORT_TOPIC"// MQTT Buffers
#define BUF_SIZE 1024
#define COMMAND_TIMEOUT_MS 6000
#define KEEP_ALIVE_INTERVAL 60static MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];// Function declarations
void mqtt_setup(void);
int reconnect(void);
void report_property(const char *topic, char *payload);void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, COMMAND_TIMEOUT_MS, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized\\n");
}int reconnect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.clientID.cstring = MQTT_CLIENT_ID;data.username.cstring = MQTT_USER;data.password.cstring = MQTT_PASSWORD;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Network connection failed (%d)\\n", rc);return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("MQTT connection failed (%d)\\n", rc);return rc;}printf("MQTT broker connected\\n");return 0;
}void report_property(const char *topic, char *payload) {MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = payload;message.payloadlen = strlen(payload);MQTTPublish(&client, topic, &message);printf("Message published: %s\\n", payload);
}int main(void) {mqtt_setup();if (reconnect() != 0) {return -1;}// Define DHT parametersdht_params_t dht_params = {.pin = DHT_PIN,.type = DHT11};dht_t dev;if (dht_init(&dev, &dht_params) != DHT_OK) {printf("Failed to initialize DHT sensor\\n");return -1;}// Initialize DHT and reading variablesint16_t temperature, humidity;char json[256];while (1) {if (dht_read(&dev, &temperature, &humidity) == DHT_OK) {snprintf(json, sizeof(json), "{\"temperature\": %d.%d, \"humidity\": %d.%d}",temperature / 10, temperature % 10, humidity / 10, humidity % 10);report_property(REPORT_TOPIC, json);} else {printf("Failed to read DHT sensor\\n");}xtimer_sleep(5); // Pause for 5 seconds}return 0;
}

5.如果所有功能都得到充分彻底的实施，则得5分。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "periph/gpio.h"
#include "dht.h"
#include "dht_params.h"
#include "ztimer.h"
#include "ztimer/periodic.h"
#include "paho_mqtt.h"
#include "MQTTClient.h"
#include "xtimer.h"// Define GPIO pins
#define JDQ_PIN GPIO_PIN(0, 16) // GPIO pin for additional control (relay)
#define DHT_PIN GPIO_PIN(0, 17) // GPIO pin connected to DHT11 data pin// Setup for interval
#define SEND_INTERVAL_SEC 5     // Interval for periodic data reading// Setup for DHT sensor
static dht_t dht_sensor;
static int16_t temperature, humidity;// MQTT Parameters
#define MQTT_SERVER "101.133.196.127"
#define MQTT_PORT 1883
#define MQTT_USER "mma845x&k1untKoVRjM"
#define MQTT_PASSWORD "3b48b9f5eaffff3e55a7e944aaaedcd91b4bf5abcb84c6fba736f455a7619ce0"
#define MQTT_CLIENT_ID "k1untKoVRjM.mma845x|securemode=2,signmethod=hmacsha256,timestamp=1731296949691|"
#define REPORT_TOPIC "/sys/k1untEWIVZV/dht11/thing/service/property/set"// MQTT Client Buffer Sizes
#define BUF_SIZE 1024
#define COMMAND_TIMEOUT_MS 6000
#define KEEP_ALIVE_INTERVAL 60static MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];// Function Prototypes
void setup_gpio(void);
void dht_read_action(void);
void mqtt_setup(void);
int reconnect(void);
void publish_sensor_data(void);
_Bool timer_callback(void *arg);int main(void) {puts("Initializing peripherals...");// Initialize GPIOsetup_gpio();// Initialize DHT sensorputs("Initializing DHT sensor...");if (dht_init(&dht_sensor, &dht_params[0]) == DHT_OK) {puts("[OK] DHT sensor initialized");} else {puts("[Error] Failed to initialize DHT sensor");return 1;}// Initialize MQTTmqtt_setup();// Setup ZTIMER Periodic for scheduled executionstatic ztimer_periodic_t periodic_timer;ztimer_periodic_init(ZTIMER_MSEC, &periodic_timer, timer_callback, NULL, SEND_INTERVAL_SEC * 1000);ztimer_periodic_start(&periodic_timer);puts("Started periodic DHT reading and MQTT reporting...");while (1) {// Ensure main thread stays aliveztimer_sleep(ZTIMER_MSEC, SEND_INTERVAL_SEC * 1000);}return 0;
}void setup_gpio(void) {// Initialize JDQ_PIN as output for relay controlif (gpio_init(JDQ_PIN, GPIO_OUT) != 0) {puts("[Error] Failed to initialize JDQ_PIN as output");return;}gpio_clear(JDQ_PIN);puts("[OK] GPIO initialized for JDQ_PIN");
}void dht_read_action(void) {// Read temperature and humidityif (dht_read(&dht_sensor, &temperature, &humidity) != DHT_OK) {puts("[Error] Failed to read data from DHT sensor");} else {printf("Temperature: %d.%d°C, Humidity: %d.%d%%\n",temperature / 10, temperature % 10,humidity / 10, humidity % 10);}
}void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, COMMAND_TIMEOUT_MS, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized.\n");if (reconnect() != 0) {puts("[Error] Failed to connect to MQTT broker");return;}
}int reconnect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.clientID.cstring = MQTT_CLIENT_ID;data.username.cstring = MQTT_USER;data.password.cstring = MQTT_PASSWORD;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Failed to connect to network (%d).\n", rc); return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("Failed to connect to broker (%d).\n", rc); return rc;}printf("Connected to broker successfully.\n");return 0;
}void publish_sensor_data(void) {char json[256];snprintf(json, sizeof(json), "{\"temperature\": %d.%d, \"humidity\": %d.%d}",temperature / 10, temperature % 10,humidity / 10, humidity % 10);MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = json;message.payloadlen = strlen(json);if (MQTTPublish(&client, REPORT_TOPIC, &message) == 0) {printf("Published: %s\n", json);} else {puts("[Error] Failed to publish message");}
}_Bool timer_callback(void *arg) {(void)arg;// Perform DHT readdht_read_action();// Publish data to MQTT brokerpublish_sensor_data();return 1;
}

代码

代码1

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "paho_mqtt.h"
#include "MQTTClient.h"
#include "xtimer.h"
#include "periph/gpio.h"
#include "dht.h"
#include "dht_params.h"
#include "ztimer.h"// Define GPIO pins according to specific ESP32 board configuration
#define DHT_PIN            GPIO_PIN(0, 17)  // Example GPIO pin for ESP32
#define LED_PIN            GPIO_PIN(0, 2)   // Example GPIO pin for ESP32// Define the delay in microseconds
#define DELAY (2U * (1000 * 1000))// MQTT Parameters
#define MQTT_SERVER "101.133.196.127"
#define MQTT_PORT 1883
#define MQTT_USER "mma845x&k1untKoVRjM"
#define MQTT_PASSWORD "password"
#define MQTT_CLIENT_ID "unique_client_id"
#define SUBSCRIBE_TOPIC "/sys/k1untEWIVZV/dht11/thing/service/property/set"
#define REPORT_TOPIC "/sys/k1untEWIVZV/dht11/thing/service/property/report"// MQTT Client Buffer Sizes
#define BUF_SIZE 1024
#define COMMAND_TIMEOUT_MS 6000
#define KEEP_ALIVE_INTERVAL 60static MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];// Function Prototypes
void mqtt_setup(void);
int reconnect(void);
void report_property(const char* topic, char* payload);
void messageArrived(MessageData* data);
void init_gpio(void);void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, COMMAND_TIMEOUT_MS, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized\\n");
}int reconnect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.clientID.cstring = MQTT_CLIENT_ID;data.username.cstring = MQTT_USER;data.password.cstring = MQTT_PASSWORD;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Failed to connect to network (%d)\\n", rc);return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("Failed to connect to broker (%d)\\n", rc);return rc;}MQTTSubscribe(&client, SUBSCRIBE_TOPIC, QOS1, messageArrived);printf("Subscribed to topic: %s\\n", SUBSCRIBE_TOPIC);return 0;
}void report_property(const char* topic, char* json) {MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = (void*)json;message.payloadlen = strlen(json);MQTTPublish(&client, topic, &message);printf("Published: %s\\n", json);
}void messageArrived(MessageData* data) {char* payload = (char*)data->message->payload;printf("Message arrived [%.*s]: %.*s\\n",(int)data->topicName->lenstring.len, data->topicName->lenstring.data,(int)data->message->payloadlen, payload);// Add your message handling logic here, if needed
}void init_gpio(void) {gpio_init(LED_PIN, GPIO_OUT);
}int main(void) {dht_t dev;int16_t temp, hum;puts("DHT temperature and humidity sensor + MQTT application\\n");// Initialize DHT sensor with specified parametersdht_params_t params = {.pin = DHT_PIN,.type = DHT11,};if (dht_init(&dev, &params) != DHT_OK) {puts("Error: Could not initialize DHT11 sensor");return 1;}mqtt_setup();init_gpio();while (1) {if (!MQTTIsConnected(&client)) {NetworkDisconnect(&network);if (reconnect() != 0) {xtimer_sleep(1);continue;}}// Read data from DHT sensorif (dht_read(&dev, &temp, &hum) == DHT_OK) {printf("Temperature: %d.%d°C, Humidity: %d.%d%%\\n", temp / 10, temp % 10, hum / 10, hum % 10);// Turn on LED if temperature is above 25.0°C (threshold)if (temp > 250) {gpio_set(LED_PIN);} else {gpio_clear(LED_PIN);}// JSON payload constructionchar json[256];snprintf(json, sizeof(json), "{\\\"temperature\\\": %d.%d, \\\"humidity\\\": %d.%d}",temp / 10, temp % 10, hum / 10, hum % 10);// Publish data via MQTTreport_property(REPORT_TOPIC, json);} else {puts("Error reading values from DHT11 sensor");}MQTTYield(&client, 1000);xtimer_sleep(5);  // Sleep for 5 seconds}return 0;
// Self Executable
}

评分： 

代码2

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include "periph/gpio.h"
#include "xtimer.h"
#include "paho_mqtt.h"
#include "MQTTClient.h"#define SENSOR_INTERVAL 5000  // Interval to poll DHT11 data in milliseconds// MQTT Configuration
#define MQTT_SERVER "test.mosquitto.org"
#define MQTT_PORT 1883
#define MQTT_USER NULL
#define MQTT_PASSWORD NULL
#define MQTT_CLIENT_ID "esp32-dht11-client"
#define SUBSCRIBE_TOPIC "/dht11/commands"
#define REPORT_TOPIC "/dht11/data"#define BUF_SIZE 1024
#define COMMAND_TIMEOUT_MS 6000
#define KEEP_ALIVE_INTERVAL 60static MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];void init_sensor_and_hardware(void);
void mqtt_setup(void);
void report_property(const char* topic, char* payload);
void publish_sensor_data(float temperature, float humidity);
int reconnect(void);
int read_sensor_data(float* temperature, float* humidity);// Initialize sensor and GPIO
void init_sensor_and_hardware(void) {printf("Mock: Sensor initialized successfully\n");
}// Mock reading temperature and humidity values
int read_sensor_data(float* temperature, float* humidity) {if (!temperature || !humidity) {return -1;}*temperature = 25.0;  // Mock data*humidity = 60.0;     // Mock dataprintf("Mock: Read Temperature = %.2f°C, Humidity = %.2f%%\n", *temperature, *humidity);return 0;
}// Setup MQTT
void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, COMMAND_TIMEOUT_MS, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized\n");reconnect();
}// Reconnect to MQTT broker
int reconnect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;data.clientID.cstring = MQTT_CLIENT_ID;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Mock: Failed to connect to network (%d)\n", rc);return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("Mock: Failed to connect to broker (%d)\n", rc);return rc;}printf("Mock: MQTT connected\n");return 0;
}// Publish sensor data to MQTT
void publish_sensor_data(float temperature, float humidity) {char json[128];snprintf(json, sizeof(json), "{\"temperature\": %.2f, \"humidity\": %.2f}", temperature, humidity);report_property(REPORT_TOPIC, json);
}// Helper to publish property
void report_property(const char* topic, char* payload) {MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = payload;message.payloadlen = strlen(payload);MQTTPublish(&client, topic, &message);printf("Mock: Published: %s\n", payload);
}int main(void) {printf("Starting ESP32-DHT11 MQTT application\n");init_sensor_and_hardware();mqtt_setup();while (1) {float temperature = 0, humidity = 0;if (read_sensor_data(&temperature, &humidity) == 0) {publish_sensor_data(temperature, humidity);}xtimer_sleep(SENSOR_INTERVAL / 1000);}return 0;
}
// Self Executable

 评分：

代码三

#include <stdio.h>
#include <string.h>
#include "paho_mqtt.h"
#include "MQTTClient.h"
#include "ztimer.h"
#include "dht.h"
#include "dht_params.h"// MQTT Parameters
#define MQTT_SERVER "101.133.196.127"
#define MQTT_PORT 1883
#define MQTT_USER "YOUR_MQTT_USERNAME"
#define MQTT_PASSWORD "YOUR_MQTT_PASSWORD"
#define MQTT_CLIENT_ID "YOUR_MQTT_CLIENT_ID"
#define REPORT_TOPIC "YOUR_REPORT_TOPIC"// MQTT Client Buffer Sizes
#define BUF_SIZE 1024
#define KEEP_ALIVE_INTERVAL 60
#define UPDATE_INTERVAL     (2 * US_PER_SEC) // 2 seconds delaystatic MQTTClient client;
static Network network;
static unsigned char buf[BUF_SIZE];
static unsigned char readbuf[BUF_SIZE];void mqtt_setup(void) {NetworkInit(&network);MQTTClientInit(&client, &network, 4000, buf, BUF_SIZE, readbuf, BUF_SIZE);printf("MQTT client initialized\n");
}int mqtt_connect(void) {MQTTPacket_connectData data = MQTTPacket_connectData_initializer;data.MQTTVersion = 4;data.clientID.cstring = MQTT_CLIENT_ID;data.username.cstring = MQTT_USER;data.password.cstring = MQTT_PASSWORD;data.keepAliveInterval = KEEP_ALIVE_INTERVAL;data.cleansession = 1;int rc = NetworkConnect(&network, MQTT_SERVER, MQTT_PORT);if (rc != 0) {printf("Failed to connect to network (%d)\n", rc);return rc;}rc = MQTTConnect(&client, &data);if (rc != 0) {printf("Failed to connect to broker (%d)\n", rc);return rc;}return 0;
}void report_property(const char* topic, char* json) {MQTTMessage message;message.qos = QOS0;message.retained = 0;message.payload = json;message.payloadlen = strlen(json);MQTTPublish(&client, topic, &message);printf("Published: %s\n", json);
}void read_and_publish_data(dht_t *dev) {int16_t temperature, humidity;if (dht_read(dev, &temperature, &humidity) != DHT_OK) {puts("Failed to read from DHT sensor");return;}char payload[256];snprintf(payload, sizeof(payload), "{\"temperature\": %.1f, \"humidity\": %.1f}", temperature / 10.0, humidity / 10.0);report_property(REPORT_TOPIC, payload);
}int main(void) {dht_t sensor;mqtt_setup();if (mqtt_connect() != 0) {return 1;}if (dht_init(&sensor, &dht_params[0]) != DHT_OK) {puts("Failed to initialize DHT sensor");return 1;}printf("Successfully initialized DHT sensor\n");while (1) {read_and_publish_data(&sensor);MQTTYield(&client, 1000);  // MQTT client task handlingztimer_sleep(ZTIMER_USEC, UPDATE_INTERVAL);  // Sleep for update interval}return 0;
}

评分：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.tpcf.cn/web/86536.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

swift 对象转Json

swift 对象转Json

在 Swift 中将对象转换为 JSON 可以通过以下方法实现&#xff1a; 使用 Codable 协议 Swift 的 Codable 协议&#xff08;Encodable 和 Decodable 的组合&#xff09;是处理 JSON 编码和解码的推荐方式。 struct Person: Codable {var name: Stringvar age: Int }let person…
阅读更多...
Python学习Day43

Python学习Day43

学习来源&#xff1a;浙大疏锦行 import torch import torch.nn as nn import torch.nn.functional as F import torchvision import torchvision.transforms as transforms import numpy as np import matplotlib.pyplot as plt from PIL import Image import os # 设置随机…
阅读更多...
了解一下Unity AssetBundle 的几种加载方式

了解一下Unity AssetBundle 的几种加载方式

Unity 的 AssetBundle 系统提供了多种加载方式&#xff0c;以满足不同场景下的资源管理和性能需求。 同步加载&#xff08;LoadFromFile&#xff09; 同步加载使用 AssetBundle.LoadFromFile 方法从文件系统中直接加载 AssetBundle。这种方式会阻塞主线程&#xff0c;直到加载…
阅读更多...
鸿蒙边缘智能计算架构实战：多线程图像采集与高可靠缓冲设计

鸿蒙边缘智能计算架构实战：多线程图像采集与高可靠缓冲设计

目录 一、技术背景与挑战二、鸿蒙边缘计算架构的核心特性1. 分布式软总线&#xff1a;打破设备孤岛2. 轻量化多线程模型 三、多线程图像采集的稳定性设计1. 分层缓冲队列架构2. 线程优先级策略 四、边缘侧高可靠缓冲机制1. 基于分布式数据管理的容错设计2. 动态带宽调节 五、实…
阅读更多...
excel中vba开发工具

excel中vba开发工具

1、支持单元格点击出现弹框进行选择 支持模多次模糊查询 Private Sub CommandButton1_Click() Call vehicle_查询 End SubPrivate Sub Worksheet_Activate()Call vehicle_取出车架号和公司名称 取出不重复的车架号Sheet13.ComboBox1.Visible False 车架号显示Sheet13.ComboB…
阅读更多...
CatBoost：征服类别型特征的梯度提升王者

CatBoost：征服类别型特征的梯度提升王者

基于有序提升与对称树的下一代GBDT框架&#xff0c;重塑高维分类数据处理范式 一、CatBoost的诞生&#xff1a;解决类别特征的终极挑战 2017年由俄罗斯Yandex团队开源&#xff0c;CatBoost&#xff08;Categorical Boosting&#xff09;直指机器学习中的核心痛点&#xff1a;类…
阅读更多...
使用 WSL 启动ubuntu.tar文件

使用 WSL 启动ubuntu.tar文件

使用 WSL 启动ubuntu.tar文件&#xff0c;可按以下步骤进行3&#xff1a; 检查 WSL 版本&#xff1a;确保你的 WSL 版本为 2.4.8 或更高版本。可以在命令行中输入wsl --update来更新 WSL 到最新版本。 设置默认 WSL 版本&#xff1a;如果还没有将 WSL 2 设置为默认版本&#x…
阅读更多...
vue-23（创建用于逻辑提取的可重用组合组件）

vue-23（创建用于逻辑提取的可重用组合组件）

创建用于逻辑提取的可重用组合组件 可重用的组合式是 Vue 组合式 API 的基石&#xff0c;它使你能够在多个组件中提取和重用有状态逻辑。这有助于编写更清晰的代码&#xff0c;减少冗余&#xff0c;并提高可维护性。通过将特定功能封装到组合式中&#xff0c;你可以轻松地共享…
阅读更多...
数据透视表学习笔记

数据透视表学习笔记

学习视频&#xff1a;Excel数据透视表大全&#xff0c;3小时从小白到大神&#xff01;_哔哩哔哩_bilibili 合并行标签 初始数据透视表 不显示分类汇总 以大纲形式显示 在组的底部显示所有分类汇总 以表格形式显示 合并单元格-右键-数据透视表选项 选中-合并并剧中排列带…
阅读更多...
吃透 Golang 基础：测试

吃透 Golang 基础：测试

文章目录 go test测试函数随机测试测试一个命令白盒测试外部测试包 测试覆盖率基准测试剖析示例函数 go test go test命令是一个按照一定的约定和组织来测试代码的程序。在包目录内&#xff0c;所有以xxx_test.go为后缀名的源文件在执行go build时不会被构建为包的一部分&#…
阅读更多...
酒店服务配置无门槛优惠券

酒店服务配置无门槛优惠券

1.查看酒店绑定的是那个仓库&#xff1b; 凯里亚德酒店(深圳北站壹城中心店)&#xff0c;绑定的是“龙华民治仓&#xff08;睿嘀购” 2.“门店列表”选择“龙华民治仓&#xff08;睿嘀购””中的“绑定场所” 3.通过酒店名字查找绑定的商品模板&#xff1b; 凯里亚德酒店(深圳…
阅读更多...
IoT创新应用场景，赋能海外市场拓展

IoT创新应用场景，赋能海外市场拓展

在数字化浪潮席卷全球的当下&#xff0c;物联网&#xff08;Internet of Things, IoT&#xff09;正以革命性的力量重塑产业生态。这项通过传感器、通信技术及智能算法实现设备互联的技术&#xff0c;不仅推动全球从“万物互联”迈向“万物智联”&#xff0c;更成为赋能企业开拓…
阅读更多...
Idea中Docker打包流程记录

Idea中Docker打包流程记录

1. maven项目&#xff0c;先打package 2.添加Dockerfile 3.执行打包命令 注意最后的路径 . docker buildx build -t xxx-app:版本号 -f Dockerfile . 4.下载文件 docker save -o xxx-app-版本号.tar xxx-app:版本号 5.加载镜像 docker load -i xxx-app-版本号.tar 6.编…
阅读更多...
硬件工程师笔试面试高频考点-电阻

硬件工程师笔试面试高频考点-电阻

目录 1.1 电阻选型时一般从哪几个方面进行考虑? 1.2上拉下拉电阻的作用 1.3 PTC热敏电阻作为电源电路保险丝的工作原理 1.4 如果阻抗不匹配&#xff0c;有哪些后果 1.5 电阻、电容和电感0402、0603和0805封装的含义 1.6 电阻、电容和电感的封装大小与什么参数有关 1.7 …
阅读更多...
小程序入门：小程序 API 的三大分类

小程序入门：小程序 API 的三大分类

在小程序开发中&#xff0c;API&#xff08;Application Programming Interface&#xff09;起着至关重要的作用&#xff0c;它为开发者提供了丰富的功能和能力&#xff0c;使我们能够创建出功能强大、用户体验良好的小程序。小程序 API 大致可分为以下三大分类&#xff1a;事件…
阅读更多...
算法第55天｜冗余连接、冗余连接II

算法第55天｜冗余连接、冗余连接II

冗余连接 题目 思路与解法 #include <iostream> #include <vector> using namespace std; int n; // 节点数量 vector<int> father(1001, 0); // 按照节点大小范围定义数组// 并查集初始化 void init() {for (int i 0; i < n; i) {father[i] i;} } //…
阅读更多...
Docker单独部署grafana

Docker单独部署grafana

Docker单独部署grafana 环境说明 操作前提&#xff1a; 先去搭建PC端的MySQL和虚拟机 自行找参考 Linux部署docker参考文章&#xff1a; 02-Docker安装_docker安装包下载-CSDN博客 本文参考文章&#xff1a; 运维小记 说明&#xff1a; 本文的操作均以搭建好的PC端的MySQL和虚…
阅读更多...
【数据分析，相关性分析】Matlab代码#数学建模#创新算法

【数据分析，相关性分析】Matlab代码#数学建模#创新算法

【数据分析&#xff0c;相关性分析】118-matlab代码 #数学建模#创新算法 相关性分析及绘图 基于最大互信息系数的特征筛选 最大互信息系数 皮尔逊相关系数 spearman相关系数 kendall秩相关系数 请自带预算时间与需求以便高效沟通&#xff0c;回复超快&#xff0c;可以加急…
阅读更多...
浅谈C++ 中泛型编程（模版编程）

浅谈C++ 中泛型编程（模版编程）

C 是一种强大且灵活的编程语言&#xff0c;支持多种编程范式&#xff0c;使得开发者能够选择最适合特定问题的解决方案。在实际开发中&#xff0c;面向对象编程、泛型编程、函数式编程和元编程是最常用的几种范式。 今天主要与大家一起来介绍和学习泛型编程&#xff08;即模版…
阅读更多...
iOS开发中的KVO以及原理

iOS开发中的KVO以及原理

KVO概述 KVO(Key-Value-Observing)是iOS开发中一种观察者模式实现&#xff0c;允许对象监听另一个对象属性的变化。当被观察属性的值发生变化时&#xff0c;观察者会收到通知。KVO基于NSKeyValueObserving协议实现&#xff0c;是Foundation框架的核心功能之一。 1.KVO的基本使…
阅读更多...
最新文章

Copyright @ 2022~2023