Geekly Articles each Day
📜 ⬆️ ⬇️

Intel Edison. Using Intel Cloud on the example of distance sensor implementation



Nowadays, rather high demands are made on modern devices and gadgets. And I’m not only talking about surfing the Internet to read my favorite newsletter, check email or chat with friends in the social network. People want much more, in the modern world it is just necessary to control and monitor devices remotely. It is natural to manage these devices through the Internet. At the moment there is a huge amount of cloud solutions, in this article we will consider a cloud solution from Intel on a practical example.

First, let's look at the new cloud for Internet-of-Things.

Analytical Cloud IoT Analytics includes resources for collecting and analyzing data collected from various sensors connected to Intel Galileo and Intel Edison. Using this service, the developer can easily store and process data without investing additional resources in it, instead focusing on creating projects for the above mentioned fees.
Consider the concept of using IoT Analytics cloud.
')


To start using the IoT Analytics cloud, you need to create an admin account with which you can register devices, manage alerts, create accounts and perform other tasks on the site. Go to the use of IoT Analytics Dashboard can link . Basic concepts and elementary examples of using this cloud are described here .

In order to demonstrate the interaction with the cloud, let's continue the work on the example from the article “Using the integrated microcontroller in Intel Edison” , in which the HC-SR04 distance measurement sensor is connected to the Intel Edison board and the measured distance is displayed on the LCD display. Take the described example of measuring the distance and add the automatic download of the data received from the sensor, straight to the cloud.



First register our distance sensor. To do this, fill in all the required fields.



We will use the integer type, set the value range from -1 (error) to 100 centimeters.
Next, you need to register a sensor for Intel Edison. Use the following command:
# iotkit-admin register dist distance.v1.0 # iotkit-admin catalog

Now our sensor is registered and assigned to this device.



Sending data to cloud can be done in several ways.
One of the most simple:

 # iotkit-admin observation dist 10


But, as you understand, this is not the most convenient way to send data to the cloud. As a rule, this command is used for testing.
There are two other ways to transfer data to the cloud:

To start the agent on the board, use the following command:
 # systemctl start iotkit-agent

