This shows you the differences between two versions of the page.
Both sides previous revision Previous revision | Last revision Both sides next revision | ||
app-notes:ein-mqtt-server-fuer-iot-telemetry-sensoren [2023/11/09 15:08] gray [4. The visualization of the telemetry data with the help of Grafana] |
app-notes:ein-mqtt-server-fuer-iot-telemetry-sensoren [2024/03/21 14:00] gray [2.1 Collect telemetry data with the help of SDK scripts] |
||
---|---|---|---|
Line 67: | Line 67: | ||
/* publish the message to mqtt broker Temperature */ | /* publish the message to mqtt broker Temperature */ | ||
ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE); | ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE); | ||
+ | nb_mqttlib_get_callback_publish(MQTT_HANDLE_DD, 5000); | ||
if (ret<0){ | if (ret<0){ | ||
nb_syslog("Failed to publish mqtt message"); | nb_syslog("Failed to publish mqtt message"); | ||
Line 75: | Line 76: | ||
/* publish the message to mqtt broker Humidity */ | /* publish the message to mqtt broker Humidity */ | ||
ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE2); | ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE2); | ||
+ | nb_mqttlib_get_callback_publish(MQTT_HANDLE_DD, 5000); | ||
if (ret<0){ | if (ret<0){ | ||
nb_syslog("Failed to publish mqtt message"); | nb_syslog("Failed to publish mqtt message"); | ||
Line 83: | Line 85: | ||
/* publish the message to mqtt broker DevicePower */ | /* publish the message to mqtt broker DevicePower */ | ||
ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE3); | ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE3); | ||
+ | nb_mqttlib_get_callback_publish(MQTT_HANDLE_DD, 5000); | ||
if (ret<0){ | if (ret<0){ | ||
nb_syslog("Failed to publish mqtt message"); | nb_syslog("Failed to publish mqtt message"); | ||
Line 91: | Line 94: | ||
/* publish the message to mqtt broker Sys */ | /* publish the message to mqtt broker Sys */ | ||
ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE4); | ret = nb_mqtt_publish(HOST, PORT, USERNAME, PASSWORD, TOPIC, QOS, RETAIN, MESSAGE4); | ||
+ | nb_mqttlib_get_callback_publish(MQTT_HANDLE_DD, 5000); | ||
if (ret<0){ | if (ret<0){ | ||
nb_syslog("Failed to publish mqtt message"); | nb_syslog("Failed to publish mqtt message"); |