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]¶