cowidev.grapher.db.utils

cowidev.grapher.db.utils.db

cowidev.grapher.db.utils.db.connection()[source]

cowidev.grapher.db.utils.db_imports

Update gapher database.

Update vaccination by age data.

cowidev.grapher.db.utils.db_imports.chunk_df(df, n)[source]

Yield successive n-sized chunks from data frame.

cowidev.grapher.db.utils.db_imports.import_dataset(dataset_name, namespace, csv_path, default_variable_display, source_name, slack_notifications=True, unit='', unit_short=None)[source]
cowidev.grapher.db.utils.db_imports.print_err(*args, **kwargs)[source]

cowidev.grapher.db.utils.db_utils

class cowidev.grapher.db.utils.db_utils.DBUtils(cursor)[source]

Bases: object

__fetch_parent_tag(name)
__get_cached_entity_id(name)
associate_dataset_tag(dataset_id, tag_id)[source]
execute(*args, **kwargs)[source]
execute_until_empty(*args, **kwargs)[source]
fetch_many(*args, **kwargs)[source]
fetch_one(*args, **kwargs)[source]
fetch_one_or_none(*args, **kwargs)[source]
get_counts()[source]
get_entity_cache()[source]
get_or_create_entity(name)[source]
insert_one(*args, **kwargs)[source]
note_import(import_type, import_notes, import_state)[source]
prefill_entity_cache(names)[source]
touch_variable(var_id)[source]
upsert_dataset(name, namespace, user_id, tag_id=None, description='This is a dataset imported by the automated fetcher')[source]
upsert_many(query, tuples)[source]
upsert_one(*args, **kwargs)[source]
upsert_parent_tag(name)[source]
upsert_source(name, description, dataset_id)[source]
upsert_tag(name, parent_id)[source]
upsert_variable(name, code, unit, short_unit, source_id, dataset_id, description=None, timespan='', coverage='', display={})[source]
exception cowidev.grapher.db.utils.db_utils.NotOne[source]

Bases: ValueError

cowidev.grapher.db.utils.db_utils.normalize_entity_name(entity_name)[source]

cowidev.grapher.db.utils.slack_client

cowidev.grapher.db.utils.slack_client.send_error(channel, title, message=None, trace=None)[source]
cowidev.grapher.db.utils.slack_client.send_success(channel, title, message=None, trace=None)[source]
cowidev.grapher.db.utils.slack_client.send_warning(channel, title, message=None, trace=None)[source]

cowidev.grapher.db.utils.utils

cowidev.grapher.db.utils.utils.export_timestamp(filename)[source]