add source info to log message

Author: Kilo59

app/services/location/csbs.py

@@ -41,11 +41,11 @@ async def get_locations():
     :rtype: dict
     """
     logger = logging.getLogger("services.location.csbs")
-    logger.info("Requesting data...")
+    logger.info("csbs Requesting data...")
     async with httputils.CLIENT_SESSION.get(BASE_URL) as response:
         text = await response.text()
 
-    logger.info("Data received")
+    logger.info("csbs Data received")
 
     data = list(csv.DictReader(text.splitlines()))
     logger.info("CSV parsed")
@@ -83,7 +83,7 @@ async def get_locations():
                 int(item["Death"] or 0),
             )
         )
-    logger.info("Data normalized")
+    logger.info("csbs Data normalized")
 
     # Return the locations.
     return locations

app/services/location/jhu.py

@@ -57,15 +57,15 @@ async def get_category(category):
     url = BASE_URL + "time_series_covid19_%s_global.csv" % category
 
     # Request the data
-    logger.info("Requesting data...")
+    logger.info("jhu Requesting data...")
     async with httputils.CLIENT_SESSION.get(url) as response:
         text = await response.text()
 
-    logger.info("Data received")
+    logger.info("jhu Data received")
 
     # Parse the CSV.
     data = list(csv.DictReader(text.splitlines()))
-    logger.info("CSV parsed")
+    logger.info("jhu CSV parsed")
 
     # The normalized locations.
     locations = []
@@ -98,7 +98,7 @@ async def get_category(category):
                 "latest": int(latest or 0),
             }
         )
-    logger.info("Data normalized")
+    logger.info("jhu Data normalized")
 
     # Latest total.
     latest = sum(map(lambda location: location["latest"], locations))

app/services/location/nyt.py

@@ -75,15 +75,15 @@ async def get_locations():
     logger = logging.getLogger("services.location.nyt")
 
     # Request the data.
-    logger.info("Requesting data...")
+    logger.info("nyt Requesting data...")
     async with httputils.CLIENT_SESSION.get(BASE_URL) as response:
         text = await response.text()
 
     logger.info("Data received")
 
     # Parse the CSV.
     data = list(csv.DictReader(text.splitlines()))
-    logger.info("CSV parsed")
+    logger.info("nyt CSV parsed")
 
     # Group together locations (NYT data ordered by dates not location).
     grouped_locations = get_grouped_locations_dict(data)
@@ -125,6 +125,6 @@ async def get_locations():
                 },
             )
         )
-    logger.info("Data normalized")
+    logger.info("nyt Data normalized")
 
     return locations