Klika Tech » Code » Nucleo-AWS-IoT-mbed

Klika Tech / Mbed 2 deprecated Nucleo-AWS-IoT-mbed

Example of AWS IoT connection and Web Dashboard thru STM32 Nucleo evaluation board and mbed OS.

Dependencies: X_NUCLEO_IKS01A1 mbed FP MQTTPacket DnsQuery ATParser

Introduction

The demo is aimed to STM32 Nucleo board with WiFi and sensors expansions. The board is a "thing" for the AWS IoT service. It updates IoT service shadow with sensors data every second and checks subscription messages.

Hardware Configuration

NUCLEO-F401RE - Nucleo Development Board
X-NUCLEO-IDW01M1 - Wi-Fi expansion board for STM32 Nucleo
X-NUCLEO-IKS01A1 - Motion MEMS and environmental sensor expansion board for STM32 Nucleo

Software Configuration

Import this Project to mbed online compiler
Find the next part of code in main.cpp file ...

WiFi network credential

#include "mbed.h"
// WiFi network credential
#define SSID   ""  // Network must be visible otherwise it can't connect
#define PASSW  ""
#error "Wifi SSID & password empty"

... And set it to your Network Name and Password. Do not forget to remove "#error" pragma line.

Information

Nucleo WiFi module is not the same as your smartphone or laptope - it is based on demo board. To avoid connection problems:

Place Nucleo as close to WiFi hot spot as possible. Or...
Turn on mobile hot spot in your laptop as close to the device as possible.
Make sure that hot spot permits 2.4 GHz band communications

Setup BackEnd and store certificates using this backend setup instruction
Find AWS_IOT_MQTT_HOST define and change it to HTTPS point mentioned in your AWS IoT thing properties named "interact"

#define AWS_IOT_MQTT_HOST              "xxxxxxxxxx.iot.us-east-1.amazonaws.com" //Use your own host.

Find the certificate defines clientCRT and clientKey in main.cpp file and change it to ones provided by Amazon.

/**********************************************************************************************
***********************************************************************************************
				Device Identity Certificates: Modify for your AWS IoT Thing
***********************************************************************************************
***********************************************************************************************/

/****************************************
(somecode)-certificate.pem.crt - Amazon signed PEM sertificate.
*****************************************/

//This Client cert is example. Use own instead.
const uint8_t clientCRT[] = "\
-----BEGIN CERTIFICATE-----\n\
MIIDBjCCAe6gAwIBAgIUVph856omeIxW3UPioq+UrX1DbwowDQYJKoZIhvcNAQEL\
BQAwTTFLMEkGA1UECwxCQW1hem9uIFdlYiBTZXJ2aWNlcyBPPUFtYXpvbi5jb20g\
SW5jLiBMPVNlYXR0bGUgU1Q9V2FzaGluZ3RvbiBDPVVTMB4XDTE3MDUyNTExNTEy\
OVoXDTQ5MTIzMTIzNTk1OVowgZUxCzAJBgNVBAYTAkJZMQ4wDAYDVQQIDAVNaW5z\
azEOMAwGA1UEBwwFTWluc2sxFzAVBgNVBAoMDktsaWthLVRlY2ggTExDMRcwFQYD\
VQQLDA5LbGlrYS1UZWNoIExMQzEMMAoGA1UEAwwDUm5EMSYwJAYJKoZIhvcNAQkB\
FhdtdmF0YWxldUBrbGlrYS10ZWNoLmNvbTBZMBMGByqGSM49AgEGCCqGSM49AwEH\
A0IABCJgOQJmoTBJVPfli9Hm/JVixaxkY5rtlgrYO3hSl633A2hg0P/ue0wXDbF3\
aQ0X57IRFE4k4FEbr3UXjT/IczKjYDBeMB8GA1UdIwQYMBaAFK3YzTUPlYB2Li75\
i/z8rEogr1d6MB0GA1UdDgQWBBT18HXBaXFJuAR/0SwegnxJ+pyJ6TAMBgNVHRMB\
Af8EAjAAMA4GA1UdDwEB/wQEAwIHgDANBgkqhkiG9w0BAQsFAAOCAQEAb0Ux1aH5\
RLxjrfGqXN6rPVqh8QQRS+AyBfzmaQN8HaPZMkX5WxXLvcn0A3uWlwQxPPkcZ4zf\
51GHtFFQWB4YZ8dx8mUQ0v/j7onHjCJgZ8iDgwOyKMGtnsDZWCakQw+a6cj+NrMZ\
tzhjwCzEEP6ePcbXwErI5OOzLuWns2L/JEr2wWNkokgRuS8ewr/SQ9OLWIWa2rFM\
ahPNTb3y/qBeWdjeJmhI+TOxdqIpsF8roWP25zwo/zkzCHCjXFBrL+0CA4MpxIl9\
x02i7aAhlJ6ys80lDxdeWeeQJXRKkGknP8mcmKn3iEqqJ5s1dQePj2b5d3ldatya\
wsxQBqqZXzIWEw==\
\n\
-----END CERTIFICATE-----\n";



/**********************************************************************************************
***********************************************************************************************
						Private Key: Modify for your AWS IoT Thing
***********************************************************************************************
***********************************************************************************************/

/********************************************************************8****************************************
nucleo.key.pem - client key generated according to readme.
**************************************************************************************************************/

//This Client Key is example. Use own instead.
const uint8_t clientKey[] ="\
-----BEGIN EC PARAMETERS-----\n\
BggqhkjOPQMBBw==\
-----END EC PARAMETERS-----\n\
-----BEGIN EC PRIVATE KEY-----\n\
MHcCAQEEIHPRfWSC8/k/BsqDWKuP15dXsI9fGwpkTIsLZe6mIrAAoAoGCCqGSM49\
AwEHoUQDQgAEImA5AmahMElU9+WL0eb8lWLFrGRjmu2WCtg7eFKXrfcDaGDQ/+57\
TBcNsXdpDRfnshEUTiTgURuvdReNP8hzMg==\
-----END EC PRIVATE KEY-----\n";

Build and Check

Plugin your board to USB of your PC. USB Disk Drive and USB COM Port should appear in your system.
Open any Serial Console, connect it to your USB Serial Port and setup speed equal to 115200.
Compile this Project and save .bin file to USB Disk Drive
After board reset you should see next log in serial console:

X-NUCLEO-IDW01M1 mbed Application

