cowidev.grapher.db.utils

cowidev.grapher.db.utils.db

cowidev.grapher.db.utils.db.connection()

cowidev.grapher.db.utils.db_imports

Update gapher database.

Update vaccination by age data.

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

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)

cowidev.grapher.db.utils.db_imports.print_err(*args, **kwargs)

cowidev.grapher.db.utils.db_utils

class cowidev.grapher.db.utils.db_utils.DBUtils(cursor)

Bases: object

__fetch_parent_tag(name)

__get_cached_entity_id(name)

associate_dataset_tag(dataset_id, tag_id)

execute(*args, **kwargs)

execute_until_empty(*args, **kwargs)

fetch_many(*args, **kwargs)

fetch_one(*args, **kwargs)

fetch_one_or_none(*args, **kwargs)

get_counts()

get_entity_cache()

get_or_create_entity(name)

insert_one(*args, **kwargs)

note_import(import_type, import_notes, import_state)

prefill_entity_cache(names)

touch_variable(var_id)

upsert_dataset(name, namespace, user_id, tag_id=None, description='This is a dataset imported by the automated fetcher')

upsert_many(query, tuples)

upsert_one(*args, **kwargs)

upsert_parent_tag(name)

upsert_source(name, description, dataset_id)

upsert_tag(name, parent_id)

upsert_variable(name, code, unit, short_unit, source_id, dataset_id, description=None, timespan='', coverage='', display={})

exception cowidev.grapher.db.utils.db_utils.NotOne

Bases: ValueError

cowidev.grapher.db.utils.db_utils.normalize_entity_name(entity_name)

cowidev.grapher.db.utils.slack_client

cowidev.grapher.db.utils.slack_client.send_error(channel, title, message=None, trace=None)

cowidev.grapher.db.utils.slack_client.send_success(channel, title, message=None, trace=None)

cowidev.grapher.db.utils.slack_client.send_warning(channel, title, message=None, trace=None)

cowidev.grapher.db.utils.utils

cowidev.grapher.db.utils.utils.export_timestamp(filename)