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/Socket.cpp@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	/* Socket
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	#include "Socket.h"
PavelSavyhin	0:4cdaf9b1e7d0	18
PavelSavyhin	0:4cdaf9b1e7d0	19	Socket::Socket()
PavelSavyhin	0:4cdaf9b1e7d0	20	: _iface(0)
PavelSavyhin	0:4cdaf9b1e7d0	21	, _socket(0)
PavelSavyhin	0:4cdaf9b1e7d0	22	, _timeout(-1)
PavelSavyhin	0:4cdaf9b1e7d0	23	{
PavelSavyhin	0:4cdaf9b1e7d0	24	}
PavelSavyhin	0:4cdaf9b1e7d0	25
PavelSavyhin	0:4cdaf9b1e7d0	26	Socket::~Socket()
PavelSavyhin	0:4cdaf9b1e7d0	27	{
PavelSavyhin	0:4cdaf9b1e7d0	28	if (_socket) {
PavelSavyhin	0:4cdaf9b1e7d0	29	close();
PavelSavyhin	0:4cdaf9b1e7d0	30	}
PavelSavyhin	0:4cdaf9b1e7d0	31	}
PavelSavyhin	0:4cdaf9b1e7d0	32
PavelSavyhin	0:4cdaf9b1e7d0	33	int Socket::open(NetworkStack *iface, nsapi_protocol_t proto)
PavelSavyhin	0:4cdaf9b1e7d0	34	{
PavelSavyhin	0:4cdaf9b1e7d0	35	_iface = iface;
PavelSavyhin	0:4cdaf9b1e7d0	36
PavelSavyhin	0:4cdaf9b1e7d0	37	void *socket;
PavelSavyhin	0:4cdaf9b1e7d0	38	int err = _iface->socket_open(&socket, proto);
PavelSavyhin	0:4cdaf9b1e7d0	39	if (err) {
PavelSavyhin	0:4cdaf9b1e7d0	40	return err;
PavelSavyhin	0:4cdaf9b1e7d0	41	}
PavelSavyhin	0:4cdaf9b1e7d0	42
PavelSavyhin	0:4cdaf9b1e7d0	43	_socket = socket;
PavelSavyhin	0:4cdaf9b1e7d0	44	_iface->socket_attach(_socket, &Socket::thunk, this);
PavelSavyhin	0:4cdaf9b1e7d0	45
PavelSavyhin	0:4cdaf9b1e7d0	46	return 0;
PavelSavyhin	0:4cdaf9b1e7d0	47	}
PavelSavyhin	0:4cdaf9b1e7d0	48
PavelSavyhin	0:4cdaf9b1e7d0	49	int Socket::close()
PavelSavyhin	0:4cdaf9b1e7d0	50	{
PavelSavyhin	0:4cdaf9b1e7d0	51	if (!_socket) {
PavelSavyhin	0:4cdaf9b1e7d0	52	return 0;
PavelSavyhin	0:4cdaf9b1e7d0	53	}
PavelSavyhin	0:4cdaf9b1e7d0	54
PavelSavyhin	0:4cdaf9b1e7d0	55	_iface->socket_attach(_socket, 0, 0);
PavelSavyhin	0:4cdaf9b1e7d0	56
PavelSavyhin	0:4cdaf9b1e7d0	57	void *volatile socket = _socket;
PavelSavyhin	0:4cdaf9b1e7d0	58	_socket = 0;
PavelSavyhin	0:4cdaf9b1e7d0	59	return _iface->socket_close(socket);
PavelSavyhin	0:4cdaf9b1e7d0	60	}
PavelSavyhin	0:4cdaf9b1e7d0	61
PavelSavyhin	0:4cdaf9b1e7d0	62	int Socket::bind(uint16_t port)
PavelSavyhin	0:4cdaf9b1e7d0	63	{
PavelSavyhin	0:4cdaf9b1e7d0	64	SocketAddress addr(0, port);
PavelSavyhin	0:4cdaf9b1e7d0	65	return bind(addr);
PavelSavyhin	0:4cdaf9b1e7d0	66	}
PavelSavyhin	0:4cdaf9b1e7d0	67
PavelSavyhin	0:4cdaf9b1e7d0	68	int Socket::bind(const char *address, uint16_t port)
PavelSavyhin	0:4cdaf9b1e7d0	69	{
PavelSavyhin	0:4cdaf9b1e7d0	70	SocketAddress addr(address, port);
PavelSavyhin	0:4cdaf9b1e7d0	71	return bind(addr);
PavelSavyhin	0:4cdaf9b1e7d0	72	}
PavelSavyhin	0:4cdaf9b1e7d0	73
PavelSavyhin	0:4cdaf9b1e7d0	74	int Socket::bind(const SocketAddress &address)
PavelSavyhin	0:4cdaf9b1e7d0	75	{
PavelSavyhin	0:4cdaf9b1e7d0	76	if (!_socket) {
PavelSavyhin	0:4cdaf9b1e7d0	77	return NSAPI_ERROR_NO_SOCKET;
PavelSavyhin	0:4cdaf9b1e7d0	78	}
PavelSavyhin	0:4cdaf9b1e7d0	79
PavelSavyhin	0:4cdaf9b1e7d0	80	return _iface->socket_bind(_socket, address);
PavelSavyhin	0:4cdaf9b1e7d0	81	}
PavelSavyhin	0:4cdaf9b1e7d0	82
PavelSavyhin	0:4cdaf9b1e7d0	83	void Socket::set_blocking(bool blocking)
PavelSavyhin	0:4cdaf9b1e7d0	84	{
PavelSavyhin	0:4cdaf9b1e7d0	85	set_timeout(blocking ? -1 : 0);
PavelSavyhin	0:4cdaf9b1e7d0	86	}
PavelSavyhin	0:4cdaf9b1e7d0	87
PavelSavyhin	0:4cdaf9b1e7d0	88	void Socket::set_timeout(int timeout)
PavelSavyhin	0:4cdaf9b1e7d0	89	{
PavelSavyhin	0:4cdaf9b1e7d0	90	_timeout = timeout;
PavelSavyhin	0:4cdaf9b1e7d0	91	}
PavelSavyhin	0:4cdaf9b1e7d0	92
PavelSavyhin	0:4cdaf9b1e7d0	93	int Socket::setsockopt(int level, int optname, const void *optval, unsigned optlen)
PavelSavyhin	0:4cdaf9b1e7d0	94	{
PavelSavyhin	0:4cdaf9b1e7d0	95	if (!_socket) {
PavelSavyhin	0:4cdaf9b1e7d0	96	return NSAPI_ERROR_NO_SOCKET;
PavelSavyhin	0:4cdaf9b1e7d0	97	}
PavelSavyhin	0:4cdaf9b1e7d0	98
PavelSavyhin	0:4cdaf9b1e7d0	99	return _iface->setsockopt(_socket, level, optname, optval, optlen);
PavelSavyhin	0:4cdaf9b1e7d0	100	}
PavelSavyhin	0:4cdaf9b1e7d0	101
PavelSavyhin	0:4cdaf9b1e7d0	102	int Socket::getsockopt(int level, int optname, void optval, unsigned optlen)
PavelSavyhin	0:4cdaf9b1e7d0	103	{
PavelSavyhin	0:4cdaf9b1e7d0	104	if (!_socket) {
PavelSavyhin	0:4cdaf9b1e7d0	105	return NSAPI_ERROR_NO_SOCKET;
PavelSavyhin	0:4cdaf9b1e7d0	106	}
PavelSavyhin	0:4cdaf9b1e7d0	107
PavelSavyhin	0:4cdaf9b1e7d0	108	return _iface->getsockopt(_socket, level, optname, optval, optlen);
PavelSavyhin	0:4cdaf9b1e7d0	109
PavelSavyhin	0:4cdaf9b1e7d0	110	}
PavelSavyhin	0:4cdaf9b1e7d0	111
PavelSavyhin	0:4cdaf9b1e7d0	112	void Socket::wakeup()
PavelSavyhin	0:4cdaf9b1e7d0	113	{
PavelSavyhin	0:4cdaf9b1e7d0	114	}
PavelSavyhin	0:4cdaf9b1e7d0	115
PavelSavyhin	0:4cdaf9b1e7d0	116	void Socket::thunk(void *data)
PavelSavyhin	0:4cdaf9b1e7d0	117	{
PavelSavyhin	0:4cdaf9b1e7d0	118	Socket self = (Socket )data;
PavelSavyhin	0:4cdaf9b1e7d0	119	if (self->_callback) {
PavelSavyhin	0:4cdaf9b1e7d0	120	self->_callback();
PavelSavyhin	0:4cdaf9b1e7d0	121	}
PavelSavyhin	0:4cdaf9b1e7d0	122	}
PavelSavyhin	0:4cdaf9b1e7d0	123
PavelSavyhin	0:4cdaf9b1e7d0	124	void Socket::attach(FunctionPointer callback)
PavelSavyhin	0:4cdaf9b1e7d0	125	{
PavelSavyhin	0:4cdaf9b1e7d0	126	_callback = callback;
PavelSavyhin	0:4cdaf9b1e7d0	127	}

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/Socket.cpp@1:042ca9148926, 2017-10-19 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning