cowidev.cmd.vax.generate#

cowidev.cmd.vax.generate.generate#

cowidev.cmd.vax.generate.utils#

class cowidev.cmd.vax.generate.utils.DatasetGenerator(logger)[source]#

Bases: object

_add_interpolate(df: DataFrame)[source]#

_add_interpolate_base(df: DataFrame, colname_cum: str, colname_diff: str) → DataFrame[source]#

_add_smoothed(df: DataFrame) → DataFrame[source]#

_cp_locations_files()[source]#

_get_aggregate(df, agg_name, included_locs, excluded_locs)[source]#

_get_aggregate_new(df, agg_name, included_locs, excluded_locs)[source]#

add_booster_share(df: DataFrame) → DataFrame[source]#

property column_names_int#

export(df_automated: DataFrame, df_locations: DataFrame, df_vaccinations: DataFrame, df_manufacturer: DataFrame, df_age: DataFrame, json_vaccinations: dict, df_grapher: DataFrame, df_manufacturer_grapher: DataFrame, df_age_grapher: DataFrame)[source]#

get_population(df_subnational: DataFrame) → DataFrame[source]#

pipe_age_checks(df: DataFrame) → DataFrame[source]#

pipe_age_flatten(df: DataFrame) → DataFrame[source]#

pipe_age_group(df: DataFrame) → DataFrame[source]#

pipe_age_output(df: DataFrame) → DataFrame[source]#

pipe_age_partly(df: DataFrame) → DataFrame[source]#

pipe_age_pivot(df: DataFrame) → DataFrame[source]#

pipe_aggregates(df: DataFrame) → DataFrame[source]#

pipe_capita(df: DataFrame) → DataFrame[source]#

pipe_daily_vaccinations(df: DataFrame) → DataFrame[source]#: Get daily vaccinations.

pipe_drop_columns(df: DataFrame) → DataFrame[source]#

pipe_grapher(df: DataFrame, date_ref: datetime = datetime.datetime(2020, 1, 21, 0, 0), fillna: bool = False, fillna_0: bool = True) → DataFrame[source]#

pipe_interpolate(df: DataFrame) → DataFrame[source]#: Interpolate missing dates.

pipe_manufacturer_add_eu(df: DataFrame) → DataFrame[source]#

pipe_manufacturer_checks(df: DataFrame) → DataFrame[source]#

pipe_manufacturer_filter_dates(df: DataFrame) → DataFrame[source]#

pipe_manufacturer_pivot(df: DataFrame) → DataFrame[source]#

pipe_manufacturer_select_cols(df: DataFrame) → DataFrame[source]#

pipe_metrics_format(df: DataFrame) → DataFrame[source]#

pipe_smoothed(df: DataFrame) → DataFrame[source]#

pipe_to_int(df: DataFrame) → DataFrame[source]#

pipe_vaccinations_csv(df: DataFrame, df_iso: DataFrame) → DataFrame[source]#

pipe_vaccinations_json(df: DataFrame) → list[source]#

pipe_vax_checks(df: DataFrame) → DataFrame[source]#

pipeline_age(df: DataFrame) → DataFrame[source]#

pipeline_age_grapher(df: DataFrame) → DataFrame[source]#

pipeline_automated(df: DataFrame) → DataFrame[source]#: Generate DataFrame for automated states.

pipeline_locations(df_vax: DataFrame, df_metadata: DataFrame, df_iso: DataFrame) → DataFrame[source]#: Generate DataFrame for locations.

pipeline_manufacturer(df: DataFrame) → DataFrame[source]#

pipeline_manufacturer_grapher(df: DataFrame) → DataFrame[source]#

pipeline_vaccinations(df: DataFrame) → DataFrame[source]#

run()[source]#

cowidev.cmd.vax.generate.utils.build_aggregates()[source]#