|
16 | 16 | FILENAME_REGEX = re.compile(
|
17 | 17 | r'^(?P<date>\d{8})_(?P<geo_type>\w+?)_(?P<signal>\w+)\.csv$')
|
18 | 18 |
|
19 |
| -params = read_params() |
20 |
| -assert "validation" in params |
21 |
| -API_KEY = ("epidata", params["validation"]["common"]["api_credentials"]) |
22 |
| - |
23 | 19 | def make_date_filter(start_date, end_date):
|
24 | 20 | """
|
25 | 21 | Create a function to filter dates in the specified date range (inclusive).
|
@@ -113,9 +109,14 @@ def get_geo_signal_combos(data_source):
|
113 | 109 |
|
114 | 110 | Cross references based on combinations reported available by COVIDcast metadata.
|
115 | 111 | """
|
| 112 | + |
| 113 | + params = read_params() |
| 114 | + assert "validation" in params |
| 115 | + api_key = ("epidata", params["validation"]["common"]["api_credentials"]) |
| 116 | + |
116 | 117 | # Maps data_source name with what's in the API, lists used in case of multiple names
|
117 | 118 | meta_response = requests.get("https://api.covidcast.cmu.edu/epidata/covidcast/meta",
|
118 |
| - auth=API_KEY) |
| 119 | + auth=api_key) |
119 | 120 | meta_response.raise_for_status()
|
120 | 121 | source_signal_mappings = {i['source']:i['db_source'] for i in
|
121 | 122 | meta_response.json()}
|
@@ -143,7 +144,7 @@ def get_geo_signal_combos(data_source):
|
143 | 144 | elif geo_status == "unknown":
|
144 | 145 | epidata_signal = requests.get(
|
145 | 146 | "https://api.covidcast.cmu.edu/epidata/covidcast/meta",
|
146 |
| - params={'signal': f"{src}:{sig}"}, auth=API_KEY) |
| 147 | + params={'signal': f"{src}:{sig}"}, auth=api_key) |
147 | 148 | epidata_signal.raise_for_status()
|
148 | 149 | # Not an active signal
|
149 | 150 | active_status = [val['active'] for i in epidata_signal.json()
|
|
0 commit comments