问卷调查[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 Executable4.如果功能大多是在不使用注释代替代码的情况下实现的，但实现尚未完善（例如，缺乏重新连接、缺乏初始化、缺乏关闭等），则得分为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, ¶ms) != 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;
}