mapper-csv

Overview

These csv mapping tools help you map any csv file into json for loading into Senzing. It contains the following python scripts ...

The csv_analyzer.py script reads a csv, accumulating column statistics like percent populated, percent unique and top 5 values. It can also create either:
- a python script for standalone use based on the python_template.py below.
- a json mapping file for use with the csv_mapper.py below.
The python_template.py is the template for a customizable python module. Sometimes the number of transforms required to map a csv file warrant going straight to python. As a bonus, this module is portable in that it contains a mapping class that can be called from other transports. Sometimes, you want to test your mappings in a file, but implement it via a message queue.
The csv_mapper.py script reads a csv using a mapping file to turn it into senzing json.
The csv_functions.py and associated csv_functions.json are a set of functions used by the csv_mapper.

Having the csv_analyzer.py create a standalone python script is the recommended method as it adds more flexibility and is easier to customize when the raw csv data does not have direct mappings to Senzing attributes. While it does require some knowledge of python, it is not much more complicated than the json mapping file approach which does not.

Please refer back to the Generic entity specification for more information on what attributes you can use to map your data to Senzing and why you might choose attribute one over another.

Prerequisites

Python 3.6 or higher

Installation

Place the the following files on a directory of your choice:

Include the input, mappings and output subdirectories and files for the tutorial:

Tutorial

Follow these steps in order. First use the supplied file test_set1.csv. Then try it with one of your own files!

Run the analyzer

Execute the csv_analyzer script as follows to create a standalone python script based on the python template ... RECOMMENDED

python csv_analyzer.py \
  -i input/test_set1.csv \
  -o input/test_set1-analysis.csv \
  -p mappings/test_set1.py

or to create a mapping file for use with the csv_mapper.py (does not require knowledge of python for simple mappings)

python csv_analyzer.py \
  -i input/test_set1.csv \
  -o input/test_set1-analysis.csv \
  -m mappings/test_set1.map

The -i parameter is for the csv file you want to analyze.
The -o parameter is for the name of the file to write the statistics to. It is a csv file as well.
The -m parameter is for the name of the mapping file to create. You will later edit this file to map the csv to json using this method.
The -p parameter is for the name of the python module file to create. You will later edit this file to map the csv to json using this method.

Note: The csv analyzer use the csv module sniffer to determine the file delimiter for you. If you have problems with this, you can override the delimiter and even the file encoding.

The -d parameter can be used to set the csv column delimiter manually
The -e parameter can be used to set the encoding to something like latin-1 if needed

Note: Normally you would decide if you want a simple mapping with the -m parameter or a python module with the -p parameter. There is no need to do both. Non-python programmers can do simple mappings using the -m mapping file method. Python programmers will likley want to use the -p python module method as they have more complete control over the process.

Type "python csv_analyzer.py --help" For the additional parameters you can specify.

Review the statistics

Open the input/test_set1-analysis.csv in your favorite spreadsheet editor. The columns are ...

columnName - The name of the column.
recordCount - The number of records with a value in this column.
percentPopulated - The percent populated (recordCount/total record count).
uniqueCount - The number of unique values in this column.
uniquePercent - The unique percent (uniqueCount/recordCount).
topValue1-5 - The top 5 most used values. Shows the value with the number of records containing it in parenthesis.

The purpose of this analysis helps you to determine what columns to map in the file. For instance ...

Lets say the gender column seems to contain a date of birth and the date of birth column seems to contain the address line 1. In this case you may want to have the file re-generated as everything seems to have shifted!
Lets say you are hoping to to match on ssn plus name. But when you look at the SSN column statistics you find that it is only 10% populated. In this case you will want to find more values to map.
Lets say you want to use the SSN column to match and it is 100% populated. But it is only 10% unique meaning a lot of the records have the same SSN. This may be ok, but it certainly indicates that you are looking at a list of transactions rather than a list of entities.
Lets say you have last_name and first_name columns but the first_name column is completely blank and the top 5 last_name examples appear to have both last and first names! In this case you would want to map last_name to the Senzing NAME_FULL attribute and not map first name at all.

Python module tutorial

If using the python module approach, complete the following steps:

Review the mappings/test_set1.py. It was built by the csv_analyzer which incorporates the columns in the csv file into the python_template.py file. The next step is to edit that file to assign a data source, set the record ID and map the column values. The csv_analyzer stats are provided for each column so that you can see how populated each is and what the top 5 most used values look like.

Simple mappings

1. Assign a data source code

Change this:

        #--mandatory attributes
        json_data['DATA_SOURCE'] = '<supply>'

to this:

        #--mandatory attributes
        json_data['DATA_SOURCE'] = 'TEST'

2. Set the record ID to a unique value

change this:

        #--the record_id should be unique, remove this mapping if there is not one 
        json_data['RECORD_ID'] = '<remove_or_supply>'

to this:

        #--the record_id should be unique, remove this mapping if there is not one 
        json_data['RECORD_ID'] = raw_data['uniqueid']

3. Set the record type to person or organization

change this:

        #--record type is not mandatory, but should be PERSON or ORGANIATION
        #--json_data['RECORD_TYPE'] = 'PERSON'

to this:

        #--record type is not mandatory, but should be PERSON or ORGANIATION
        json_data['RECORD_TYPE'] = 'PERSON' if raw_data['type'] == 'individual' else 'ORGANIZATION'

While not strictly necessary, when there is an obvious mapping it should be used.

4. Comment out the uniqueid and type mappings

change these:

        json_data['uniqueid'] = raw_data['uniqueid']

        json_data['type'] = raw_data['type']

to these:

        # already mapped as record_id
        # json_data['uniqueid'] = raw_data['uniqueid']

        # already mapped as record_type
        # json_data['type'] = raw_data['type']

There is no need to map columns twice!

5. Map the name field

change this:

        json_data['name'] = raw_data['name']

to this:

        if json_data['RECORD_TYPE'] == 'PERSON':
            json_data['PRIMARY_NAME_FULL'] = raw_data['name']
        else:
            json_data['PRIMARY_NAME_ORG'] = raw_data['name']

See the "Attributes for names ..." chapter of the Generic entity specification for information on why it was mapped this way.

6. Map the next 3 columns to their appropriate Senzing attributes

change these:

        json_data['gender'] = raw_data['gender']
        json_data['dob'] = raw_data['dob']
        json_data['ssn'] = raw_data['ssn']

to these:

        json_data['GENDER'] = raw_data['gender']
        json_data['DATE_OF_BIRTH'] = raw_data['dob']
        json_data['SSN_NUMBER'] = raw_data['ssn']

7. Set the address type to business or primary

Add this before the addr1 column mapping code

        #--set the address type to business if an organization
        if json_data['RECORD_TYPE'] == 'ORGANIZATION':
            json_data['ADDR_TYPE'] = 'BUSINESS'
        else:
            json_data['ADDR_TYPE'] = 'PRIMARY'

See the "Special attribute types and labels" chapter of the Generic entity specification for information on why it was mapped this way.

8. Map the address columns to their appropriate Senzing attributes

change these:

        json_data['addr1'] = raw_data['addr1']
        json_data['city'] = raw_data['city']
        json_data['state'] = raw_data['state']
        json_data['zip'] = raw_data['zip']

to these:

        json_data['ADDR_LINE1'] = raw_data['addr1']
        json_data['ADDR_CITY'] = raw_data['city']
        json_data['ADDR_STATE'] = raw_data['state']
        json_data['ADDR_POSTAL_CODE'] = raw_data['zip']

9. Leave the remaining column mappings as is

These are the "Attributes for values that are not used for entity resolution" as described in the Generic entity specification

Running the python module standalone

Type the following to test the mapper standalone ...

python mappings/test_set1.py \
  -i input/test_set1.csv \
  -o output/test_set1.json \
  -l output/test_set1-stats.json

You will get the following output ...

9 rows processed, 9 rows written, completed in 0.0 minutes

Mapping stats written to output/test_set1-stats.json

You can then review the resulting json and mapping stats file to ensure everything is working as expected!

Advanced mapping functions

What if there are records you want to filter out?

Let's say you didn't want to send any records that didn't have a name. Add this code in the filter section ...

#--place any filters needed here
if not raw_data['name']:
    return None

What if there is not a unique key for a record in the file

There are 2 options:

Option 1 - use the row number

        json_data['RECORD_ID'] = input_row_num

input_row_num is computed for you and passed into the map() class

This is fine option if the file will never be reloaded

Option 2 - compute a record hash of the mapped fields

        #--place any calculations needed here

        #--compute a hash of the fields used for resolution to use as a record_id
        pii_attrs = ['name',
                     'gender',
                     'dob',
                     'ssn',
                     'addr1',
                     'city',
                     'state',
                     'zip']
        record_hash = self.compute_record_hash(raw_data, pii_attrs)

and then later in the code ...

        json_data['RECORD_ID'] = record_hash

The purpose of only including the fields used for resolution in the record_hash is so that any dates or status that may change will not create a duplicate record

This is the safest method if the file will ever be updated and reloaded!

What if you want to use an algorithm to determine if this is a person or an organization

In this tutorial, we will assume the type field is inaccurate and we will add our own function that determines whether the record represents an organization or person based on name tokens or presence of dob or ssn.

Step 1: Add the is_organization function just under the format_date function.

    #-----------------------------------
    def is_organization(self, raw_name, raw_dob, raw_ssn):
        #--if a dob or ssn was supplied its a person
        if raw_dob or raw_ssn or not raw_name:
            return False
        #--if organizational tokens exist, its an organization 
        prior_tokens = []
        for token in raw_name.replace('.',' ').replace(',',' ').replace('-',' ').upper().split():
            if token in self.variant_data['ORGANIZATION_TOKENS']:
                return True
            elif ' '.join(prior_tokens[-2:]) in self.variant_data['ORGANIZATION_TOKENS']:
                return True
            elif ' '.join(prior_tokens[-3:]) in self.variant_data['ORGANIZATION_TOKENS']:
                return True
            prior_tokens.append(token)
        return False

Step 2: Add the configuration for it to the load_reference_data() function.

        #--organization tokens
        self.variant_data['ORGANIZATION_TOKENS'] = []
        self.variant_data['ORGANIZATION_TOKENS'].append('COMPANY')
        self.variant_data['ORGANIZATION_TOKENS'].append('HOSPITAL')
        self.variant_data['ORGANIZATION_TOKENS'].append('CLINIC')
        self.variant_data['ORGANIZATION_TOKENS'].append('CITY OF')

Step 3: Call the is_organization() function in the calculations section

        #--place any calculations needed here

        #--use an algorithm to determine if a person or organization
        is_organization = self.is_organization(raw_data['name'], raw_data['dob'], raw_data['ssn'])

Step 4: Replace the record_type attribute based on the outcome

        # json_data['RECORD_TYPE'] = 'PERSON' if raw_data['type'] == 'individual' else 'ORGANIZATION'  #-commented out as un-reliable
        json_data['RECORD_TYPE'] = 'ORGANIZATION' if is_organization else 'PERSON'

And that's it! Most sources you hit will not need much clean-up and the only thing you really need to do is put the right value in the right attribute. But when the data is really messy, you may need to do some clean-up!

Mapping file tutorial

If using the mapping file approach, complete the following steps ...

Review the mappings/test_set1.map. It was built by the csv_analyzer based on the columns in the csv file.

Input section

The purpose of this section is to set the csv file delimiter and column headers.

"input": {
    "inputFileName": "input/test_set1.csv",
    "fieldDelimiter": ",",
    "columnHeaders": [
        "uniqueid",
        "name",
        "gender",
        ...

Calculations section

This is where you can transform the data in your csv file. Here you can execute python code to create new columns from old columns.

"calculations": [
      {"name_org": "rowData['name'] if rowData['type'] == 'company' else ''"},
      {"name_full": "rowData['name'] if rowData['type'] != 'company' else ''"},
      {"addr_type": "'BUSINESS' if rowData['type'] == 'company' else ''"}
],

The syntax is {"newcolumnName": "single line of python code"}. References to current column values use the rowData['columnName'] syntax. These calculations are executed in order which means that all the prior calculation's new column values are available to the later ones. Notice that the first calculation creates the "is_organization" value that is called by all the ones after it.

If the code you need to execute is more than a single line, create a function for it in the csv_functions.py script. Notice how the first calculation that creates is_organization calls the approriate csv_function.

The calculations above determine whether or not the name field should be mapped to name_org or name_full and if the address should be labled a "business" address. It is a best practice for organizations to have their name mapped as a name_org and their physical address to be labeled business.

Output section

The purpose of this section is to map the csv columns to valid Senzing json attributes as defined here ... https://senzing.zendesk.com/hc/en-us/articles/231925448-Generic-Entity-Specification

Occasionally, you will have a csv file that really contains multiple entities which should be presented to the Senzing engine in separate json messages.

"outputs": [                                <-- this is a list of output messages
    {
        "filter": "not rowData['name']",   <-- this is a record level filter

Simply duplicate the output structure as many times as you want. Each must have a data source, entity type, record ID and list of attributes.

Just like calculations above, the filter is a single line python expression referencing current record column values with the rowData['columnName'] syntax. The one above bypasses any csv record with an empty name field.

Step 1: Decide on a data source code, entity type and record_id for this data set. You can hard code values like "TEST" below or refer to csv columns in source input file using the pythonic notation for replacing data in strings "%(columnName)s"

"outputs": [
    {
        "filter": "not rowData['name']",      <-- add this filter to remove the blank record in the test file 
        "data_source": "TEST",                <-- use "TEST" here
        "record_type": "GENERIC",             <-- keep the default "GENERIC" here
        "record_id": "%(uniqueid)s",          <-- use uniqueid here as it the unique ID for each record in the file
        ...

Step 2: Then for each column, replace the attribute tag with the Senzing attribute of your choice. Please note you can delete any attributes you don't want or add any new attributes you have computed in the calculations section described below.

You may notice the statistics section supplied for each column by the csv_analyzer. While not required by the csv_mapper, it is included to help you decide on the appropriate mapping. For instance if this field was not populated or did not contain M and F as values, you may want to not map it at all or convert it in the calculations sectrion described below.

"attributes": [
    {
        "attribute": "<ignore>",            <--keep ignoring this as we used it as the record_id above
        "mapping": "%(uniqueid)s",
        "statistics": {
            "columnName": "uniqueid",
            "populated%": 100.0,
            "unique%": 100.0,
            ...
        }
    },
    {
        "attribute": "<ignore>",            <--keep ignoring this as it will not be used for resolution
        "mapping": "%(type)s",
        ...
    },
    {                                       <--add this whole attribute section to map the calculated field
        "attribute": "NAME_FULL",
        "mapping": "%(name_full)s"
    },
    {                                       <--add this whole attribute section to map the calculated field
        "attribute": "NAME_ORG",            
        "mapping": "%(name_org)s"
    },
    {
        "attribute": "<ignore>",            <--keep ignoring the name as we replace it with name_org or name_full
        "mapping": "%(name)s",
        ...
    },
    {
        "attribute": "<ignore>",            <--keep ignoring the gender as it is not populated with meaningful values
        "mapping": "%(gender)s",
        "statistics": {
            "columnName": "gender",
            "populated%": 100.0,
            "unique%": 11.11,
            "top5values": [
                "u (9)"
            ]
        }
    },
    {
        "attribute": "DATE_OF_BIRTH",       <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(dob)s",
        ...
    },
    {
        "attribute": "SSN_NUMBER",          <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(ssn)s",
        ...
    {                                       <--add this whole attribute section to map the calculated field
        "attribute": "ADDR_TYPE",         
        "mapping": "%(addr_type)s"
    },
    {
        "attribute": "ADDR_LINE1",          <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(addr1)s",
        ...
    },
    {
        "attribute": "ADDR_CITY",           <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(city)s",
        ...
    {
        "attribute": "ADDR_STATE",          <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(state)s",
        ...
    },
    {
        "attribute": "ADDR_POSTAL_CODE",    <--map this to a recognized attribute in the generic entity specification
        "mapping": "%(zip)s",
        ...
    }
    {
        "attribute": "important_date",      <--map this important value to a standardized name even though not used for resolution
        "mapping": "%(create_date)s",
        ...
    },
    {
        "attribute": "important_status",    <--map this important value to a standardized name even though not used for resolution
        "mapping": "%(status)s",
        ...
    },
    {
        "attribute": "<ignore>",            <--keep ignoring this as it may be too sensitive to store in Senzing
        "mapping": "%(value)s",
        ...
    }

Run the mapper with a mapping file

Execute the csv_mapper script as follows ...

python csv_mapper.py \
  -i input/test_set1.csv \
  -m mappings/test_set1.map \
  -o output/test_set1.json \
  -l output/test_set1-statistics.json

Processing input/test_set1.csv ...
 10 rows processed, 1 rows skipped, complete!               <--the header row was skipped

OUTPUT #0 ...
  8 rows written
  1 rows skipped                                            <--this was due to the empty name filter

 MAPPED ATTRIBUTES:                                         <--these are the attributes that will be used for resolution
  name_full.....................          4 50.0 %
  name_org......................          4 50.0 %
  date_of_birth.................          2 25.0 %
  ssn_number....................          2 25.0 %
  addr_type.....................          4 50.0 %
  addr_line1....................          8 100.0 %
  addr_city.....................          8 100.0 %
  addr_state....................          8 100.0 %
  addr_postal_code..............          8 100.0 %

 UNMAPPED ATTRIBUTES:                                       <--these are attributes you decided to keep that won't be used for resolution
  important_date................          8 100.0 %
  important_status..............          8 100.0 %

 COLUMNS IGNORED: 
  uniqueid, type, name, gender, value                       <--make sure you didn't intend to map these!

process completed!

The -i parameter is for the csv file you want to map into json. The -o parameter is for the name of the json records to. The -m parameter is for the name of the completed mapping file to use.

You will want to review the statistics it produces and make sure it makes sense to you ...

Do the mapped statistics make sense? Especially for calculated values such as name_org and name_full.
Should any of the unmapped attributes really be mapped? Maybe there is a typo.
Should any of the columns ignored be included?

Loading into Senzing

You must first update the Senzing configuration with any new data source codes, features or attributes you specified in your mapper. These can be added via the G2ConfigTool python script provided in the install.

The JSON files created by your mapper can be loaded into Senzing in various ways. If you have a docker or AWS setup, you can load them via the stream-producer or if you have a bare metal install you can load them via the G2Loader python script provided in the install.

Name		Name	Last commit message	Last commit date
Latest commit History 133 Commits
.github		.github
input		input
mappings		mappings
output		output
.gitignore		.gitignore
.project		.project
.pylintrc		.pylintrc
CHANGELOG.md		CHANGELOG.md
CODE_OF_CONDUCT.md		CODE_OF_CONDUCT.md
CONTRIBUTING.md		CONTRIBUTING.md
LICENSE		LICENSE
README.md		README.md
csv_analyzer.py		csv_analyzer.py
csv_functions.json		csv_functions.json
csv_functions.py		csv_functions.py
csv_mapper.py		csv_mapper.py
dependabot-approve-and-merge.yaml		dependabot-approve-and-merge.yaml
python_template.py		python_template.py

License

Senzing/mapper-csv

Folders and files

Latest commit

History

Repository files navigation

mapper-csv

Overview

Contents

Prerequisites

Installation

Tutorial

Run the analyzer

Review the statistics

Python module tutorial

Simple mappings

1. Assign a data source code

2. Set the record ID to a unique value

3. Set the record type to person or organization

4. Comment out the uniqueid and type mappings

5. Map the name field

6. Map the next 3 columns to their appropriate Senzing attributes

7. Set the address type to business or primary

8. Map the address columns to their appropriate Senzing attributes

9. Leave the remaining column mappings as is

Running the python module standalone

Advanced mapping functions

What if there are records you want to filter out?

What if there is not a unique key for a record in the file

Option 1 - use the row number

Option 2 - compute a record hash of the mapped fields

What if you want to use an algorithm to determine if this is a person or an organization

Step 1: Add the is_organization function just under the format_date function.

Step 2: Add the configuration for it to the load_reference_data() function.

Step 3: Call the is_organization() function in the calculations section

Step 4: Replace the record_type attribute based on the outcome

Mapping file tutorial

Input section

Calculations section

Output section

Run the mapper with a mapping file

Loading into Senzing

About

Topics

Resources

License

Code of conduct

Stars

Watchers

Forks

Releases 2

Contributors 6

Languages