forcast.py

from apixu.client import ApixuClient, ApixuException
import MySQLdb
api_key = '01def7821ddc40c3a9c150301161804'
client = ApixuClient(api_key)
db = MySQLdb.connect("localhost", "root", "", "zambia_weather")
cursor = db.cursor()

###########################
# current weather
# Town names array, helps to grab the data for each specific town.
towns_one = ['Chadiza', 'Chama', 'Chavuma', 'Chembe', 'Chibombo', 'Chiengi', 'Chililabombwe', 'Chilubi', 'Chingola', 'Chinsali']
towns_two = ['Chipata', 'Chirundu', 'Choma', 'Gwembe', 'Isoka', 'Kabwe', 'Kafue', 'Kalabo']
towns_three = ['Kalomo', 'Kaoma Kapiri', 'Mposhi', 'Kasama', 'Kasempa', 'Kataba', 'Katete', 'Kawambwa', 'Kazembe']
towns_four = ['Kazungula', 'Kitwe', 'Livingstone', 'Luangwa', 'Luanshya', 'Lufwanyama', 'Lukulu', 'Lundazi']
towns_five = ['Lusaka', 'Maamba', 'Makeni', 'Mansa', 'Mazabuka', 'Mbala', 'Mbereshi', 'Mfuwe', 'Milenge']
towns_six = ['Mkushi', 'Mongu', 'Monze', 'Mpika', 'Mporokoso', 'Mpulungu', 'Mufulira', 'Mumbwa', 'Muyombe']
towns_seven = ['Mwinilunga', 'Nchelenge', 'Ndola', 'Ngoma', 'Nkana', 'Pemba', 'Petauke', 'Samfya', 'Senanga']
towns_eight = ['Serenje', 'Sesheke', 'Shiwa', 'Ngandu', 'Siavonga', 'Sikalongo', 'Sinazongwe', 'Solwezi', 'Zambezi', 'Zimba']

towns = towns_one + towns_two + towns_three + towns_four + towns_five + towns_six + towns_seven + towns_eight

for x in towns:
    current = current.getCurrentWeather(q=x)

    tables = """CREATE TABLE IF NOT EXISTS %s (
          `id` int(11) NOT NULL AUTO_INCREMENT,
          `cloud` int(5) DEFAULT NULL,
          `condition_text` varchar(20) DEFAULT NULL,
          `condition_code` int(5) DEFAULT NULL,
          `icon` text,
          `temperature` float DEFAULT NULL,
          `humidity` int(5) DEFAULT NULL,
          `wind_degree` int(5) DEFAULT NULL,
          `wind_dir` varchar(5) DEFAULT NULL,
          `wind_kph` float DEFAULT NULL,
          `localtime` text,
          `region` varchar(30) DEFAULT NULL,
          `tz_id` varchar(50) DEFAULT NULL,
          PRIMARY KEY (`id`)
        ) ENGINE=InnoDB DEFAULT CHARSET=latin1 AUTO_INCREMENT=1 ;""" % x

    cursor = db.cursor()
    cursor.execute(tables)

    # Data from API
    cloud = current['current']['cloud']
    code = current['current']['condition']['code']
    condition_icon = current['current']['condition']['icon']
    condition_text = current['current']['condition']['text']
    humidity = current['current']['humidity']
    temperature = current['current']['temp_c']
    wind_degree = current['current']['wind_degree']
    wind_dir = current['current']['wind_dir']
    wind_speed = current['current']['wind_kph']
    localtime = current['location']['localtime']
    region = current['location']['region']
    tz_id = current['location']['tz_id']

    sql = cursor.execute("INSERT INTO "+ x +" VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)", (
    0, cloud, condition_text, code, condition_icon, temperature, humidity, wind_degree, wind_dir, wind_speed, localtime,
    region, tz_id))
    db.commit()
    db.close()