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