MQTT and Sensor integration
Dependencies: X_NUCLEO_IKS01A2
Diff: main.cpp
- Revision:
- 1:ba4c33393a52
- Parent:
- 0:0f878e3e5401
--- a/main.cpp Thu Nov 05 19:07:22 2020 +0000 +++ b/main.cpp Thu Jan 07 14:32:21 2021 +0000 @@ -1,4 +1,5 @@ #include "mbed.h" +#include <math.h> #include <MQTTClientMbedOs.h> #include "SpwfSAInterface.h" @@ -40,7 +41,7 @@ TCPSocket socket; MQTTClient client(&socket); socket.open(&wifi); - int rc = socket.connect("mqtt.eclipse.org", 1883); + int rc = socket.connect("192.168.178.21", 1883); if (rc == 0) printf("Connection Successful"); @@ -51,8 +52,8 @@ data.MQTTVersion = 4; data.struct_version=0; - data.clientID.cstring = "clientId-Scf7TcRtbgasdseg"; - data.username.cstring = "bob"; + data.clientID.cstring = "clientId-ACC2"; + data.username.cstring = "jlenz"; data.password.cstring = "123"; rc = client.connect(data); @@ -70,16 +71,19 @@ acc_gyro->get_x_axes_raw(axes); MQTT::Message message; - char* pubTopic = "SLG/ACC"; + char* pubTopic = "SLG/ACC2"; char buf[MQTT_MAX_PAYLOAD_SIZE]; - sprintf(buf,"%d,%d,%d",axes[0],axes[1],axes[2]); + auto normAxe = axes[0]*axes[0] + axes[1]*axes[1] + axes[2]*axes[2]; + sprintf(buf,"%d",normAxe); message.qos = MQTT::QOS0; message.retained = false; message.dup = false; message.payload = (void*)buf; message.payloadlen = strlen(buf); client.publish(pubTopic, message); - printf("%d,%d,%d \n",axes[0],axes[1],axes[2]); + printf("%d \n",normAxe); + printf("%d \n",axes[0]); + }