Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Put shutdown process in subsets of Stage 5, Run Bulk Loader

Table of Contents
Overview

...

Stage NumberStageCategorySummaryEnvironmentIterationsEstimated Person TimeEstimated Computer Time
1Import and parse reference dataset (Optional)ParsingThis optional step in the Bulk Loader process is to cross check an address for a match in a reference data set. If a source address is found in the reference dataset the address makes it to the next step. If not found the address is put aside in an exclusion set for later review.

Python 3

PostgreSQL / pgAdmin

Once per Bulk Loader process1 hour10 minutes
2Import, parse and filter source datasetParsingImport the dataset destined for the EAS. Parse and filter the set.

Python 3

PostgreSQL / pgAdmin

Once per Bulk Loader process90 minutes15 minutes

3

Geocode and filterGeocodingGeocode the set and filter further based on geocoder score and status.ArcMapOnce per Bulk Loader process1 hour 5 minutes
4Export full set (single batch) or subset (multiple batches)GeocodingFor large datasets, create one of many subsets that will be run through the Bulk Loader in many batches.ArcMapOne or more batches for each Bulk Loader process30 minutes per batch5 minutes per batch
5Bulk Load batch (full set or subset)Bulk LoadingRun each subset batch through the Bulk Loader.

EAS <environment>(+)

PostgreSQL / pgAdmin

One or more batches for each Bulk Loader process1 hour per batch5 minutes per batch
6Extract resultsBulk LoadingExtract and archive the list of addresses that were added to the EAS . Also archive the unique EAS 'change request id' associated with this batch. Also archive the addresses that were rejected by the Bulk Loader in this batch.PostgreSQL / pgAdminOne or more batches for each Bulk Loader process1 hour per batchseconds

...

Anchor
stage1
stage1
Stage 1 Import and parse reference dataset (Optional)

This optional stage is run once per Bulk Loader process. This stage can be skipped if the reference dataset is already available or if the optional 'filter by reference' step is skipped.

...

Anchor
stage3
stage3
Stage 3 
Geocode and filter

  •  

    Step 3.1 - Geocode source dataset

...

Anchor
stage4
stage4
Stage 4 
Export full set (single batch) or subset (multiple batches)

Note
titleA Note about Batches

Stages 4, 5 and 6 can be run one time with the results from Stage 3, or they can be run in multiple batches of subsets.

A major consideration of when to run the full set at once versus in batches is the number of records being Bulk Loaded.

The size of each Bulk Loader operation affects the following aspects of the EAS:

  • The disk space consumed by the database server
  • The EAS user interface section that lists addresses loaded in a given Bulk Loader operation
  • The weekly email attachment listing new addresses added to the EAS

For medium-to-large datasets (input sets with over 1000 records) it is recommended to run the process on a development server and assess the implications of the operation. Where appropriate, perform the Bulk Loading process in batches over several days or weeks.

The remaining steps will document one example iteration of a multi-batch process.

...

Anchor
stage5
stage5
Stage 5 
Run the Bulk Loader

...

...

(info) For a complete set of steps and background about the Bulk Loader, see also Running the Bulk Loader, a page dedicated to its input, operation and results.

  •  

    Step 5.1 - Bulk Loader Preparation

  1. Transfer the bulkload.shp shapefile from previous step to an EAS automation machine, <environment>_AUTO.

    • Substitute <environment> with one of the relevant environments: SF_DEV, SF_QA, SF_PROD, SD_PROD.

  2. Copy the shapefile to the folder C:\apps\eas_automation\app_data\data\bulkload_shapefile.

  3. Connect to the database, <environment>_DB, and clear any leftover records from previous Bulk Loader batches.

    1. TRUNCATE bulkloader.address_extract, bulkloader.blocks_nearest;

    2. VACUUM FULL ANALYZE bulkloader.address_extract;

    3. VACUUM FULL ANALYZE bulkloader.blocks_nearest;

  4. Make note of EAS record counts before the Bulk Loading operation.


    Code Block
    languagesql
    firstline1
    titleRecord Counts
    linenumberstrue
    SELECT schemaname,relname,n_live_tup FROM pg_stat_user_tables ORDER BY schemaname,relname,n_live_tup


  •  

    Step 5.2 - Halt Services (production only)

    1. Place EAS web application into maintenance mode

    2. Turn off the replication server

    3. Turn off downstream database propagation service(s)


  •  

    Step 5.3 - Backup Database

  1. Make a backup of the EAS database
  •  

    Step 5.4 - Run Bulk Loader

  1. Open a command prompt and change folders:
    • cd C:\apps\eas_automation\automation\src

  2. Run the step to stage the address records:

    • python job.py --job stage_bulkload_shapefile --env SF_DEV --action EXECUTE --v

  3. Run the step to bulk load the address records:

    • python job.py --job bulkload --env SF_DEV --action EXECUTE --v

  4. (info) To calculate the time it took to run the Bulk Loader look at the timestamps in the output or use a stopwatch or clock to time the operation.


  •  

    Step 5.3 - 
    Anchor
    analysis
    analysis
    Analysis

  1. Query and make note of totals in the bulkloader.address_extract table. The results here will be used to cross check the results in the next stage.
    1. Count/view new base addresses added to the EAS.


      Code Block
      languagesql
      firstline1
      titleCount/view new base addresses
      linenumberstrue
      SELECT COUNT(*) FROM bulkloader.address_extract WHERE NOT (street_segment_id IS NULL)
      
      SELECT * FROM bulkloader.address_extract WHERE NOT (street_segment_id IS NULL)


    2. Count/view unit addresses (some were already there, some are new)

      Code Block
      languagesql
      firstline1
      titleCount/view unit addresses
      linenumberstrue
      SELECT COUNT(*) FROM bulkloader.address_extract WHERE NOT (address_id IS NULL)
      
      SELECT * FROM bulkloader.address_extract WHERE NOT (address_id IS NULL)


  2. Make note of EAS record counts after the Bulk Load operation.


    Code Block
    languagesql
    firstline1
    titleRecord Counts
    linenumberstrue
    SELECT schemaname,relname,n_live_tup FROM pg_stat_user_tables ORDER BY schemaname,relname,n_live_tup


    • A comparison of 'before' and 'after' record counts will indicate the number of new base addresses added to the table `public.address_base` and the number of new addresses and units added to the table `public.addresses`.

    1. (info) See dedicated Bulk Loader page, Running the Bulk Loader, for more analysis options.

Anchor
stage6
stage6
Stage 6 
Extract results

  •  

    Step 6.1 - Archive exceptions

...