cowidev.vax.incremental#

cowidev.vax.incremental.africacdc#

class cowidev.vax.incremental.africacdc.AfricaCDC(skip_who: bool = False)[source]#

Bases: object

_base_url = 'https://services8.arcgis.com/vWozsma9VzGndzx7/ArcGIS/rest/services/Admin_Boundaries_Africa_corr_Go_Vaccine_DB_JOIN/FeatureServer/0'#
_map_vaccines(vaccine_raw: str)[source]#
_parse_date()[source]#
columns_rename = {'ADM0_SOVRN': 'location', 'Booster': 'total_boosters', 'FullyVacc': 'people_fully_vaccinated', 'TotAmtAdmi': 'total_vaccinations', 'VacAd1Dose': 'people_vaccinated'}#
columns_use = ['ADM0_SOVRN', 'TotAmtAdmi', 'FullyVacc', 'VacAd1Dose', 'Booster', 'ISO_3_CODE', 'VacAd2Dose', 'VaccApprov']#
export()[source]#
increment_countries(df: DataFrame)[source]#
pipe_date(df: DataFrame) DataFrame[source]#
pipe_exclude_observations(df: DataFrame) DataFrame[source]#
pipe_filter_columns(df: DataFrame) DataFrame[source]#
pipe_filter_countries(df: DataFrame, countries: dict) DataFrame[source]#

Get rows from selected countries.

pipe_one_dose_correction(df: DataFrame) DataFrame[source]#
pipe_rename(df: DataFrame) DataFrame[source]#
pipe_select_out_cols(df: DataFrame) DataFrame[source]#
pipe_source(df: DataFrame) DataFrame[source]#
pipe_vaccine(df: DataFrame) DataFrame[source]#
pipe_vaccine_who(df: DataFrame) DataFrame[source]#
pipeline(df: DataFrame, countries: dict = {'Angola': 'Angola', 'Botswana': 'Botswana', 'Burkina Faso': 'Burkina Faso', 'Burundi': 'Burundi', 'Central African Republic': 'Central African Republic', 'Chad': 'Chad', 'Congo': 'Congo', 'Djibouti': 'Djibouti', 'Eswatini': 'Eswatini', 'Gabon': 'Gabon', 'Ghana': 'Ghana', 'Lesotho': 'Lesotho', 'Liberia': 'Liberia', 'Libya': 'Libya', 'Madagascar': 'Madagascar', 'Mauritania': 'Mauritania', 'Mauritius': 'Mauritius', 'Mozambique': 'Mozambique', 'Namibia': 'Namibia', 'Niger': 'Niger', 'Nigeria': 'Nigeria', 'Rwanda': 'Rwanda', 'Senegal': 'Senegal', 'Sudan': 'Sudan', 'Zambia': 'Zambia'}, exclude=True) DataFrame[source]#
read() DataFrame[source]#
property source_url#
property source_url_date#
source_url_ref = 'https://africacdc.org/covid-19-vaccination/'#
cowidev.vax.incremental.africacdc.main()[source]#

cowidev.vax.incremental.antigua_barbuda#

class cowidev.vax.incremental.antigua_barbuda.AntiguaBarbuda[source]#

Bases: object

_get_elements(soup)[source]#
_parse_date(dose1_elem, dose2_elem)[source]#
_parse_metric(elem)[source]#
export()[source]#

Generalized.

location = 'Antigua and Barbuda'#
parse_data(soup)[source]#
pipe_location(ds: Series) Series[source]#
pipe_people_vaccinated(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(df: Series) Series[source]#
read() DataFrame[source]#
regex = {'date': '\\[Updated on ([a-zA-Z]+ \\d{1,2}, 202\\d)\\]'}#
source_url = 'https://covid19.gov.ag'#
cowidev.vax.incremental.antigua_barbuda.main()[source]#

cowidev.vax.incremental.aruba#

cowidev.vax.incremental.aruba.add_totals(ds: Series) Series[source]#
cowidev.vax.incremental.aruba.enrich_date(ds: Series) Series[source]#
cowidev.vax.incremental.aruba.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.aruba.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.aruba.main()[source]#
cowidev.vax.incremental.aruba.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.aruba.read(source: str) Series[source]#

cowidev.vax.incremental.azerbaijan#

class cowidev.vax.incremental.azerbaijan.Azerbaijan[source]#

Bases: CountryVaxBase

_parse_data(soup: BeautifulSoup) dict[source]#

get data from the source page.

_parse_date(text: str) str[source]#

Parse date from text.

_parse_metrics(text: str) tuple[source]#

Parse metrics from text.

Parse pdf link from source page.

_parse_pdf_text(url: str) str[source]#

Parse pdf text from url.

enrich_location(ds: Series) Series[source]#

Enrich data with locationß.

enrich_vaccine(ds: Series) Series[source]#

Enrich data with vaccine names.

export()[source]#

Export data to csv.

location: str = 'Azerbaijan'#
pipeline(df: DataFrame) DataFrame[source]#

Pipeline for data.

read() Series[source]#

Read data from source.

regex = {'date': '(\\d{2}\\.\\d{2}\\.20\\d{2})', 'doses': '\\"Buster\\" doza vaksinlərin sayı (\\d+) (\\d+) (\\d+) (\\d+) (\\d+) Gün', 'title': 'Vaksinasiya'}#
source_url = 'https://koronavirusinfo.az'#
cowidev.vax.incremental.azerbaijan.main()[source]#

cowidev.vax.incremental.bahrain#

class cowidev.vax.incremental.bahrain.Bahrain[source]#

Bases: object

_parse_data(soup: BeautifulSoup) Series[source]#
export()[source]#
location: str = 'Bahrain'#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://healthalert.gov.bh/en/'#
cowidev.vax.incremental.bahrain.main()[source]#

cowidev.vax.incremental.bangladesh#

class cowidev.vax.incremental.bangladesh.Bangladesh[source]#

Bases: object

_parse_metrics(soup)[source]#
_parse_metrics_raw(soup, raise_err=True)[source]#
_parse_single_doses()[source]#
_parse_vaccines(soup)[source]#
export()[source]#
location: str = 'Bangladesh'#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'http://103.247.238.92/webportal/pages/covid19-vaccination-update.php'#
vaccines_rename = {'AstraZeneca': 'Oxford/AstraZeneca', 'Janssen (Johnson & Johnson)': 'Johnson&Johnson', 'Moderna': 'Moderna', 'Pfizer': 'Pfizer/BioNTech', 'Pfizer-PF (Comirnaty)': 'Pfizer/BioNTech', 'Sinopharm': 'Sinopharm/Beijing', 'Sinovac': 'Sinovac'}#
cowidev.vax.incremental.bangladesh.main()[source]#

cowidev.vax.incremental.barbados#

class cowidev.vax.incremental.barbados.Barbados[source]#

Bases: CountryVaxBase

_parse_data(soup: BeautifulSoup) DataFrame[source]#

Parse data from soup

_parse_date(soup: BeautifulSoup) str[source]#

Parse date from soup

_parse_metrics(soup: BeautifulSoup) int[source]#

Parse metrics from soup

export()[source]#

Export data to csv

location: str = 'Barbados'#
pipe_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names for main data.

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for data processing

read() DataFrame[source]#

Read data from source

regex: dict = {'people_fully_vaccinated': 'fully? (?:vaccinated|vaccinated persons) is ([\\d,\\s]+)', 'people_vaccinated': 'at least one dose is ([\\d,\\s]+)', 'title': 'COVID-19 Update'}#
source_url: str = 'https://gisbarbados.gov.bb/top-stories/'#
source_url_ref: str = None#
cowidev.vax.incremental.barbados.main()[source]#

cowidev.vax.incremental.brazil#

class cowidev.vax.incremental.brazil.Brazil[source]#

Bases: object

export()[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read()[source]#
cowidev.vax.incremental.brazil.main()[source]#

cowidev.vax.incremental.bulgaria#

class cowidev.vax.incremental.bulgaria.Bulgaria[source]#

Bases: CountryVaxBase

_parse_data(soup: BeautifulSoup) Series[source]#
export()[source]#
location: str = 'Bulgaria'#
pipe_date(ds: Series) Series[source]#
pipe_index(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) DataFrame[source]#
read() Series[source]#
source_url: str = 'https://coronavirus.bg/bg/statistika'#
cowidev.vax.incremental.bulgaria.main()[source]#

cowidev.vax.incremental.china#

class cowidev.vax.incremental.china.China[source]#

Bases: CountryVaxBase

_parse_data(driver, url)[source]#
_parse_data_complete(driver, url)[source]#
chinese: str = '[\\u4e00-\\u9fff、()]*'#
export()[source]#
location: str = 'China'#
metric: str = '((?:\\d+亿零?)?[\\d\\.]+万)'#
metric_ignore: str = '(?:\\d+亿[\\u4e00-\\u96f5\\u96f7-\\u9fff,]{1,5})?'#
month_day: str = ',?(?:\\d{2,4}年)?(\\d{1,2})月(\\d{1,2})[\\u4e00-\\u9fff,]{1,5}(?:\\d+个)?'#
pipe_metadata(df: DataFrame) DataFrame[source]#
pipe_vaccine(df: DataFrame) DataFrame[source]#
pipeline(df: DataFrame) DataFrame[source]#
pipeline_merge(df_complete: DataFrame, df_last: DataFrame, df: DataFrame) DataFrame[source]#
read(last_update: str) DataFrame[source]#
read_complete() DataFrame[source]#
regex: dict = {'date': '截至(20\\d{2})年(\\d{1,2})月(\\d{1,2})日', 'title': '新冠病毒疫苗接种情况', 'total_vaccinations': '([\\d\\.]+\\s*万)剂次'}#
regex_complete: dict = {'boosters': '加强免疫[\\u4e00-\\u9fff、()]*接种[\\u4e00-\\u9fff、()]*(?:\\d+亿[\\u4e00-\\u96f5\\u96f7-\\u9fff,]{1,5})?((?:\\d+亿零?)?[\\d\\.]+万)', 'fully': '全程接种[\\u4e00-\\u9fff、()]*(?:\\d+亿[\\u4e00-\\u96f5\\u96f7-\\u9fff,]{1,5})?((?:\\d+亿零?)?[\\d\\.]+万)', 'summary': '截[\\u4e00-\\u9fff、()]*,?(?:\\d{2,4}年)?(\\d{1,2})月(\\d{1,2})[\\u4e00-\\u9fff,]{1,5}(?:\\d+个)?[\\u4e00-\\u9fff、()]*接种[\\u4e00-\\u9fff、()]*(?:\\d+亿[\\u4e00-\\u96f5\\u96f7-\\u9fff,]{1,5})?((?:\\d+亿零?)?[\\d\\.]+万)剂', 'title': '国务院(?:联防联控机制|新闻办公室)(20\\d{2})年(\\d{1,2})月(\\d{1,2})日新闻发布会', 'vaccinated': '接种[\\u4e00-\\u9fff、()]*总人数[\\u4e00-\\u9fff、()]*(?:\\d+亿[\\u4e00-\\u96f5\\u96f7-\\u9fff,]{1,5})?((?:\\d+亿零?)?[\\d\\.]+万)'}#
source_url: str = 'http://www.nhc.gov.cn/xcs/yqjzqk/list_gzbd.shtml'#
source_url_complete: str = 'http://www.nhc.gov.cn/xcs/s2906/new_list.shtml'#
timeout: int = 30#
cowidev.vax.incremental.china.main()[source]#

cowidev.vax.incremental.costa_rica#

class cowidev.vax.incremental.costa_rica.CostaRica[source]#

Bases: object

_parse_data(soup: BeautifulSoup) Series[source]#
_parse_date(soup)[source]#
_parse_table(soup)[source]#
export()[source]#
location: str = 'Costa Rica'#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://www.ccss.sa.cr/web/coronavirus/vacunacion'#
cowidev.vax.incremental.costa_rica.main()[source]#

cowidev.vax.incremental.croatia#

cowidev.vax.incremental.croatia.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.croatia.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.croatia.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.croatia.main()[source]#
cowidev.vax.incremental.croatia.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.croatia.read(source: str) Series[source]#

cowidev.vax.incremental.cuba#

class cowidev.vax.incremental.cuba.Cuba[source]#

Bases: object

_parse_data(soup: BeautifulSoup) Series[source]#
_parse_date(soup)[source]#
_parse_metrics(soup)[source]#
export()[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(df: Series) Series[source]#
read() Series[source]#
cowidev.vax.incremental.cuba.main()[source]#

cowidev.vax.incremental.curacao#

class cowidev.vax.incremental.curacao.Curacao[source]#

Bases: object

_parse_data() dict[source]#
export()[source]#
location = 'Curacao'#
pipe_date(ds: Series) Series[source]#
pipe_total_vaccinations(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://bakuna-counter.ibis-management.com/init/'#
source_url_ref = 'https://bakuna.cw/'#
vaccine = 'Pfizer/BioNTech, Moderna'#
cowidev.vax.incremental.curacao.main()[source]#

cowidev.vax.incremental.cyprus#

cowidev.vax.incremental.cyprus.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.cyprus.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.cyprus.main()[source]#
cowidev.vax.incremental.cyprus.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.cyprus.read(source: str) Series[source]#

cowidev.vax.incremental.dominican_republic#

class cowidev.vax.incremental.dominican_republic.DominicanRepublic[source]#

Bases: CountryVaxBase

_parse_date(driver)[source]#
_parse_metrics(driver)[source]#
export()[source]#
location: str = 'Dominican Republic'#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read()[source]#
source_url = 'https://vacunate.gob.do'#
source_url_ref = 'https://vacunate.gob.do'#
cowidev.vax.incremental.dominican_republic._find_h3(driver)[source]#
cowidev.vax.incremental.dominican_republic._find_potential_metric_elements(h3)[source]#
cowidev.vax.incremental.dominican_republic._find_potential_metrics(driver)[source]#
cowidev.vax.incremental.dominican_republic.main()[source]#

cowidev.vax.incremental.el_salvador#

class cowidev.vax.incremental.el_salvador.ElSalvador[source]#

Bases: object

_get_infogram_value(infogram_data: dict, field_id: str, join_text: bool = False)[source]#
_parse_boosters(infogram_data: dict) int[source]#
_parse_people_fully_vaccinated(infogram_data: dict) int[source]#
_parse_people_vaccinated(infogram_data: dict) int[source]#
_parse_total_vaccinations(infogram_data: dict) int[source]#
export()[source]#
location: str = 'El Salvador'#
parse_infogram_data(soup: BeautifulSoup) dict[source]#
parse_infogram_date(infogram_data: dict) str[source]#
pipe_location(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://covid19.gob.sv/'#
cowidev.vax.incremental.el_salvador.main()[source]#

cowidev.vax.incremental.faeroe_islands#

class cowidev.vax.incremental.faeroe_islands.FaeroeIslands[source]#

Bases: object

export()[source]#
location: str = 'Faeroe Islands'#
pipe_format_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_metrics(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://corona.fo/json/stats'#
source_url_ref: str = 'https://corona.fo/api'#
cowidev.vax.incremental.faeroe_islands.main()[source]#

cowidev.vax.incremental.fiji#

class cowidev.vax.incremental.fiji.Fiji[source]#

Bases: CountryVaxBase

__element = None#
_get_list_of_elements(soup: BeautifulSoup) None[source]#

Get the relevant elements list from the source page.

_get_relevant_element_and_year() tuple[source]#

Get the relevant element and year from the element list.

_get_text_from_url(url: str) str[source]#

Extract text from the url.

_num_max_pages: int = 3#
_num_rows_per_page: int = 3#
_parse_data(soup: BeautifulSoup) tuple[source]#

Get data from the source page.

_parse_date_from_text(year: str, text: str) str[source]#

Get date from relevant element.

Get link from relevant element.

_parse_metrics(text: str) int[source]#

Get metrics from news text.

export()[source]#

Exports data to csv.

location: str = 'Fiji'#
pipe_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names.

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for data.

read() DataFrame[source]#

Read data from source.

regex = {'booster': '(\\d+) individuals have so far received booster doses.', 'date': 'tests have been reported for (\\w+ \\d+)', 'title': 'COVID-19 Update', 'year': '\\d{4}'}#
source_url: str = 'https://www.health.gov.fj/page/'#
source_url_ref: str = ''#
cowidev.vax.incremental.fiji.check_booster()[source]#
cowidev.vax.incremental.fiji.main()[source]#

cowidev.vax.incremental.finland#

class cowidev.vax.incremental.finland.Finland[source]#

Bases: CountryVaxBase

export()[source]#
location: str = 'Finland'#
metrics_mapping: dict = {'Booster dose': 'total_boosters', 'First dose': 'people_vaccinated', 'Second dose': 'people_fully_vaccinated', 'Third dose (NOT booster)': 'third_dose'}#
pipe_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://sampo.thl.fi/pivot/prod/en/vaccreg/cov19cov/fact_cov19cov.csv?row=vacprod-533726&row=measure-533175.&column=cov_vac_dose-533174&'#
source_url_ref: str = 'https://sampo.thl.fi/pivot/prod/en/vaccreg/cov19cov/fact_cov19cov'#
vaccine_mapping: dict = {'COVID-19 Vaccine Janssen (JANSSEN-CILAG)': 'Johnson&Johnson', 'Comirnaty (BioNTech)': 'Pfizer/BioNTech', 'Spikevax (MODERNA)': 'Moderna', 'Vaxzevria (AstraZeneca)': 'Oxford/AstraZeneca'}#
cowidev.vax.incremental.finland.main()[source]#

cowidev.vax.incremental.gabon#

class cowidev.vax.incremental.gabon.Gabon[source]#

Bases: object

export()[source]#

Generalized.

location = 'Gabon'#
parse_data(soup: BeautifulSoup) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_people_vaccinated(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(df: Series) Series[source]#
read() DataFrame[source]#
regex = {'date': '(\\d{1,2}-\\d{1,2}-202\\d) \\d{1,2}:\\d{1,2}:\\d{1,2}'}#
source_url = 'https://monitoring-covid19gabon.ga/'#
cowidev.vax.incremental.gabon.main()[source]#

cowidev.vax.incremental.georgia#

class cowidev.vax.incremental.georgia.Georgia[source]#

Bases: object

export()[source]#
parse_data(soup)[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
cowidev.vax.incremental.georgia.main()[source]#

cowidev.vax.incremental.greenland#

class cowidev.vax.incremental.greenland.Greenland[source]#

Bases: object

_parse_data(soup) dict[source]#
_parse_data_date(soup) dict[source]#
_parse_data_metrics(soup) dict[source]#
export()[source]#
location: str = 'Greenland'#
pipe_location(ds: Series) Series[source]#
pipe_metrics(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
regex = {'date': '.*Nutarterneqarpoq: (\\d+. [a-zA-Z]+202\\d)'}#
source_url: str = 'https://corona.nun.gl'#
cowidev.vax.incremental.greenland.main()[source]#

cowidev.vax.incremental.guatemala#

cowidev.vax.incremental.guatemala.main()[source]#

cowidev.vax.incremental.guernsey#

class cowidev.vax.incremental.guernsey.Guernsey[source]#

Bases: object

_regex_date = 'This page was last updated on (\\d{1,2} [A-Za-z]+ 202\\d)'#
export()[source]#

Generalized.

location = 'Guernsey'#
parse_data(soup)[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://covid19.gov.gg/guidance/vaccine/stats'#
cowidev.vax.incremental.guernsey.main()[source]#

cowidev.vax.incremental.hungary#

class cowidev.vax.incremental.hungary.Hungary[source]#

Bases: CountryVaxBase

export()[source]#

Generalized.

get_elements(soup: BeautifulSoup) list[source]#
parse_data(soup: BeautifulSoup, last_update: str) tuple[source]#
parse_data_news_page(soup: BeautifulSoup)[source]#

2021-09-10 We received confirmation from the International Communications Office, State Secretariat for International Communications and Relations, that the part of the report referring to people who received the 2nd dose (“közülük ([d ]+) fő már a második oltását is megkapt”) also included those who have received the J&J vaccine. On the other hand, we cannot estimate the number of vaccinations administered, as adding the two reported metrics would count J&J vaccines twice.

pipe_drop_duplicates(df: DataFrame) DataFrame[source]#
pipe_location(df: DataFrame) DataFrame[source]#
pipe_select_output_columns(df: DataFrame) DataFrame[source]#
pipe_vaccine(df: DataFrame) DataFrame[source]#
pipeline(df: Series) Series[source]#
read(last_update: str) DataFrame[source]#
cowidev.vax.incremental.hungary.main()[source]#

cowidev.vax.incremental.iceland#

class cowidev.vax.incremental.iceland.Iceland[source]#

Bases: CountryVaxBase

_get_json_data(soup)[source]#
_parse_data(json_data)[source]#
_parse_data_manufacturer(json_data)[source]#
_parse_date(json_data)[source]#
_parse_metrics(json_data)[source]#
export()[source]#
location: str = 'Iceland'#
metric_entities: dict = {'additional_doses': 'c1286d9e-254c-434a-9455-21b94969d163', 'people_fully_vaccinated': '16a69e30-01fd-4806-920c-436f8f29e9bf', 'people_vaccinated': '8d14f33a-d482-4176-af55-71209314b07b', 'total_boosters': '209af2de-9927-4c51-a704-ddc85e28bab9', 'total_vaccinations': '7287c058-7921-4abc-a667-ce298827c969'}#
pipeline_manufacturer(df)[source]#
read()[source]#
source_url: str = 'https://e.infogram.com/c3bc3569-c86d-48a7-9d4c-377928f102bf'#
source_url_ref: str = 'https://www.covid.is/tolulegar-upplysingar-boluefni'#
cowidev.vax.incremental.iceland.main()[source]#

cowidev.vax.incremental.india#

class cowidev.vax.incremental.india.India[source]#

Bases: object

property date_str#
export()[source]#
location: str = 'India'#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read()[source]#
read_cowin(json_data) Series[source]#
read_mohfw(json_data) Series[source]#
source_name: str = 'cowin'#
property source_url#
source_url_ref: str = {'cowin': 'https://dashboard.cowin.gov.in/', 'mohfw': 'https://www.mohfw.gov.in/'}#
cowidev.vax.incremental.india.main()[source]#

cowidev.vax.incremental.iran#

class cowidev.vax.incremental.iran.Iran[source]#

Bases: object

_base_url = 'https://irangov.ir/'#

Extract link and date from relevant element.

_get_relevant_element(soup: BeautifulSoup) Tag[source]#

Get the relevant element in news feed.

_get_text_from_url(url: str) str[source]#

Extract text from the url.

_num_max_pages = 3#
_parse_data(soup: BeautifulSoup) tuple[source]#

Get data from the source page.

_parse_date_from_element(elem: Tag) str[source]#

Get date from relevant element.

Get link from relevant element.

_parse_metrics(text: str) dict[source]#

Get metrics from news text.

_url_subdirectory = 'ministry-of-health-and-medical-education'#
export()[source]#
location = 'Iran'#
pipe_location(data_series: Series) Series[source]#
pipe_vaccine(data_series: Series) Series[source]#
pipeline(data_series: Series) Series[source]#
read() Series[source]#
regex = {'date': '(\\d+\\-\\d+\\-\\d+)', 'people_fully_vaccinated': '(\\d+) people have so far received the second dose', 'people_vaccinated': '(\\d+) Iranians have received the first dose', 'title': "Health Ministry's Updates on COVID-19", 'total_boosters': '(\\d+) people have received the third dose'}#
cowidev.vax.incremental.iran.main()[source]#

cowidev.vax.incremental.isle_of_man#

class cowidev.vax.incremental.isle_of_man.IsleOfMan[source]#

Bases: CountryVaxBase

_parse_data(df: DataFrame) Series[source]#
property data_body#
export()[source]#
property headers#
location: str = 'Isle of Man'#
metrics_mapping: dict = {'Booster dose': 'total_boosters', 'First dose': 'people_vaccinated', 'Second dose': 'people_fully_vaccinated', 'Third dose (NOT booster)': 'third_dose'}#
pipe_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_metrics(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://wabi-west-europe-b-primary-api.analysis.windows.net/public/reports/querydata?synchronous=true'#
source_url_ref: str = 'https://covid19.gov.im/general-information/covid-19-vaccination-statistics/'#
cowidev.vax.incremental.isle_of_man.main()[source]#

cowidev.vax.incremental.jamaica#

class cowidev.vax.incremental.jamaica.Jamaica[source]#

Bases: CountryVaxBase

_parse_data(soup) Series[source]#
export()[source]#
location: str = 'Jamaica'#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://vaccination.moh.gov.jm'#
source_url_ref: str = 'https://vaccination.moh.gov.jm'#
cowidev.vax.incremental.jamaica.main()[source]#

cowidev.vax.incremental.kazakhstan#

class cowidev.vax.incremental.kazakhstan.Kazakhstan[source]#

Bases: CountryVaxBase

_parse_boosters(driver: WebDriver) tuple[source]#
_parse_date(driver: WebDriver) str[source]#
_parse_vaccinations(driver: WebDriver) tuple[source]#
export()[source]#
location: str = 'Kazakhstan'#
pipe_metadata(ds: Series)[source]#
pipe_metrics(ds: Series)[source]#
pipe_to_frame(ds: Series)[source]#
pipe_vaccine(ds: Series)[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://www.coronavirus2020.kz/'#
cowidev.vax.incremental.kazakhstan.main()[source]#

cowidev.vax.incremental.kosovo#

class cowidev.vax.incremental.kosovo.Kosovo[source]#

Bases: CountryVaxBase

_parse_data(soup: BeautifulSoup) DataFrame[source]#

Parse data from the soup

_parse_metrics(soup: BeautifulSoup) int[source]#

Parse metrics from the soup

export()[source]#

Exports data to csv

location: str = 'Kosovo'#
pipe_date(df: DataFrame) DataFrame[source]#

Pipes date

pipe_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names.

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for data processing

read() DataFrame[source]#

Read data from source

regex: dict = {'Boosters': 'Numri i dozave përforcuese administruara', 'Dose2': 'Numri i vaksinuarve me dy dozat', 'Dose3': 'Numri i dozave treta administruara', 'Total': 'Numri total i vaksinave administruara'}#
source_url: str = 'https://msh.rks-gov.net/sq/statistikat-covid-19/'#
source_url_ref: str = 'https://msh.rks-gov.net/sq/statistikat-covid-19/'#
cowidev.vax.incremental.kosovo.main()[source]#

cowidev.vax.incremental.kyrgyzstan#

class cowidev.vax.incremental.kyrgyzstan.Kyrgyzstan[source]#

Bases: object

_parse_data(soup)[source]#
export()[source]#

Generalized.

location = 'Kyrgyzstan'#
pipe_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://vc.emed.gov.kg/'#
cowidev.vax.incremental.kyrgyzstan.main()[source]#

cowidev.vax.incremental.laos#

class cowidev.vax.incremental.laos.Laos[source]#

Bases: object

_get_relevant_element(soup: BeautifulSoup) Tag[source]#

Gets element from the soup.

_get_text_from_element(elem: Tag) str[source]#

Gets text from element.

_parse_data(soup: BeautifulSoup) dict[source]#

Gets data from the source page.

_parse_date(text: str) str[source]#

Gets date from the text.

_parse_metrics(text: str) tuple[source]#

Gets metrics from the text.

export()[source]#

Exports data to csv.

location = 'Laos'#
pipe_location(ds: Series) Series[source]#

Pipes location.

pipe_source(ds: Series) Series[source]#

Pipes source url.

pipe_vaccine(ds: Series) Series[source]#

Pipes vaccine names.

pipeline(ds: Series) Series[source]#

Pipeline for the data.

read() Series[source]#

Reads data from source.

regex = {'date': 'ຂໍ້ມູນ ເວລາ .*? (\\d+\\/\\d+\\/\\d+)', 'dose_1': 'ຮັບວັກຊິນເຂັມທີ 1 (\\d+)', 'dose_2': 'ຮັບວັກຊິນເຂັມທີ 2 (\\d+)'}#
source_url = 'https://www.covid19.gov.la/index.php'#
cowidev.vax.incremental.laos.main()[source]#

cowidev.vax.incremental.macao#

class cowidev.vax.incremental.macao.Macao[source]#

Bases: object

_parse_data(element)[source]#
_parse_date(element)[source]#

Get data from report file title.

_parse_pdf_table(url)[source]#

Extract table

export()[source]#
location = 'Macao'#
read()[source]#

Create data.

source_url = 'https://www.ssm.gov.mo/apps1/covid19vaccine/en.aspx'#
cowidev.vax.incremental.macao.main()[source]#

cowidev.vax.incremental.moldova#

class cowidev.vax.incremental.moldova.Moldova[source]#

Bases: CountryVaxBase

_parse_data(soup: BeautifulSoup) Series[source]#
enrich_location(ds: Series) Series[source]#
enrich_source(ds: Series) Series[source]#
enrich_vaccine(ds: Series) Series[source]#
export()[source]#
format_date(ds: Series) Series[source]#
location: str = 'Moldova'#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://vaccinare.gov.md'#
cowidev.vax.incremental.moldova.main()[source]#

cowidev.vax.incremental.monaco#

class cowidev.vax.incremental.monaco.Monaco[source]#

Bases: CountryVaxBase

_base_url = 'https://www.gouv.mc'#
_num_max_pages = 5#
export()[source]#

Generalized.

get_elements(soup: BeautifulSoup) list[source]#
location: str = 'Monaco'#
parse_data(soup: BeautifulSoup, last_update: str) tuple[source]#
parse_data_news_page(soup: BeautifulSoup)[source]#
parse_date(elem)[source]#
pipe_drop_duplicates(df: DataFrame) DataFrame[source]#
pipe_filter_nans(df: DataFrame) DataFrame[source]#
pipe_location(df: DataFrame) DataFrame[source]#
pipe_select_output_columns(df: DataFrame) DataFrame[source]#
pipe_total_vaccinations(df: DataFrame) DataFrame[source]#
pipe_vaccine(df: DataFrame) DataFrame[source]#
pipeline(df: Series) Series[source]#
read(last_update: str) DataFrame[source]#
regex = {'date': 'voici les chiffres arrêtés au (\\d+ \\w+) inclus', 'people_fully_vaccinated': 'Nombre de personnes ayant reçu l’injection de rappel\\s:\\s([\\d\\.]+)', 'people_vaccinated': 'Nombre de personnes vaccinées en primo injection\\s:\\s([\\d\\.]+)', 'title': 'Covid-19 : .*'}#
source_url = 'https://www.gouv.mc/Action-Gouvernementale/Coronavirus-Covid-19/Actualites/'#
cowidev.vax.incremental.monaco.main()[source]#

cowidev.vax.incremental.mongolia#

cowidev.vax.incremental.mongolia._check_vaccine_names(vaccine_names: list)[source]#
cowidev.vax.incremental.mongolia._get_vaccine_names(data: dict, translate: bool = False) list[source]#
cowidev.vax.incremental.mongolia.add_totals(ds: Series) Series[source]#
cowidev.vax.incremental.mongolia.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.mongolia.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.mongolia.main()[source]#
cowidev.vax.incremental.mongolia.parse_data(data: dict) Series[source]#
cowidev.vax.incremental.mongolia.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.mongolia.read(source: str) Series[source]#

cowidev.vax.incremental.montenegro#

cowidev.vax.incremental.montenegro.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.montenegro.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.montenegro.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.montenegro.main()[source]#
cowidev.vax.incremental.montenegro.parse_data(data: dict) Series[source]#
cowidev.vax.incremental.montenegro.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.montenegro.read(source: str) Series[source]#

cowidev.vax.incremental.morocco#

class cowidev.vax.incremental.morocco.Morocco[source]#

Bases: object

_parse_data(soup: BeautifulSoup) Series[source]#
export()[source]#
location: str = 'Morocco'#
pipe_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'http://www.covidmaroc.ma/pages/Accueilfr.aspx'#
cowidev.vax.incremental.morocco.main()[source]#

cowidev.vax.incremental.myanmar#

class cowidev.vax.incremental.myanmar.Myanmar[source]#

Bases: object

_base_url = 'https://mohs.gov.mm'#

Extracts link and date from relevant element.

_get_relevant_element(soup: BeautifulSoup) NavigableString[source]#

Gets the relevant element in news feed.

_get_text_from_url(url: str) str[source]#

Extracts text from the url.

_num_max_pages = 3#
_parse_data(soup: BeautifulSoup) tuple[source]#

Get data from the source page.

_parse_date_from_element(elem: NavigableString) str[source]#

Gets date from relevant element.

Gets link from relevant element.

_parse_metrics(text: str) dict[source]#

Gets metrics from news text.

_url_subdirectory = '/main/content/new/list?pagesize=9&pagenumber='#
export()[source]#

Exports data to csv.

location = 'Myanmar'#
pipe_location(data_series: Series) Series[source]#

Pipes location.

pipe_vaccine(data_series: Series) Series[source]#

Pipes vaccine names.

pipeline(data_series: Series) Series[source]#

Pipeline for data.

read() Series[source]#

Reads data from source.

regex = {'date': '(\\d{1,2}\\-\\d{1,2}\\-20\\d{2})', 'people_fully_vaccinated': '(\\d+) \\(Cumulative fully vaccinated people\\)', 'people_vaccinated': '(\\d+) \\(Cumulative vaccinated people\\)', 'title': 'ကိုဗစ်-19 ရောဂါ ကာကွယ်ဆေး ထိုးနှံပြီးစီးမှု', 'total_vaccinations': '(\\d+) \\(Cumulative vaccinated doses\\)'}#
cowidev.vax.incremental.myanmar.main()[source]#

cowidev.vax.incremental.nepal#

class cowidev.vax.incremental.nepal.Nepal[source]#

Bases: CountryVaxBase

_parse_data(links: dict) tuple[source]#

Parses data from link.

_parse_date(link: str) str[source]#

Get date from link.

_parse_metrics(ds: Series) tuple[source]#

Parses metrics from data.

_parse_pdf_table() Series[source]#

Extract table from pdf url

export()[source]#

Exports data to CSV.

extract_clean_count_series(df: DataFrame, regex: str) list[source]#

Extracts clean count from series using regex.

location: str = 'Nepal'#
pipe_date(df: DataFrame) DataFrame[source]#

Pipes date for main data.

pipe_location(df: DataFrame) DataFrame[source]#

Pipes location for main data.

pipe_manufacturer_date(df: DataFrame) DataFrame[source]#

Pipes date for manufacturer data.

pipe_manufacturer_location(df: DataFrame) DataFrame[source]#

Pipes location for manufacturer data.

pipe_manufacturer_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names for manufacturer data.

pipe_source(df: DataFrame) DataFrame[source]#

Pipes source for main data.

pipe_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names for main data.

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for main data.

pipeline_manufacturer(df: DataFrame) DataFrame[source]#

Pipeline for manufacturer data.

read() tuple[source]#

Reads data from source.

regex: dict = {'count': '\\d+', 'date': '(\\d{1,2}\\-\\d{1,2}\\-20\\d{2})'}#
source_url: dict = {'api': 'https://covid19.mohp.gov.np/covid/api/ministryrelease', 'base': 'https://covid19.mohp.gov.np/covid/englishSituationReport/'}#
source_url_ref: dict = {'main': 'https://covid19.mohp.gov.np/situation-report'}#
cowidev.vax.incremental.nepal.main()[source]#

cowidev.vax.incremental.north_macedonia#

cowidev.vax.incremental.north_macedonia.connect_parse_data(source: str) Series[source]#
cowidev.vax.incremental.north_macedonia.enrich_date(ds: Series) Series[source]#
cowidev.vax.incremental.north_macedonia.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.north_macedonia.enrich_source(ds: Series, source: str) Series[source]#
cowidev.vax.incremental.north_macedonia.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.north_macedonia.main()[source]#
cowidev.vax.incremental.north_macedonia.pipeline(ds: Series, source: str) Series[source]#
cowidev.vax.incremental.north_macedonia.read(source: str) Series[source]#

cowidev.vax.incremental.northern_cyprus#

cowidev.vax.incremental.northern_cyprus.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.northern_cyprus.enrich_source(ds: Series, source: str) Series[source]#
cowidev.vax.incremental.northern_cyprus.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.northern_cyprus.main()[source]#
cowidev.vax.incremental.northern_cyprus.parse_data(soup: BeautifulSoup) Series[source]#
cowidev.vax.incremental.northern_cyprus.pipeline(ds: Series, source: str) Series[source]#
cowidev.vax.incremental.northern_cyprus.read(source: str) Series[source]#

cowidev.vax.incremental.paho#

class cowidev.vax.incremental.paho.PAHO[source]#

Bases: object

_download_csv(driver, option: str, filename: str)[source]#
_download_path = '/tmp'#
_get_downloaded_filename()[source]#
_parse_data(url: str)[source]#
_parse_date(driver)[source]#
columns_mapping = {'1st additional dose': 'total_boosters_1', '2nd additional dose': 'total_boosters_2', 'Country code': 'country_code', 'Country/ Territory': 'location', 'First dose': 'dose_1', 'Second dose': 'dose_2', 'Single dose': 'single_dose', 'Total doses': 'total_vaccinations', 'date': 'date'}#
export()[source]#
increment_countries(df: DataFrame)[source]#
pipe_check_columns(df: DataFrame) DataFrame[source]#
pipe_check_countries(df: DataFrame) DataFrame[source]#
pipe_filter_countries(df: DataFrame) DataFrame[source]#

Get rows from selected countries.

pipe_metadata(df: DataFrame) DataFrame[source]#
pipe_metrics(df: DataFrame) DataFrame[source]#
pipe_rename_columns(df: DataFrame) DataFrame[source]#
pipe_vaccine(df: DataFrame) DataFrame[source]#
pipeline(df: DataFrame) DataFrame[source]#
read()[source]#
source_url = 'https://ais.paho.org/imm/IM_DosisAdmin-Vacunacion.asp'#
cowidev.vax.incremental.paho.main()[source]#

cowidev.vax.incremental.pakistan#

class cowidev.vax.incremental.pakistan.Pakistan[source]#

Bases: CountryVaxBase

_parse_data(soup)[source]#
export()[source]#
location: str = 'Pakistan'#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read()[source]#
source_url = 'https://covid.gov.pk/vaccine-details'#
source_url_ref = 'https://covid.gov.pk/vaccine-details'#
cowidev.vax.incremental.pakistan.main()[source]#

cowidev.vax.incremental.philippines#

class cowidev.vax.incremental.philippines.Philippines[source]#

Bases: CountryVaxBase

_get_json_data(soup: BeautifulSoup) dict[source]#

Gets JSON from Soup

_parse_data(json_data: dict) dict[source]#

Parses data from JSON

_parse_date(json_data: dict) str[source]#

Parses date from JSON

_parse_metrics(json_data: dict) dict[source]#

Parses metrics from JSON

_print_entitiy_ids()[source]#
date_entity: str = '01ff1d02-e027-4eee-9de1-5e19f7fdd5e8'#
export()[source]#

Exports data to CSV

location: str = 'Philippines'#
metric_entities: dict = {'people_fully_vaccinated': 'a4c3cd88-85f7-44ea-b48f-1c97618f1e48', 'people_vaccinated': '32ae0a31-293e-48ea-91cf-e4518496d6bdc9fe1875-6600-4e45-ae6d-a48d9b8a1eae', 'total_boosters': '2c3bf26f-5d71-4793-b6de-4f6b0f1735626ba8b43e-d7c0-4f38-91ff-61d7d8770432', 'total_vaccinations': '4b9e949e-2990-4349-aa85-5aff8501068a'}#
pipe_boosters(ds: Series) Series[source]#

Pipes source url

pipe_location(ds: Series) Series[source]#

Pipes location

pipe_source(ds: Series) Series[source]#

Pipes source url

pipe_vaccine(ds: Series) Series[source]#

Pipes vaccine names

pipeline(ds: Series) Series[source]#

Pipeline for data

read() Series[source]#

Reada data from source

source_url: str = 'https://e.infogram.com/_/yFVE69R1WlSdqY3aCsBF'#
source_url_ref: str = 'https://news.abs-cbn.com/spotlight/multimedia/infographic/03/23/21/philippines-covid-19-vaccine-tracker'#
cowidev.vax.incremental.philippines.main()[source]#

cowidev.vax.incremental.poland#

class cowidev.vax.incremental.poland.Poland[source]#

Bases: object

columns_rename: dict = {'DAWKA_1_SUMA': 'people_vaccinated', 'Data': 'date', 'SZCZEPIENIA_SUMA': 'total_vaccinations', 'dawka_3_suma': 'dose_3', 'dawka_przypominajaca': 'total_boosters', 'zaszczepieni_finalnie': 'people_fully_vaccinated'}#
export()[source]#

Generalized.

location: str = 'Poland'#
pipe_boosters(ds: Series) Series[source]#
pipe_date(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_rename_columns(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url: str = 'https://services-eu1.arcgis.com/zk7YlClTgerl62BY/ArcGIS/rest/services/widok_global_szczepienia_actual/FeatureServer/0/query'#
source_url_ref: str = 'https://www.gov.pl/web/szczepimysie/raport-szczepien-przeciwko-covid-19'#
cowidev.vax.incremental.poland.main()[source]#

cowidev.vax.incremental.qatar#

class cowidev.vax.incremental.qatar.Qatar[source]#

Bases: CountryVaxBase

connect_parse_data() Series[source]#
enrich_location(ds: Series) Series[source]#
enrich_source(ds: Series) Series[source]#
enrich_vaccine(ds: Series) Series[source]#
export()[source]#
location: str = 'Qatar'#
pipeline(ds: Series) Series[source]#
read() Series[source]#
source_url = 'https://covid19.moph.gov.qa/EN/Pages/Vaccination-Program-Data.aspx'#
cowidev.vax.incremental.qatar.main()[source]#

cowidev.vax.incremental.russia#

class cowidev.vax.incremental.russia.Russia[source]#

Bases: object

export()[source]#
cowidev.vax.incremental.russia.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.russia.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.russia.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.russia.main()[source]#
cowidev.vax.incremental.russia.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.russia.read(source: str) Series[source]#

cowidev.vax.incremental.saint_lucia#

cowidev.vax.incremental.saint_lucia.connect_parse_data(source: str) Series[source]#
cowidev.vax.incremental.saint_lucia.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.saint_lucia.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.saint_lucia.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.saint_lucia.main()[source]#
cowidev.vax.incremental.saint_lucia.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.saint_lucia.read(source: str) Series[source]#

cowidev.vax.incremental.serbia#

class cowidev.vax.incremental.serbia.Serbia[source]#

Bases: object

_parse_date(soup: BeautifulSoup) str[source]#
_parse_metrics(soup: BeautifulSoup)[source]#
export()[source]#
pipe_location(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
cowidev.vax.incremental.serbia.main()[source]#

cowidev.vax.incremental.south_africa#

class cowidev.vax.incremental.south_africa.SouthAfrica[source]#

Bases: CountryVaxBase

_build_df(metrics: list, date: str) tuple[source]#

Builds DataFrame from metrics.

_parse_data() tuple[source]#

Parses the data from the source.

_parse_date(date: str) str[source]#

Parses the date from the list.

_payload(payload_var: str = 'Pfizer_first') dict[source]#

Request payload for the source.

Parameters:

payload_var (str): A key in payload_vars (e.g. “Pfizer_first”)

Returns:

dict: A payload for the request

export()[source]#

Exports data to CSV.

property headers#

Headers for the request

location: str = 'South Africa'#
payload_vars = {'Johnson_booster': {'Entity': 'Boosters Measures', 'Name': 'Boosters Measures.Booster Totals', 'Property': 'Booster Totals', 'Value': "'Johnson & Johnson'"}, 'Johnson_first': {'Entity': 'Vaccinations Administered Measures', 'Name': 'Vaccinations Administered Measures.First Dose Total', 'Property': 'First Dose Total', 'Value': "'Johnson & Johnson'"}, 'Pfizer_booster': {'Entity': 'Boosters Measures', 'Name': 'Boosters Measures.Booster Totals', 'Property': 'Booster Totals', 'Value': "'Pfizer'"}, 'Pfizer_first': {'Entity': 'Vaccinations Administered Measures', 'Name': 'Vaccinations Administered Measures.First Dose Total', 'Property': 'First Dose Total', 'Value': "'Pfizer'"}, 'Pfizer_second': {'Entity': 'Vaccinations Administered Measures', 'Name': 'Vaccinations Administered Measures.Second Dose Total', 'Property': 'Second Dose Total', 'Value': "'Pfizer'"}}#
pipe_manufacturer_location(df: DataFrame) DataFrame[source]#

Pipes location for manufacturer data.

pipe_manufacturer_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names for manufacturer data.

pipe_vaccine(df: DataFrame) DataFrame[source]#

Pipes vaccine names for main data.

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for main data.

pipeline_manufacturer(df: DataFrame) DataFrame[source]#

Pipeline for manufacturer data.

read() tuple[source]#

Reads the data from the source

source_url: str = 'https://wabi-west-europe-api.analysis.windows.net/public/reports/querydata?synchronous=true'#
source_url_ref: str = 'https://sacoronavirus.co.za/latest-vaccine-statistics/'#
cowidev.vax.incremental.south_africa.main()[source]#

cowidev.vax.incremental.spain#

class cowidev.vax.incremental.spain.Spain[source]#

Bases: CountryVaxBase

_check_vaccine_names(df: DataFrame)[source]#
_date_field_raw = 'Fecha de la última vacuna registrada (2)'#
_get_source_url(dt_str)[source]#
_get_vaccine_names(df: DataFrame, translate: bool = False)[source]#
_max_days_back = 20#
_parse_data(last_update: str)[source]#

Goes back _max_days_back days to retrieve data.

Does not exceed last_update date.

_parse_data_day(df: DataFrame, source: str) Series[source]#

Parse data for a single day

export()[source]#
location: str = 'Spain'#
pipe_date(df: DataFrame) DataFrame[source]#
pipe_location(df: DataFrame) DataFrame[source]#
pipeline(df: DataFrame) DataFrame[source]#
read(last_update: str) Series[source]#
vaccine_mapping = {'AstraZeneca': 'Oxford/AstraZeneca', 'Janssen': 'Johnson&Johnson', 'Moderna': 'Moderna', 'Pfizer': 'Pfizer/BioNTech'}#
cowidev.vax.incremental.spain.main()[source]#

cowidev.vax.incremental.sri_lanka#

class cowidev.vax.incremental.sri_lanka.SriLanka[source]#

Bases: CountryVaxBase

_fix_header(df)[source]#
_get_elems() list[source]#
_parse_data(date, elem) dict[source]#
export()[source]#
parse_metrics_from_pdf(pdf_path)[source]#
read() DataFrame[source]#
cowidev.vax.incremental.sri_lanka.main()[source]#

cowidev.vax.incremental.suriname#

cowidev.vax.incremental.suriname.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.suriname.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.suriname.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.suriname.main()[source]#
cowidev.vax.incremental.suriname.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.suriname.read(source: str) Series[source]#

cowidev.vax.incremental.taiwan#

class cowidev.vax.incremental.taiwan.Taiwan[source]#

Bases: object

_parse_date(soup) str[source]#
_parse_stats(df: DataFrame) int[source]#
_parse_table(url_pdf: str)[source]#
_parse_tables_all(url_pdf: str) int[source]#
_parse_vaccines(df: DataFrame) str[source]#
export()[source]#
location = 'Taiwan'#
parse_data(df: DataFrame, soup)[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
property source_data_url#
source_url = 'https://www.cdc.gov.tw'#
vaccines_mapping = {'AstraZeneca': 'Oxford/AstraZeneca', 'BioNTech': 'Pfizer/BioNTech', 'Moderna': 'Moderna', 'Moderna 雙價\rBA.1': 'Moderna', 'Novavax': 'Novavax', '高端': 'Medigen'}#
cowidev.vax.incremental.taiwan.main()[source]#

cowidev.vax.incremental.thailand#

class cowidev.vax.incremental.thailand.Thailand[source]#

Bases: CountryVaxBase

_get_abailable_worksheets()[source]#
_parse_data() DataFrame[source]#

Parse metrics from source

export()[source]#

Export data to CSV

location: str = 'Thailand'#
pipe_date(df: DataFrame) DataFrame[source]#
pipe_metadata(df: DataFrame) DataFrame[source]#

Add metadata

pipe_metrics(df: DataFrame) DataFrame[source]#
pipe_vaccines(df: DataFrame) DataFrame[source]#

Add vaccine information

pipeline(df: DataFrame) DataFrame[source]#

Pipeline for data

read() DataFrame[source]#

Read data from source

source_url = 'https://public.tableau.com/views/SATCOVIDDashboard/1-dash-tiles-w'#
source_url_ref = 'https://ddc.moph.go.th/covid19-dashboard/'#
cowidev.vax.incremental.thailand.main()[source]#

cowidev.vax.incremental.turkey#

cowidev.vax.incremental.turkey.enrich_location(ds: Series) Series[source]#
cowidev.vax.incremental.turkey.enrich_source(ds: Series) Series[source]#
cowidev.vax.incremental.turkey.enrich_vaccine(ds: Series) Series[source]#
cowidev.vax.incremental.turkey.main()[source]#
cowidev.vax.incremental.turkey.parse_data(soup: BeautifulSoup) Series[source]#
cowidev.vax.incremental.turkey.parse_date(soup: BeautifulSoup) str[source]#
cowidev.vax.incremental.turkey.parse_metric(soup: BeautifulSoup, metric_name: str) int[source]#
cowidev.vax.incremental.turkey.pipeline(ds: Series) Series[source]#
cowidev.vax.incremental.turkey.read(source: str) Series[source]#

cowidev.vax.incremental.united_arab_emirates#

class cowidev.vax.incremental.united_arab_emirates.UnitedArabEmirates[source]#

Bases: object

_estimate_population(elem, total_vaccinations) Series[source]#
_parse_data() Series[source]#
_parse_date(driver) Series[source]#
_parse_people_fully_vaccinated(elem, population) Series[source]#
_parse_people_vaccinated(elem, population) Series[source]#
_parse_relative_metric(elem, class_name: str, regex: str)[source]#
_parse_total_vaccinations(elem) Series[source]#
export()[source]#
pipe_calculate_boosters(ds: Series) Series[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read() Series[source]#
cowidev.vax.incremental.united_arab_emirates.main()[source]#

cowidev.vax.incremental.vietnam#

class cowidev.vax.incremental.vietnam.Vietnam[source]#

Bases: object

Get the relevant URL from the source page.

_get_text_from_url(url: str) str[source]#

Extract text from URL.

_parse_data(soup: BeautifulSoup) dict[source]#

Get data from the source page.

_parse_date_from_text(text: str) str[source]#

Get date from text.

_parse_metrics(text: str) tuple[source]#

Get metrics from text.

base_url = 'https://covid19.gov.vn'#
export()[source]#

Export data to CSV.

location = 'Vietnam'#
pipe_location(ds: Series) Series[source]#

Pipe location.

pipe_vaccine(ds: Series) Series[source]#

Pipe vaccine name.

pipeline(ds: Series) Series[source]#

Pipeline for data.

read() Series[source]#

Read data from source.

regex = {'date': '(\\d{2}/\\d{2}/\\d{4})', 'metrics': {'adolescent': '\\+ Số liều tiêm cho trẻ từ 12\\-17 tuổi ([\\d\\.]+) liều: Mũi 1 ([\\d\\.]+) liều; Mũi 2 ([\\d\\.]+) liều.', 'adult': 'Số liều tiêm cho người từ 18 tuổi trở lên ([\\d\\.]+) liều: Mũi 1 ([\\d\\.]+) liều; Mũi 2 ([\\d\\.]+) liều; Mũi 3 ([\\d\\.]+) liều; Mũi bổ sung ([\\d\\.]+) liều; Mũi nhắc lại lần 1 ([\\d\\.]+) liều; Mũi nhắc lại lần 2 ([\\d\\.]+) liều.', 'all': 'Trong ngày (\\d\\d?\\/\\d) (?:[\\d\\.]+) liều vacc?cine phòng COVID-19 đ?ược tiêm(?: chủng)?. Như vậy, tổng số liều (?:vắc xin|vaccine) đã được tiêm ([\\d\\.]+) liều, trong đó:', 'children': '\\+ Số liều tiêm cho trẻ từ 5\\-11 tuổi ([\\d\\.]+) liều: Mũi 1 ([\\d\\.]+) liều; Mũi 2 ([\\d\\.]+) liều.'}, 'title': 'Ngày'}#
source_url = 'https://covid19.gov.vn/ban-tin-covid-19.htm'#
cowidev.vax.incremental.vietnam.main()[source]#

cowidev.vax.incremental.who#

class cowidev.vax.incremental.who.WHO[source]#

Bases: CountryVaxBase

_map_vaccines_func(row) tuple[source]#

Replace vaccine names and create column only_2_doses.

export()[source]#
increment_countries(df: DataFrame)[source]#
location: str = 'WHO'#
pipe_add_boosters(df: DataFrame) DataFrame[source]#
pipe_calculate_metrics(df: DataFrame) DataFrame[source]#
pipe_checks(df: DataFrame) DataFrame[source]#
pipe_filter_entries(df: DataFrame) DataFrame[source]#

Get valid entries:

  • Countries not coming from OWID (avoid loop)

  • Rows with total_vaccinations >= people_vaccinated >= people_fully_vaccinated

pipe_map_vaccines(df: DataFrame) DataFrame[source]#

Based on the list of known vaccines, identifies whether each country is using only 2-dose vaccines or also some 1-dose vaccines. This determines whether people_fully_vaccinated can be calculated as total_vaccinations - people_vaccinated. Vaccines check

pipe_rename_countries(df: DataFrame) DataFrame[source]#
pipe_vaccine_checks(df: DataFrame) DataFrame[source]#
pipeline(df: DataFrame)[source]#
read() DataFrame[source]#
rename_columns = {'COUNTRY': 'location', 'DATE_UPDATED': 'date', 'VACCINES_USED': 'vaccine'}#
source_url = 'https://covid19.who.int/who-data/vaccination-data.csv'#
source_url_ref = 'https://covid19.who.int/'#
cowidev.vax.incremental.who.main()[source]#

cowidev.vax.incremental.zambia#

class cowidev.vax.incremental.zambia.Zambia[source]#

Bases: CountryVaxBase

export()[source]#
pipe_location(ds: Series) Series[source]#
pipe_source(ds: Series) Series[source]#
pipe_vaccine(ds: Series) Series[source]#
pipeline(ds: Series) Series[source]#
read()[source]#
cowidev.vax.incremental.zambia.main()[source]#