src/dirbs/cli/importer.py
def subscribers_registration_list(ctx, config, statsd, logger, run_id, conn, metadata_conn, command,
                                  metrics_root, metrics_run_root, input_file, disable_historic_check,
                                  delta, disable_delta_adds_check, disable_delta_removes_check,
                                  disable_delta_updates_check):
    """Import the Subscribers Registration List data found in INPUT into the PostgreSQL database."""
    params = _common_import_params(ctx)
    subscribers_tc = config.subscribers_threshold_config
    params.update({'perform_historic_check': not disable_historic_check,
                   'delta': delta,
                   'perform_delta_adds_check': not disable_delta_adds_check,
                   'perform_delta_removes_check': not disable_delta_removes_check,
                   'import_size_variation_percent': subscribers_tc.import_size_variation_percent,
                   'import_size_variation_absolute': subscribers_tc.import_size_variation_absolute,
                   'perform_delta_updates_check': not disable_delta_updates_check})
    with importer_factory.make_data_importer('subscribers_registration_list', input_file, config, statsd, conn,
                                             metadata_conn, run_id, metrics_root,
                                             metrics_run_root, **params) as importer:
        importer.import_data()
Import the Subscribers Registration List data found in INPUT into the PostgreSQL database.
Import the Subscribers Registration List data found in INPUT into the PostgreSQL database.
Import the Subscribers Registration List data found in INPUT into the PostgreSQL database .
def subscribers_registration_list(ctx, config, statsd, logger, run_id, conn, metadata_conn, command,
                                  metrics_root, metrics_run_root, input_file, disable_historic_check,
                                  delta, disable_delta_adds_check, disable_delta_removes_check,
                                  disable_delta_updates_check):
    params = _common_import_params(ctx)
    subscribers_tc = config.subscribers_threshold_config
    params.update({'perform_historic_check': not disable_historic_check,
                   'delta': delta,
                   'perform_delta_adds_check': not disable_delta_adds_check,
                   'perform_delta_removes_check': not disable_delta_removes_check,
                   'import_size_variation_percent': subscribers_tc.import_size_variation_percent,
                   'import_size_variation_absolute': subscribers_tc.import_size_variation_absolute,
                   'perform_delta_updates_check': not disable_delta_updates_check})
    with importer_factory.make_data_importer('subscribers_registration_list', input_file, config, statsd, conn,
                                             metadata_conn, run_id, metrics_root,
                                             metrics_run_root, **params) as importer:
        importer.import_data()
def subscribers_registration_list ( ctx , config , statsd , logger , run_id , conn , metadata_conn , command , metrics_root , metrics_run_root , input_file , disable_historic_check , delta , disable_delta_adds_check , disable_delta_removes_check , disable_delta_updates_check ) : params = _common_import_params ( ctx ) subscribers_tc = config . subscribers_threshold_config params . update ( { 'perform_historic_check' : not disable_historic_check , 'delta' : delta , 'perform_delta_adds_check' : not disable_delta_adds_check , 'perform_delta_removes_check' : not disable_delta_removes_check , 'import_size_variation_percent' : subscribers_tc . import_size_variation_percent , 'import_size_variation_absolute' : subscribers_tc . import_size_variation_absolute , 'perform_delta_updates_check' : not disable_delta_updates_check } ) with importer_factory . make_data_importer ( 'subscribers_registration_list' , input_file , config , statsd , conn , metadata_conn , run_id , metrics_root , metrics_run_root , ** params ) as importer : importer . import_data ( )
Import the Subscribers Registration List data found in INPUT into the PostgreSQL database.
Import the Subscribers Registration List data found in INPUT into the PostgreSQL database .
"""Import the Subscribers Registration List data found in INPUT into the PostgreSQL database."""
ctx
config
statsd
logger
run_id
conn
metadata_conn
command
metrics_root
metrics_run_root
input_file
disable_historic_check
delta
disable_delta_adds_check
disable_delta_removes_check
disable_delta_updates_check