It is possible to send UDP messages through localhost to port 41234 (UDP: // localhost: 41234). To do this, you need to create a JSON file (JavaScript Object Notation):
 {"n": "<sensor name>", "v": "<value>" }

where “n” is the name of the measurement being taken, and “v” is the value.
For example:
 { "n": "dist", "v": 17 } { "n": "dist", "v": 24}

I have described how to send data to the IoT Analytics cloud via iotkitagent. Developers can also send data using programming languages ​​such as C / C ++, JavaScript, or Python. In one of the articles mentioned at the beginning, an example of publishing data using C / C ++ is implemented. Since I prefer the concept of faster and more convenient programming, in this article I will write a small example using my favorite Python language.

Script IoTCloudManager.py:
 import sys import requests import json import uuid import time import random import pyupm_i2clcd host = "dashboard.us.enableiot.com" proxies = { #   } username = "email@gmail.com" password = "*********" account_name = "account_name" #  id ,      device_id = "***************************************" observations_per_hour = 1 days_of_data = 1 verify = True api_root = "/v1/api" base_url = "https://{0}{1}".format(host, api_root) device_name = "Device-{0}".format(device_id) g_user_token = "" g_device_token = "" def main(): global g_user_token, g_device_token #     API  g_user_token = get_token(username, password) #  user_id  Intel IoT Analytics Platform uid = get_user_id() print "UserId: {0}".format(uid) aid = get_account_id(uid, account_name) print "AccountId: {0}".format(aid) #      create_device(aid, device_id, device_name) #    ac = generate_activation_code(aid) print "Activation code: {0}".format(ac) #   g_device_token = activate(aid, device_id, ac) #     "Distance.v1.0".    component_id (cid) cid = create_component(aid, device_id, "Distance.v1.0", "Dist") print "ComponentID (cid): {0}".format(cid) lcd = pyupm_i2clcd.Jhd1313m1(6, 0x3E, 0x62) with open('/dev/ttymcu0', 'w+t') as f: while True: f.write('get_distance\n') # Send command to MCU f.flush() line = f.readline() # Read response from MCU, -1 = ERROR value = int(line.strip('\n\r\t ')) #     create_observations(aid, device_id, cid, value) #    o = get_observations(aid, device_id, cid) print_observation_counts(o) lcd.clear() if value == -1: lcd.setColor(255, 0, 0) # RED lcd.write('ERROR') else: lcd.setColor(0, 255, 0) # GREEN lcd.write('%d cm' % (value,)) time.sleep(1) def get_user_headers(): headers = { 'Authorization': 'Bearer ' + g_user_token, 'content-type': 'application/json' } return headers def get_device_headers(): headers = { 'Authorization': 'Bearer ' + g_device_token, 'content-type': 'application/json' } #print "Headers = " + str(headers) ( ) return headers def check(resp, code): if resp.status_code != code: print "Expected {0}. Got {1} {2}".format(code, resp.status_code, resp.text) sys.exit(1) def get_token(username, password): url = "{0}/auth/token".format(base_url) headers = {'content-type': 'application/json'} payload = {"username": username, "password": password} data = json.dumps(payload) resp = requests.post(url, data=data, headers=headers, proxies=proxies, verify=verify) check(resp, 200) js = resp.json() token = js['token'] return token def get_user_id(): url = "{0}/auth/tokenInfo".format(base_url) resp = requests.get(url, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 200) js = resp.json() user_id = js["payload"]["sub"] return user_id def get_account_id(user_id, account_name): url = "{0}/users/{1}".format(base_url, user_id) resp = requests.get(url, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 200) js = resp.json() if 'accounts' in js: accounts = js["accounts"] for k, v in accounts.iteritems(): if 'name' in v and v["name"] == account_name: return k print "Account name {0} not found.".format(account_name) print "Available accounts are: {0}".format([v["name"] for k, v in accounts.iteritems()]) return None def create_device(account, device_id, device_name): url = "{0}/accounts/{1}/devices".format(base_url, account) device = { "deviceId": str(device_id), "gatewayId": str(device_id), "name": device_name, "tags": ["Russia", "Moscow", "RoadShow"], "attributes": { "vendor": "intel", "platform": "x86", "os": "linux" } } data = json.dumps(device) resp = requests.post(url, data=data, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 201) return resp def generate_activation_code(account_id): url = "{0}/accounts/{1}/activationcode/refresh".format(base_url, account_id) resp = requests.put(url, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 200) js = resp.json() activation_code = js["activationCode"] return activation_code def activate(account_id, device_id, activation_code): url = "{0}/accounts/{1}/devices/{2}/activation".format(base_url, account_id, device_id) activation = { "activationCode": activation_code } data = json.dumps(activation) resp = requests.put(url, data=data, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 200) js = resp.json() if "deviceToken" in js: token = js["deviceToken"] return token else: print js sys.exit(1) def create_component(account_id, device_id, component_type_name, name): url = "{0}/accounts/{1}/devices/{2}/components".format(base_url, account_id, device_id) component = { "type": component_type_name, "name": name, "cid": str(uuid.uuid4()) } data = json.dumps(component) resp = requests.post(url, data=data, headers=get_device_headers(), proxies=proxies, verify=verify) check(resp, 201) js = resp.json() return js["cid"] def create_observations(account_id, device_id, cid, val): url = "{0}/data/{1}".format(base_url, device_id) body = { "accountId": account_id, "data": [] } o = { "componentId": cid, "value": str(val), "attributes": { "i": i } } body["data"].append(o) data = json.dumps(body) resp = requests.post(url, data=data, headers=get_device_headers(), proxies=proxies, verify=verify) check(resp, 201) def get_observations(account_id, device_id, component_id): url = "{0}/accounts/{1}/data/search".format(base_url, account_id) search = { "from": 0, "targetFilter": { "deviceList": [device_id] }, "metrics": [ { "id": component_id } ] } data = json.dumps(search) resp = requests.post(url, data=data, headers=get_user_headers(), proxies=proxies, verify=verify) check(resp, 200) js = resp.json() return js def print_observation_counts(js): if 'series' in js: series = js["series"] series = sorted(series, key=lambda v: v["deviceName"]) for v in series: print "Device: {0} Count: {1}".format(v["deviceName"], len(v["points"])) if __name__ == "__main__": main()



Now let's see what happened on the graph for a certain number of measurements. The graph shows the data (in centimeters) measurements from the sensor at different points in time.

Thus, it is easy enough to upload data to the cloud.
Now let's try to determine the maximum and minimum distance of the distance (cm) that we sent to the cloud. We get the following picture.

As a conclusion, I would like to note that IoT Analytics cloud is a simple and convenient tool for storing and analyzing data received from sensors connected to the boards.

Source: https://habr.com/ru/post/262821/

More articles:


All Articles