# -*- coding: utf-8 -*-
"""Tutorial on using the InfluxDB client."""

import argparse

from influxdb import InfluxDBClient

# curl -i -XPOST 'http://localhost:8086/write?db=smog_db' --data-binary 'smog,airQualityIndex=4,sensorId=11 pm10=0.01,pm25=0.02 14340555620000'

# curl -G 'http://localhost:8086/query?pretty=true' --data-urlencode "db=smog_db" --data-urlencode "q=SELECT * FROM \"smog\""


# ssh -i pajtong.pem ec2-user@ec2-52-16-76-3.eu-west-1.compute.amazonaws.com
# scp -i pajtong.pem ec2-user@ec2-52-16-76-3.eu-west-1.compute.amazonaws.com

# http://ec2-52-16-76-3.eu-west-1.compute.amazonaws.com:3000
# admin
# admin


# curl -i -XPOST 'http://localhost:8086/write?db=smog_db' --data-binary 'smog,airQualityIndex=4,sensorId=11 pm10=0.01,pm25=0.02 14340555620000'

import requests

# http://ec2-52-16-76-3.eu-west-1.compute.amazonaws.com:8086/query?db=smog_db&q=SELECT%20*%20FROM%20pm25
def get_from_url(host='ec2-52-16-76-3.eu-west-1.compute.amazonaws.com', port=8086, query='pm25', sensorId='1'):
    """Instantiate a connection to the InfluxDB."""
    user = ''
    password = ''
    dbname = 'smog_db'
    query = 'SELECT * FROM ' + query + ' WHERE sensorId=' + '\''+str(sensorId)+ '\''
    json_body = []

    client = InfluxDBClient(host, port, user, password, dbname)

    print("Querying data: " + query)
    result = client.query(query)

    print("Result: {0}".format(result))

    # print("Switch user: " + user)
    # client.switch_user(user, password)

    # print("Drop database: " + dbname)
    # client.drop_database(dbname)

if __name__ == '__main__':
    get_from_url(query='pm10', sensorId=17)