connecting to AP
LOG:   int main() L#361 Connected to WiFI.
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#186 =====================================
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#187 Connecting WiFi.
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#188 Nucleo IP ADDRESS: X.X.X.X
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#189 Nucleo MAC ADDRESS: 00:11:22:33:44:55
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#190 Server Hostname: xxxxxxxx.iot.us-east-1.amazonaws.com port: 8883
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#191 Client ID: Nucleo
LOG:   int connect(MQTT::Client<MQTTWiFi, Countdown, 350, 5> *, MQTTWiFi *) L#194 =====================================
LOG:   int MQTTSocket::getNTPtime(int) L#58 Success receiving time from ntp server. Tick from 1 Jan 1970 is equal to 1505399292.
--->TCP Connected
--->MQTT Connected
--->>>MQTT subscribed to: Nucleo/test
Length - 245, Publishing {"state": {"reported": {"temperature": 23.690001, "humidity": 98.190002, "pressure": 982.869141, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.420000, -2.660000, 1.750000], "magnetometer": [-3.600000, -7.100000, 53.300000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.660000, "humidity": 98.010002, "pressure": 982.770264, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.770000, -2.310000, 1.470000], "magnetometer": [-3.100000, -8.300000, 54.200000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.670000, "humidity": 98.129997, "pressure": 982.724121, "accelerometer": [-0.008000, 0.029000, 0.971000], "gyroscope": [0.630000, -2.380000, 1.400000], "magnetometer": [-3.100000, -7.900000, 53.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.690001, "humidity": 98.019997, "pressure": 982.840088, "accelerometer": [-0.009000, 0.030000, 0.972000], "gyroscope": [0.700000, -2.450000, 1.540000], "magnetometer": [-3.700000, -7.900000, 53.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.709999, "humidity": 98.040001, "pressure": 982.828613, "accelerometer": [-0.009000, 0.030000, 0.971000], "gyroscope": [0.630000, -2.520000, 1.470000], "magnetometer": [-2.900000, -7.400000, 52.400000]}}}
Length - 245, Publishing {"state": {"reported": {"temperature": 23.719999, "humidity": 97.860001, "pressure": 982.917236, "accelerometer": [-0.026000, 0.103000, 0.891000], "gyroscope": [1.050000, -2.310000, 1.260000], "magnetometer": [-3.300000, -7.100000, 53.500000]}}}

Information

Device connection state might be checked by Green Led on the board. Green light means that device is connected and transferring data to cloud.

Configure and start your dashboard using instruction and corresponding sources from github
Use Blue button to set up markers to charts.
Use AWS IoT console MQTT Client to test device subscription to "Nucleo/test". Just publish any message to this topic and serial port output.
PROFIT!

NetworkSocketAPI/UDPSocket.h@1:042ca9148926, 2017-10-19 (annotated)

Committer:: PavelSavyhin
Date:: Thu Oct 19 11:36:41 2017 +0000
Revision:: 1:042ca9148926
Parent:: 0:4cdaf9b1e7d0

Connection times are optimized and logging is extended.

Who changed what in which revision?

User	Revision	Line number	New contents of line
PavelSavyhin	0:4cdaf9b1e7d0	1	/* UDPSocket
PavelSavyhin	0:4cdaf9b1e7d0	2	* Copyright (c) 2015 ARM Limited
PavelSavyhin	0:4cdaf9b1e7d0	3	*
PavelSavyhin	0:4cdaf9b1e7d0	4	* Licensed under the Apache License, Version 2.0 (the "License");
PavelSavyhin	0:4cdaf9b1e7d0	5	* you may not use this file except in compliance with the License.
PavelSavyhin	0:4cdaf9b1e7d0	6	* You may obtain a copy of the License at
PavelSavyhin	0:4cdaf9b1e7d0	7	*
PavelSavyhin	0:4cdaf9b1e7d0	8	* http://www.apache.org/licenses/LICENSE-2.0
PavelSavyhin	0:4cdaf9b1e7d0	9	*
PavelSavyhin	0:4cdaf9b1e7d0	10	* Unless required by applicable law or agreed to in writing, software
PavelSavyhin	0:4cdaf9b1e7d0	11	* distributed under the License is distributed on an "AS IS" BASIS,
PavelSavyhin	0:4cdaf9b1e7d0	12	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
PavelSavyhin	0:4cdaf9b1e7d0	13	* See the License for the specific language governing permissions and
PavelSavyhin	0:4cdaf9b1e7d0	14	* limitations under the License.
PavelSavyhin	0:4cdaf9b1e7d0	15	*/
PavelSavyhin	0:4cdaf9b1e7d0	16
PavelSavyhin	0:4cdaf9b1e7d0	17	#ifndef UDPSOCKET_H
PavelSavyhin	0:4cdaf9b1e7d0	18	#define UDPSOCKET_H
PavelSavyhin	0:4cdaf9b1e7d0	19
PavelSavyhin	0:4cdaf9b1e7d0	20	#include "Socket.h"
PavelSavyhin	0:4cdaf9b1e7d0	21	#include "NetworkStack.h"
PavelSavyhin	0:4cdaf9b1e7d0	22
PavelSavyhin	0:4cdaf9b1e7d0	23	/** UDP socket
PavelSavyhin	0:4cdaf9b1e7d0	24	*/
PavelSavyhin	0:4cdaf9b1e7d0	25	class UDPSocket : public Socket {
PavelSavyhin	0:4cdaf9b1e7d0	26	public:
PavelSavyhin	0:4cdaf9b1e7d0	27	/** Create an uninitialized socket
PavelSavyhin	0:4cdaf9b1e7d0	28	*
PavelSavyhin	0:4cdaf9b1e7d0	29	* Must call open to initialize the socket on a network stack.
PavelSavyhin	0:4cdaf9b1e7d0	30	*/
PavelSavyhin	0:4cdaf9b1e7d0	31	UDPSocket();
PavelSavyhin	0:4cdaf9b1e7d0	32
PavelSavyhin	0:4cdaf9b1e7d0	33	/** Create a socket on a network stack
PavelSavyhin	0:4cdaf9b1e7d0	34	*
PavelSavyhin	0:4cdaf9b1e7d0	35	* Creates and opens a socket on the specified network stack.
PavelSavyhin	0:4cdaf9b1e7d0	36	*
PavelSavyhin	0:4cdaf9b1e7d0	37	* @param iface Network stack as target for socket
PavelSavyhin	0:4cdaf9b1e7d0	38	*/
PavelSavyhin	0:4cdaf9b1e7d0	39	UDPSocket(NetworkStack *iface);
PavelSavyhin	0:4cdaf9b1e7d0	40
PavelSavyhin	0:4cdaf9b1e7d0	41	/** Opens a socket
PavelSavyhin	0:4cdaf9b1e7d0	42	*
PavelSavyhin	0:4cdaf9b1e7d0	43	* Creates a network socket on the specified network stack.
PavelSavyhin	0:4cdaf9b1e7d0	44	* Not needed if stack is passed to the socket's constructor.
PavelSavyhin	0:4cdaf9b1e7d0	45	*
PavelSavyhin	0:4cdaf9b1e7d0	46	* @param iface Network stack as target for socket
PavelSavyhin	0:4cdaf9b1e7d0	47	* @return 0 on success, negative error code on failure
PavelSavyhin	0:4cdaf9b1e7d0	48	*/
PavelSavyhin	0:4cdaf9b1e7d0	49	virtual int open(NetworkStack *iface);
PavelSavyhin	0:4cdaf9b1e7d0	50
PavelSavyhin	0:4cdaf9b1e7d0	51	/** Send a packet over a UDP socket
PavelSavyhin	0:4cdaf9b1e7d0	52	*
PavelSavyhin	0:4cdaf9b1e7d0	53	* Sends data to the specified address specified by either a domain name
PavelSavyhin	0:4cdaf9b1e7d0	54	* or an IP address and port. Returns the number of bytes sent from the
PavelSavyhin	0:4cdaf9b1e7d0	55	* buffer.
PavelSavyhin	0:4cdaf9b1e7d0	56	*
PavelSavyhin	0:4cdaf9b1e7d0	57	* By default, sendto blocks until data is sent. If socket is set to
PavelSavyhin	0:4cdaf9b1e7d0	58	* non-blocking or times out, NSAPI_ERROR_WOULD_BLOCK is returned
PavelSavyhin	0:4cdaf9b1e7d0	59	* immediately.
PavelSavyhin	0:4cdaf9b1e7d0	60	*
PavelSavyhin	0:4cdaf9b1e7d0	61	* @param host Hostname of the remote host
PavelSavyhin	0:4cdaf9b1e7d0	62	* @param port Port of the remote host
PavelSavyhin	0:4cdaf9b1e7d0	63	* @param data Buffer of data to send to the host
PavelSavyhin	0:4cdaf9b1e7d0	64	* @param size Size of the buffer in bytes
PavelSavyhin	0:4cdaf9b1e7d0	65	* @return Number of sent bytes on success, negative error
PavelSavyhin	0:4cdaf9b1e7d0	66	* code on failure
PavelSavyhin	0:4cdaf9b1e7d0	67	*/
PavelSavyhin	0:4cdaf9b1e7d0	68	int sendto(const char host, uint16_t port, const void data, unsigned size);
PavelSavyhin	0:4cdaf9b1e7d0	69
PavelSavyhin	0:4cdaf9b1e7d0	70	/** Send a packet over a UDP socket
PavelSavyhin	0:4cdaf9b1e7d0	71	*
PavelSavyhin	0:4cdaf9b1e7d0	72	* Sends data to the specified address. Returns the number of bytes
PavelSavyhin	0:4cdaf9b1e7d0	73	* sent from the buffer.
PavelSavyhin	0:4cdaf9b1e7d0	74	*
PavelSavyhin	0:4cdaf9b1e7d0	75	* By default, sendto blocks until data is sent. If socket is set to
PavelSavyhin	0:4cdaf9b1e7d0	76	* non-blocking or times out, NSAPI_ERROR_WOULD_BLOCK is returned
PavelSavyhin	0:4cdaf9b1e7d0	77	* immediately.
PavelSavyhin	0:4cdaf9b1e7d0	78	*
PavelSavyhin	0:4cdaf9b1e7d0	79	* @param address The SocketAddress of the remote host
PavelSavyhin	0:4cdaf9b1e7d0	80	* @param data Buffer of data to send to the host
PavelSavyhin	0:4cdaf9b1e7d0	81	* @param size Size of the buffer in bytes
PavelSavyhin	0:4cdaf9b1e7d0	82	* @return Number of sent bytes on success, negative error
PavelSavyhin	0:4cdaf9b1e7d0	83	* code on failure
PavelSavyhin	0:4cdaf9b1e7d0	84	*/
PavelSavyhin	0:4cdaf9b1e7d0	85	int sendto(const SocketAddress &address, const void *data, unsigned size);
PavelSavyhin	0:4cdaf9b1e7d0	86
PavelSavyhin	0:4cdaf9b1e7d0	87	/** Receive a packet over a UDP socket
PavelSavyhin	0:4cdaf9b1e7d0	88	*
PavelSavyhin	0:4cdaf9b1e7d0	89	* Receives data and stores the source address in address if address
PavelSavyhin	0:4cdaf9b1e7d0	90	* is not NULL. Returns the number of bytes received into the buffer.
PavelSavyhin	0:4cdaf9b1e7d0	91	*
PavelSavyhin	0:4cdaf9b1e7d0	92	* By default, recvfrom blocks until data is sent. If socket is set to
PavelSavyhin	0:4cdaf9b1e7d0	93	* non-blocking or times out, NSAPI_ERROR_WOULD_BLOCK is returned
PavelSavyhin	0:4cdaf9b1e7d0	94	* immediately.
PavelSavyhin	0:4cdaf9b1e7d0	95	*
PavelSavyhin	0:4cdaf9b1e7d0	96	* @param address Destination for the source address or NULL
PavelSavyhin	0:4cdaf9b1e7d0	97	* @param data Destination buffer for data received from the host
PavelSavyhin	0:4cdaf9b1e7d0	98	* @param size Size of the buffer in bytes
PavelSavyhin	0:4cdaf9b1e7d0	99	* @return Number of received bytes on success, negative error
PavelSavyhin	0:4cdaf9b1e7d0	100	* code on failure
PavelSavyhin	0:4cdaf9b1e7d0	101	*/
PavelSavyhin	0:4cdaf9b1e7d0	102	int recvfrom(SocketAddress address, void data, unsigned size);
PavelSavyhin	0:4cdaf9b1e7d0	103	};
PavelSavyhin	0:4cdaf9b1e7d0	104
PavelSavyhin	0:4cdaf9b1e7d0	105	#endif

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	27 Sep 2017
Imports:	341
Forks:	0
Commits:	2
Dependents:	0
Dependencies:	6
Followers:	8

The code in this repository is Apache licensed.

Introduction

Hardware Configuration

Software Configuration

WiFi network credential

Information

Build and Check

Information

NetworkSocketAPI/UDPSocket.h@1:042ca9148926, 2017-10-19 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning