Skip to content
Snippets Groups Projects
Commit 83095a6c authored by CI-bot's avatar CI-bot Committed by renku 0.10.4
Browse files

renku rerun data/covidtracking/states-metadata.json data/covidtracking/states-daily.json

parent 3a3f5d65
No related branches found
No related tags found
1 merge request!351Automatic update - auto-update_2020-10-26_10-45
class: Workflow
cwlVersion: v1.0
hints: []
inputs:
input_1:
default: out_folder
streamable: false
type: string
input_2:
default: data/covidtracking
streamable: false
type: string
input_3:
default:
class: File
path: ../../notebooks/process/download-covidtracking-data.ipynb
streamable: false
type: File
input_4:
default: runs/download-covidtracking-data.runs.ipynb
streamable: false
type: string
input_5:
default: states-metadata.json
streamable: false
type: string
input_6:
default: states-daily.json
streamable: false
type: string
outputs:
output_0:
outputSource: step_1/output_1
streamable: false
type: Directory
output_2:
outputSource: step_1/output_0
streamable: false
type: File
requirements: []
steps:
step_1:
in:
input_1: input_1
input_2: input_2
input_3: input_3
input_4: input_4
out:
- output_0
- output_1
run: a17d560c41a54f5aa307ce5f3c5effe5_papermill.cwl
step_2:
in:
filename: input_5
input_directory: step_1/output_1
out:
- output_file
run:
arguments: []
baseCommand:
- 'true'
class: CommandLineTool
cwlVersion: v1.0
hints: []
inputs:
filename:
default: states-metadata.json
streamable: false
type: string
input_directory:
streamable: false
type: Directory
outputs:
output_file:
outputBinding:
glob: $(inputs.filename)
streamable: false
type: File
permanentFailCodes: []
requirements:
- &id001
class: InlineJavascriptRequirement
- &id002
class: InitialWorkDirRequirement
listing: $(inputs.input_directory.listing)
successCodes: []
temporaryFailCodes: []
step_3:
in:
filename: input_6
input_directory: step_1/output_1
out:
- output_file
run:
arguments: []
baseCommand:
- 'true'
class: CommandLineTool
cwlVersion: v1.0
hints: []
inputs:
filename:
default: states-daily.json
streamable: false
type: string
input_directory:
streamable: false
type: Directory
outputs:
output_file:
outputBinding:
glob: $(inputs.filename)
streamable: false
type: File
permanentFailCodes: []
requirements:
- *id001
- *id002
successCodes: []
temporaryFailCodes: []
source diff could not be displayed: it is stored in LFS. Options to address this: view the blob.
source diff could not be displayed: it is stored in LFS. Options to address this: view the blob.
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
import requests import requests
import os import os
import pandas as pd import pandas as pd
``` ```
%% Cell type:code id: tags:parameters %% Cell type:code id: tags:parameters
``` python ``` python
out_folder = "../data/covidtracking/" out_folder = "../data/covidtracking/"
PAPERMILL_OUTPUT_PATH = None PAPERMILL_OUTPUT_PATH = None
``` ```
%% Cell type:code id: tags:injected-parameters %% Cell type:code id: tags:injected-parameters
``` python ``` python
# Parameters # Parameters
PAPERMILL_INPUT_PATH = "/tmp/nez13572/notebooks/process/download-covidtracking-data.ipynb" PAPERMILL_INPUT_PATH = "/tmp/7ghx_g0f/notebooks/process/download-covidtracking-data.ipynb"
PAPERMILL_OUTPUT_PATH = "runs/download-covidtracking-data.runs.ipynb" PAPERMILL_OUTPUT_PATH = "runs/download-covidtracking-data.runs.ipynb"
out_folder = "data/covidtracking" out_folder = "data/covidtracking"
``` ```
%% Cell type:markdown id: tags: %% Cell type:markdown id: tags:
# Download state metadata # Download state metadata
Download a dataset of URLs for data for each US state and several territories. See [Google Doc](https://docs.google.com/spreadsheets/d/18oVRrHj3c183mHmq3m89_163yuYltLNlOmPerQ18E8w/htmlview?sle=true). Download a dataset of URLs for data for each US state and several territories. See [Google Doc](https://docs.google.com/spreadsheets/d/18oVRrHj3c183mHmq3m89_163yuYltLNlOmPerQ18E8w/htmlview?sle=true).
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
url = 'http://covidtracking.com/api/states/info' url = 'http://covidtracking.com/api/states/info'
r = requests.get(url, allow_redirects=True) r = requests.get(url, allow_redirects=True)
states_metadata_json = r.content states_metadata_json = r.content
``` ```
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
# save the result # save the result
if PAPERMILL_OUTPUT_PATH: if PAPERMILL_OUTPUT_PATH:
out_path = os.path.join(out_folder, 'states-metadata.json') out_path = os.path.join(out_folder, 'states-metadata.json')
with open(out_path, 'wb') as f: with open(out_path, 'wb') as f:
f.write(states_metadata_json) f.write(states_metadata_json)
``` ```
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
metadata_df = pd.read_json(states_metadata_json) metadata_df = pd.read_json(states_metadata_json)
print(len(metadata_df), "states and territories have metadata") print(len(metadata_df), "states and territories have metadata")
metadata_df.head(2) metadata_df.head(2)
``` ```
%% Output %% Output
56 states and territories have metadata 56 states and territories have metadata
state notes \ state notes \
0 AK Alaska combines PCR and antigen tests in the t... 0 AK Alaska combines PCR and antigen tests in the t...
1 AL Alabama combines PCR and antigen tests in the ... 1 AL Alabama combines PCR and antigen tests in the ...
covid19Site \ covid19Site \
0 http://dhss.alaska.gov/dph/Epi/id/Pages/COVID-... 0 http://dhss.alaska.gov/dph/Epi/id/Pages/COVID-...
1 https://alpublichealth.maps.arcgis.com/apps/op... 1 https://alpublichealth.maps.arcgis.com/apps/op...
covid19SiteSecondary \ covid19SiteSecondary \
0 https://experience.arcgis.com/experience/ed1c8... 0 https://experience.arcgis.com/experience/ed1c8...
1 https://alpublichealth.maps.arcgis.com/apps/op... 1 https://alpublichealth.maps.arcgis.com/apps/op...
covid19SiteTertiary covid19SiteQuaternary \ covid19SiteTertiary covid19SiteQuaternary \
0 https://alaska-dhss.maps.arcgis.com/apps/opsda... None 0 https://alaska-dhss.maps.arcgis.com/apps/opsda... None
1 https://services7.arcgis.com/4RQmZZ0yaZkGR1zy/... None 1 https://services7.arcgis.com/4RQmZZ0yaZkGR1zy/... None
covid19SiteQuinary twitter \ covid19SiteQuinary twitter \
0 None @Alaska_DHSS 0 None @Alaska_DHSS
1 None @alpublichealth 1 None @alpublichealth
covid19SiteOld \ covid19SiteOld \
0 http://dhss.alaska.gov/dph/Epi/id/Pages/COVID-... 0 http://dhss.alaska.gov/dph/Epi/id/Pages/COVID-...
1 http://www.alabamapublichealth.gov/infectiousd... 1 http://www.alabamapublichealth.gov/infectiousd...
covidTrackingProjectPreferredTotalTestUnits \ covidTrackingProjectPreferredTotalTestUnits \
0 Specimens 0 Specimens
1 Unclear units 1 Unclear units
covidTrackingProjectPreferredTotalTestField totalTestResultsField pui \ covidTrackingProjectPreferredTotalTestField totalTestResultsField pui \
0 totalTestsViral Total Tests (PCR) All data 0 totalTestsViral Total Tests (PCR) All data
1 totalTestsViral Total Tests (PCR) No data 1 totalTestsViral Total Tests (PCR) No data
pum name fips pum name fips
0 False Alaska 2 0 False Alaska 2
1 False Alabama 1 1 False Alabama 1
%% Cell type:markdown id: tags: %% Cell type:markdown id: tags:
# Download daily state data # Download daily state data
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
url = 'https://covidtracking.com/api/states/daily' url = 'https://covidtracking.com/api/states/daily'
r = requests.get(url, allow_redirects=True) r = requests.get(url, allow_redirects=True)
states_daily_json = r.content states_daily_json = r.content
``` ```
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
# save the result # save the result
if PAPERMILL_OUTPUT_PATH: if PAPERMILL_OUTPUT_PATH:
out_path = os.path.join(out_folder, 'states-daily.json') out_path = os.path.join(out_folder, 'states-daily.json')
with open(out_path, 'wb') as f: with open(out_path, 'wb') as f:
f.write(states_daily_json) f.write(states_daily_json)
``` ```
%% Cell type:code id: tags: %% Cell type:code id: tags:
``` python ``` python
data_df = pd.read_json(states_daily_json) data_df = pd.read_json(states_daily_json)
print(len(data_df), "data points") print(len(data_df), "data points")
data_df.head(2) data_df.head(2)
``` ```
%% Output %% Output
13213 data points 13213 data points
date state positive probableCases negative pending \ date state positive probableCases negative pending \
0 20201025 AK 14064.0 NaN 545905.0 NaN 0 20201025 AK 14064.0 NaN 545905.0 NaN
1 20201025 AL 184355.0 26474.0 1144785.0 NaN 1 20201025 AL 184355.0 26474.0 1144785.0 NaN
totalTestResultsSource totalTestResults hospitalizedCurrently \ totalTestResultsSource totalTestResults hospitalizedCurrently \
0 totalTestsViral 559969.0 58.0 0 totalTestsViral 559969.0 58.0
1 totalTestsViral 1302666.0 922.0 1 totalTestsViral 1302666.0 922.0
hospitalizedCumulative ... posNeg deathIncrease hospitalizedIncrease \ hospitalizedCumulative ... posNeg deathIncrease hospitalizedIncrease \
0 NaN ... 559969 0 0 0 NaN ... 559969 0 0
1 19595.0 ... 1329140 0 0 1 19595.0 ... 1329140 0 0
hash commercialScore \ hash commercialScore \
0 175a4f70a15c098ac277246bff6ae33838f66029 0 0 175a4f70a15c098ac277246bff6ae33838f66029 0
1 14421edcbba78df1217731644f92a3a03211c44d 0 1 14421edcbba78df1217731644f92a3a03211c44d 0
negativeRegularScore negativeScore positiveScore score grade negativeRegularScore negativeScore positiveScore score grade
0 0 0 0 0 0 0 0 0 0
1 0 0 0 0 1 0 0 0 0
[2 rows x 55 columns] [2 rows x 55 columns]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment