fully async flask app based on quart and aiohttp

Author: mikeckennedy

src/10-async-web/.idea/dictionaries/screencaster.xml

@@ -2,4 +2,6 @@
 quart
 
 # Calling services requirements
-requests
+aiohttp
+aiodns
+cchardet

src/10-async-web/acityscape_api/requirements.txt

@@ -1,7 +1,8 @@
 import random
 import time
 from typing import Tuple
-import requests
+
+import aiohttp
 
 use_cached_data = False
 
@@ -10,18 +11,19 @@
     0.535646, 0.527148, 0.533472, 0.53351, 0.523462]
 
 
-def get_lat_long(zip_code: str, country: str) -> Tuple[float, float]:
+async def get_lat_long(zip_code: str, country: str) -> Tuple[float, float]:
     key = f'{zip_code}, {country}'
     url = f'http://www.datasciencetoolkit.org/street2coordinates/{key.replace(" ", "+")}'
 
     if use_cached_data:
         time.sleep(random.choice(measured_latency_in_sec))
         return 45.50655, -122.733888
     else:
-        resp = requests.get(url)
-        resp.raise_for_status()
+        async with aiohttp.ClientSession() as session:
+            async with session.get(url) as resp:
+                resp.raise_for_status()
 
-        data = resp.json()
+                data = await resp.json()
 
         city_data = data.get(f'{zip_code}, {country}', dict())
         return city_data.get('latitude', 0.00), city_data.get('longitude', 0.00)

src/10-async-web/acityscape_api/services/location_service.py

@@ -2,13 +2,13 @@
 import random
 import time
 
-import requests
+import aiohttp
 
 measured_latency_in_sec = [0.399203, 0.7046, 0.422959, 0.741911, 0.404674]
 use_cached_data = False
 
 
-def for_today(latitude: float, longitude: float) -> dict:
+async def for_today(latitude: float, longitude: float) -> dict:
     url = f'https://api.sunrise-sunset.org/json?lat={latitude}&lng={longitude}'
 
     if use_cached_data:  # Set in config/dev.json or config/prod.json
@@ -18,10 +18,12 @@ def for_today(latitude: float, longitude: float) -> dict:
                 'nautical_twilight_begin': '04:49:54 AM', 'nautical_twilight_end': '09:43:03 PM',
                 'astronomical_twilight_begin': '04:03:13 AM', 'astronomical_twilight_end': '10:29:44 PM'}
     else:
-        resp = requests.get(url)
-        resp.raise_for_status()
+        async with aiohttp.ClientSession() as session:
+            async with session.get(url) as resp:
+
+                data = await resp.json()
+                sun_data = data.get('results', {})
 
-        sun_data = resp.json().get('results', {})
         for k, v in list(sun_data.items()):
             if 'AM' not in v and 'PM' not in v:
                 continue

src/10-async-web/acityscape_api/services/sun_service.py

@@ -1,4 +1,4 @@
-import requests
+import aiohttp
 
 __api_key = ''
 
@@ -8,9 +8,10 @@ def global_init(api_key: str):
     __api_key = api_key
 
 
-def get_current(zip_code: str, country_code: str) -> dict:
+async def get_current(zip_code: str, country_code: str) -> dict:
     url = f'https://api.openweathermap.org/data/2.5/weather?zip={zip_code},{country_code}&appid={__api_key}'
-    resp = requests.get(url)
-    resp.raise_for_status()
+    async with aiohttp.ClientSession() as session:
+        async with session.get(url) as resp:
+            resp.raise_for_status()
 
-    return resp.json()
+            return await resp.json()

src/10-async-web/acityscape_api/services/weather_service.py

@@ -5,17 +5,17 @@
 
 
 @blueprint.route('/api/weather/<zip_code>/<country>', methods=['GET'])
-def weather(zip_code: str, country: str):
-    weather_data = weather_service.get_current(zip_code, country)
+async def weather(zip_code: str, country: str):
+    weather_data = await weather_service.get_current(zip_code, country)
     if not weather_data:
         quart.abort(404)
     return quart.jsonify(weather_data)
 
 
 @blueprint.route('/api/sun/<zip_code>/<country>', methods=['GET'])
-def sun(zip_code: str, country: str):
-    lat, long = location_service.get_lat_long(zip_code, country)
-    sun_data = sun_service.for_today(lat, long)
+async def sun(zip_code: str, country: str):
+    lat, long = await location_service.get_lat_long(zip_code, country)
+    sun_data = await sun_service.for_today(lat, long)
     if not sun_data:
         quart.abort(404)
     return quart.jsonify(sun_data)