You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
236 lines
7.2 KiB
236 lines
7.2 KiB
import tago
|
|
import requests
|
|
import json
|
|
from datetime import datetime
|
|
import time
|
|
|
|
while (True):
|
|
|
|
print("Input telemetry string (or Control-C to exit)")
|
|
|
|
# telem_string = input()
|
|
|
|
telem_json = requests.get('https://api.aprs.fi/api/get?name=W3YP-11&what=loc&apikey=APIKEY&format=json').json()
|
|
|
|
lat = float(telem_json['entries'][0]['lat'])
|
|
lon = float(telem_json['entries'][0]['lng'])
|
|
telem_string = telem_json['entries'][0]['comment']
|
|
times = int(telem_json['entries'][0]['time'])
|
|
|
|
|
|
print(lat)
|
|
print(lon)
|
|
print(telem_string)
|
|
|
|
chunks = telem_string.split(' ')
|
|
|
|
#printchunks = str.split(' ')
|
|
|
|
print(chunks)
|
|
|
|
temp = 0
|
|
pressure = 0
|
|
altitude = 0
|
|
humidity = 0
|
|
|
|
|
|
timestamp = datetime.utcfromtimestamp(times).strftime('%Y-%m-%d %H:%M:%S')
|
|
print(timestamp)
|
|
|
|
for i in range(len(chunks)):
|
|
if (chunks[i] == "BME280"):
|
|
print("Found BME280")
|
|
temp = chunks[i+1]
|
|
pressure = chunks[i+2]
|
|
altitude = chunks[i+3]
|
|
humidity = chunks[i+4]
|
|
print(temp)
|
|
print(humidity)
|
|
if (chunks[i] == "MPU6050"):
|
|
print("Found MPU6050")
|
|
x_rotate = chunks[i+1]
|
|
y_rotate = chunks[i+2]
|
|
z_rotate = chunks[i+3]
|
|
x_accel = chunks[i+4]
|
|
y_accel = chunks[i+5]
|
|
z_accel = chunks[i+6]
|
|
if (chunks[i] == "SGP30"):
|
|
print("Found SGP30")
|
|
tvoc = chunks[i+1]
|
|
e_co2 = chunks[i+2]
|
|
raw_h2 = chunks[i+3]
|
|
raw_ethanol= chunks[i+4]
|
|
|
|
#print(telem_string)
|
|
|
|
|
|
my_device = tago.Device('a824cdc6-dc87-4c54-a848-41dabb8873ad')
|
|
|
|
"""
|
|
The following code defines the set of data to be sent to TagoIO
|
|
data fields:
|
|
- variable name
|
|
- variable unit
|
|
- variable value
|
|
- Optional: desired data timestamp
|
|
- Optional: lat/long location (associated to your data)
|
|
"""
|
|
data = {
|
|
'variable': 'temperature',
|
|
'unit' : 'C',
|
|
'value' : temp,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
#print(data)
|
|
|
|
data = {
|
|
'variable': 'pressure',
|
|
'unit' : 'kPa',
|
|
'value' : pressure,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'altitude',
|
|
'unit' : 'm',
|
|
'value' : altitude,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'humidity',
|
|
'unit' : '%',
|
|
'value' : humidity,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'x_rotate',
|
|
'unit' : 'dps',
|
|
'value' : x_rotate,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'y_rotate',
|
|
'unit' : 'dps',
|
|
'value' : y_rotate,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'z_rotate',
|
|
'unit' : 'dps',
|
|
'value' : z_rotate,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'x_accel',
|
|
'unit' : 'g',
|
|
'value' : x_accel,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'y_accel',
|
|
'unit' : 'g',
|
|
'value' : y_accel,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'z_accel',
|
|
'unit' : 'g',
|
|
'value' : z_accel,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'tvoc',
|
|
'unit' : 'ppb',
|
|
'value' : tvoc,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'e_co2',
|
|
'unit' : 'ppm',
|
|
'value' : e_co2,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'raw_h2',
|
|
'unit' : 'raw',
|
|
'value' : raw_h2,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
'variable': 'raw_ethanol',
|
|
'unit' : 'raw',
|
|
'value' : raw_ethanol,
|
|
'time' : timestamp,
|
|
'location': {'lat': lat, 'lng': lon}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
data = {
|
|
"variable": "location",
|
|
"value": "Villanova University HAB-2",
|
|
"location": {
|
|
"lat": lat,
|
|
"lng": lon
|
|
}
|
|
}
|
|
result = my_device.insert(data)
|
|
print(result)
|
|
|
|
time.sleep(60)
|