This article applies to all the customers looking for AWS Integration with TeamViewer IoT Solution.
General
This article helps to establish communication between AWS Greengrass and IoT TV Cloud by publishing and subscribing data from teamviewer-iot-agent to aws greengrass platform and vice-versa.
Requirements
Installing AWS Greengrass
Configure AWS IoT Greengrass on AWS IoT
- Sign in to the AWS Management Console on your computer and open the AWS IoT console. If this is your first time opening this console, select Get started. In the navigation pane, select Greengrass image
- On the Welcome to AWS IoT Greengrass page, select Create a Group. An AWS IoT Greengrass group contains settings and other information about its components, such as devices, Lambda functions, and connectors. A group defines how its components can interact with each other.
- Greengrass needs your permission to access other services dialog box, select Grant permission to allow the console to create or configure the Greengrass service role for you.
- On the Set up your Greengrass group page, select Use default creation to create a group.
- Enter a name for your group (for example,
MyFirstGroup), and then select Next.
- Use the default name, and then select Next.
- On the Review Group creation page, select Create Group and Core.
- Download your core's security resources and configuration file. On the confirmation page, under Download and store your Core's security resources, choose Download these resources as a tar.gz. The name of your downloaded
tar.gz file starts with a 10-digit hash that's also used for the certificate and key file names.
- After you download the security resources, select Finish.
- Download the AWS IoT Greengrass Core software installation package. select the CPU architecture and distribution (and operating system, if necessary) that best describe your core device. For example:
For Raspberry Pi Model B or B+, download the Armv7l for Raspbian package.
- For an Amazon EC2 instance, download the x86_64 for Linux package.
Start AWS IoT Greengrass on the Edge Device
In a previous step, you downloaded two files to your computer:
greengrass-<CODE class="replaceable">OS-architecture-1.10.0.tar.gz. This compressed file contains the AWS IoT Greengrass Core software that runs on the edge device.<CODE class="replaceable">hash-setup.tar.gz (for example, c6973960cc-setup.tar.gz). This compressed file contains security certificates that enable secure communications between AWS IoT and the config.json file that contains configuration information specific to your AWS IoT Greengrass core and the AWS IoT endpoint.- Transfer the two compressed files from your local computer to the edge device. To transfer the compressed files from your computer to edge device, using file transfer feature .
- Open a terminal on th edge edevice and navigate to the folder that contains the compressed files (for example,
cd /home/pi). - Decompress the AWS IoT Greengrass Core software and the security resources.
sudo tar -xzvf greengrass-OS-architecture-1.10.0.tar.gz -C /
sudo tar -xzvf hash-setup.tar.gz -C /greengrass
- Review Server Authentication in the AWS IoT Developer Guide and choose the appropriate root CA certificate. We recommend that you use Amazon Trust Services (ATS) endpoints and ATS root CA certificates. Certificates enable your device to communicate with AWS IoT using the MQTT messaging protocol over TLS.
- For ATS endpoints (preferred), download the appropriate ATS root CA certificate. The following example downloads
AmazonRootCA1.pem. The wget -O parameter is the capital letter O.
cd /greengrass/certs/ sudo wget -O root.ca.pem https://www.amazontrust.com/repository/AmazonRootCA1.pem
- You can run the following command to confirm that the
root.ca.pem file is not empty:- cat root.ca.pem (If the
root.ca.pem file is empty, check the wget URL and try again.)
- Start AWS IoT Greengrass on your edge device.
cd /greengrass/ggc/core/
sudo ./greengrassd start
- You should see a
Greengrass successfully started message. Make a note of the PID. - You can run the following command to confirm that the AWS IoT Greengrass Core software (Greengrass daemon) is functioning. Replace
PID-number with your PID:
ps aux | grep PID-number
Lambda Functions on AWS IoT Greengrass
User should copy/paste the code to his lambda function, get the metrics values and use greengrass sdk to push the data to the AWS.
Don't forget to replace the paths, client id and sensor id with your own in the lambda functions described below.
- aws_iot_tv_pub: This lambda function subscribes data from mqtt-broker from edge device and publishes is to amazon cloud to the topic ‘tv/greengrass’.
Below is the sample code attached for aws_iot_tv_pub:
#!/usr/bin/python
import paho.mqtt.subscribe as subscribe
import paho.mqtt.publish as publish
import traceback
import json
def function_handler(event, context):
return
# AWS part
# Change following parameters
aws_host = "a10kx625z9icrs-ats.iot.eu-central-1.amazonaws.com" # Endpoint
aws_port = 8883
aws_tls = {'certfile': "/home/pi/Downloads/certs/1b9a6e0dcb.cert.pem",
'keyfile': "/home/pi/Downloads/certs/1b9a6e0dcb.private.key",
'ca_certs': "/home/pi/Downloads/certs/root.ca.pem"
}
# TV part
#Change following parameters
tv_iot_api_version = "v1.0"
tv_host = "localhost"
tv_port = 18884
tv_tls = {'certfile': "/home/pi/Downloads/test_client_greengrass/cert-7a2b7efc1ad1473d87e049517a19628b.pem",
'keyfile': "/home/pi/Downloads/test_client_greengrass/key-7a2b7efc1ad1473d87e049517a19628b.pem",
'ca_certs': "/home/pi/Downloads/test_client_greengrass/TeamViewerAuthority.crt"}
client_id = "fd9e67783b7441ffb7cd62dda121567a"
sensor_id = "111804"
def subscribe_data():
try:
mqtt_topic_subscribe_data = "/" + tv_iot_api_version + "/" + client_id + "/sensor/" + sensor_id + "/livedata"
print("Suscribing to " + mqtt_topic_subscribe_data)
subscribe.callback(on_subscribe, mqtt_topic_subscribe_data, hostname=tv_host, port=tv_port, tls=tv_tls)
except Exception as e:
traceback.print_exc()
print(str(e))
def on_subscribe(client, userdata, message):
json_message = json.loads(message.payload.decode('utf8'))
msgArr = []
for metric in json_message["metrics"]:
messageJ = {}
messageJ['metricId'] = metric["metricId"]
messageJ['metricValue'] = metric["value"]
msgArr.append(messageJ)
msgs = []
msgs.append({'topic': "tv/greengrass", 'payload': json.dumps(msgArr)})
print(msgs)
publish.multiple(msgs, hostname=aws_host, port=aws_port, tls=aws_tls)
subscribe_data()
- aws_iot_tv_sub: This lambda function subscribes the data from amazon cloud and pushes the data to teamviewer metrics and real-time data can be visualized on edge and teamviewer-cloud dashboard.
#!/usr/bin/python
import paho.mqtt.subscribe as subscribe
import paho.mqtt.publish as publish
import traceback
import json
import ssl
def function_handler(event, context):
return
# AWS part
# Change following parameters
aws_host = "a10kx625z9icrs-ats.iot.eu-central-1.amazonaws.com" # Endpoint
aws_port = 8883
aws_tls = {'certfile': "/home/pi/Downloads/certs/1b9a6e0dcb.cert.pem",
'keyfile': "/home/pi/Downloads/certs/1b9a6e0dcb.private.key",
'ca_certs': "/home/pi/Downloads/certs/root.ca.pem",
'tls_version': ssl.PROTOCOL_TLSv1_2
}
# TV part
#Change following parameters
tv_iot_api_version = "v1.0"
tv_host = "localhost"
tv_port = 18884
tv_tls = {'certfile': "/home/pi/Downloads/test_client_greengrass/cert-7a2b7efc1ad1473d87e049517a19628b.pem",
'keyfile': "/home/pi/Downloads/test_client_greengrass/key-7a2b7efc1ad1473d87e049517a19628b.pem",
'ca_certs': "/home/pi/Downloads/test_client_greengrass/TeamViewerAuthority.crt"}
client_id = "7a2b7efc1ad1473d87e049517a19628b"
sensor_id = "71b91c40fb2d4f61bec2fa593172085d"
def aws_subscribe():
print("Suscribing to tv/greengrassSub")
subscribe.callback(on_subscribe, "tv/greengrassSub", hostname=aws_host, port=aws_port, tls=aws_tls)
def on_subscribe(client, userdata, message):
try:
metric_data = json.loads(message.payload.decode('utf8'))
mqtt_topic_push_data = "/" + tv_iot_api_version + "/" + client_id + "/sensor/" + sensor_id + "/metric/pushValues"
# metric_data = {"metrics": [{"value": 1, "metricId": "7ad8ad3e2dbe4cdcba0ee3ec0cbd2717"}]}
msgs = []
msgs.append({'topic': mqtt_topic_push_data, 'payload': json.dumps(metric_data)})
print(msgs)
publish.multiple(msgs, hostname=tv_host, port=tv_port, tls=tv_tls)
except Exception as e:
traceback.print_exc()
print(str(e))
aws_subscribe()
Further reading/Realated articles
- For Troubleshooting purposes click here and here
