GIS

import time

import ttn

import sys

import logging

logging.basicConfig(level=logging.DEBUG)

config = {

  'apps': {

    'ami_rama': "ttn-account-v2.6UEpQT1kb58BCouvltr5HLOP7CGOwZsLTWYpTo2nK3I",

    'baraka': "ttn-account-v2.eo-VseYHokva5d5h7J0b9b1fMQqWPU1dzOeBGXdqwrw"

  },

  'timeout': 10

}

def uplink_callback(msg, client):

  logging.debug("Values Received from appId: {}, devId: {}, wLevel:  {}, wPressure: {}, temp: {}".format(msg.dev_id, msg.app_id, msg.payload_fields.wLevel, msg.payload_fields.wPressure, msg.payload_fields.tempC))

handlers = {}

mqtt_clients = {}

for app_id, access_key in config['apps'].items():

  try:

    handlers[app_id] = ttn.HandlerClient(app_id, access_key)

  except Exception as err:

    logging.debug(str(err))

    logging.warning(err._state.details)

  else:

    # using mqtt client

    logging.info('Connected to {}'.format(app_id))

    mqtt_clients[app_id] = handlers[app_id].data()

    mqtt_clients[app_id].set_uplink_callback(uplink_callback)

    mqtt_clients[app_id].connect()

if len(handlers) == 0:

  sys.exit(0)

else:

  time.sleep(600)

for name, mqtt_client in mqtt_clients.items():

  logging.info('Closing connection to {}'.format(name))

  mqtt_client.close()

# using application manager client

# app_client = handler.application()

# my_app = app_client.get()

# print(my_app)

# my_devices = app_client.devices()

# print(my_devices)