-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
1 changed file
with
81 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 1,81 @@ | ||
| // Copyright (C) 2022 Toitware ApS. | ||
| // Use of this source code is governed by a Zero-Clause BSD license that can | ||
| // be found in the EXAMPLES_LICENSE file. | ||
| /** | ||
| Demonstrates the use of AWS IoT Core. | ||
| */ | ||
|
|
||
| import certificate_roots | ||
| import mqtt | ||
| import mqtt.transport as mqtt | ||
| import net | ||
| import net.x509 | ||
| import tls | ||
|
|
||
| // The Endpoint. Can be found in the 'Settings' section of the AWS IoT | ||
| // Core console. Also available with | ||
| // `aws iot describe-endpoint --endpoint-type iot:Jobs` | ||
| // Of the form <account-specific-prefix>.jobs.iot.<aws-region>.amazonaws.com. | ||
| HOST ::= "<- insert endpoint URL here ->" | ||
| PORT ::= 8883 | ||
|
|
||
| CLIENT_CERTIFICATE ::= """ | ||
| -----BEGIN CERTIFICATE----- | ||
| <- insert cert here -> | ||
| -----END CERTIFICATE----- | ||
| """ | ||
|
|
||
| CLIENT_KEY ::= """ | ||
| -----BEGIN RSA PRIVATE KEY----- | ||
| <- insert cert here -> | ||
| -----END RSA PRIVATE KEY----- | ||
| """ | ||
|
|
||
| // The client ID. | ||
| // Note that the active policy might require the ID to be of a | ||
| // specific form. | ||
| // See the 'iot:Connect" Policy action. If it ends with ':client/foo/*' then | ||
| // clients must be prefixed with "foo/". | ||
| CLIENT_ID ::= "<- insert client ID here ->" | ||
|
|
||
| // The topic to publish to. | ||
| // See the Policy action 'iot:Publish' to see which topics are allowed. | ||
| // If it ends with ':topic/foo/*' then only topics that are prefixed with | ||
| // "foo/" are allowed. | ||
| MY_TOPIC ::= "<- insert topic here ->" | ||
|
|
||
| create_transport network/net.Interface -> mqtt.Transport: | ||
| client_certificate := tls.Certificate (x509.Certificate.parse CLIENT_CERTIFICATE) CLIENT_KEY | ||
| return mqtt.TcpTransport.tls network --host=HOST --port=PORT | ||
| --server_name=HOST | ||
| --root_certificates=[certificate_roots.AMAZON_ROOT_CA_1] | ||
| --certificate=client_certificate | ||
|
|
||
| main: | ||
| network := net.open | ||
| transport := create_transport network | ||
|
|
||
| client := mqtt.Client --transport=transport | ||
|
|
||
| options := mqtt.SessionOptions | ||
| --client_id=CLIENT_ID | ||
| --clean_session=true | ||
|
|
||
| client.start --options=options | ||
|
|
||
| topic := MY_TOPIC | ||
|
|
||
| // Simulate a temperature sensor. | ||
| temperature := 25.0 | ||
| 10.repeat: | ||
| temperature = ((random 100) - 50) / 100.0 | ||
| print "publishing" | ||
| client.publish topic "$temperature".to_byte_array | ||
| sleep --ms=2_500 | ||
|
|
||
| client.close |