Cleans data, best to be used as a part of initial preprocessor
Project description
refineryframe
The goal of the package is to simplify life for data scientists, that have to deal with imperfect raw data. The package suppose to detect and clean unexpected values, while doubling as safeguard in production code based on predifined conditions that arise from business assumptions or any other source. The package is well suited to be an initial preprocessing step in ml pipelines situated between data gathering and training/scoring steps.
Developed by Kyrylo Mordan (c) 2023
Installation
Install refineryframe
via pip with
pip install refineryframe
Feature List
refineryframe.refiner.Refiner.check_col_names_types
- checks if a given dataframe has the same column names as keys in a given dictionary and those columns have the same types as items in the dictionary.refineryframe.refiner.Refiner.check_date_format
- checks if the values in the datetime columns of the input dataframe have the expected 'YYYY-MM-DD' format.refineryframe.refiner.Refiner.check_date_range
- checks if dates are in expected ranges.refineryframe.refiner.Refiner.check_duplicates
- checks for duplicates in a pandas DataFrame.refineryframe.refiner.Refiner.check_inf_values
- counts the inf values in each column of a pandas DataFrame.refineryframe.refiner.Refiner.check_missing_types
- takes a DataFrame and a dictionary of missing types as input, and searches for any instances of these missing types in each column of the DataFrame.refineryframe.refiner.Refiner.check_missing_values
- counts the number of NaN, None, and NaT values in each column of a pandas DataFrame.refineryframe.refiner.Refiner.check_numeric_range
- checks if numeric values are in expected ranges.refineryframe.refiner.Refiner.detect_unexpected_values
- detects unexpected values in a pandas DataFrame.refineryframe.refiner.Refiner.get_type_dict_from_dataframe
- returns a dictionary or string representation of a dictionary containing the data types of each column in the given pandas DataFrame.refineryframe.refiner.Refiner.replace_unexpected_values
- replaces unexpected values in a pandas DataFrame with missing types.refineryframe.refiner.Refiner.set_type_dict
- changes the data types of the columns in the given DataFrame based on a dictionary of intended data types.refineryframe.refiner.Refiner.set_types
- changes the data types of the columns in the given DataFrame based on a dictionary of intended data types.
Package usage example
import os
import sys
import numpy as np
import pandas as pd
import logging
sys.path.append(os.path.dirname(sys.path[0]))
from refineryframe.refiner import Refiner
Creating example data (exceptionally messy dataframe)
df = pd.DataFrame({
'num_id' : [1, 2, 3, 4, 5],
'NumericColumn': [1, -np.inf, np.inf,np.nan, None],
'NumericColumn_exepted': [1, -996, np.inf,np.nan, None],
'NumericColumn2': [None, None, 1,None, None],
'NumericColumn3': [1, 2, 3, 4, 5],
'DateColumn': pd.date_range(start='2022-01-01', periods=5),
'DateColumn2': [pd.NaT,pd.to_datetime('2022-01-01'),pd.NaT,pd.NaT,pd.NaT],
'DateColumn3': ['2122-05-01',
'2022-01-01',
'2021-01-01',
'1000-01-09',
'1850-01-09'],
'CharColumn': ['Fół', None, np.nan, 'nót eXpęćTęd', '']
})
df
<style scoped>
.dataframe tbody tr th:only-of-type {
vertical-align: middle;
}
.dataframe tbody tr th {
vertical-align: top;
}
.dataframe thead th {
text-align: right;
}
</style>
num_id | NumericColumn | NumericColumn_exepted | NumericColumn2 | NumericColumn3 | DateColumn | DateColumn2 | DateColumn3 | CharColumn | |
---|---|---|---|---|---|---|---|---|---|
0 | 1 | 1.0 | 1.0 | NaN | 1 | 2022-01-01 | NaT | 2122-05-01 | Fół |
1 | 2 | -inf | -996.0 | NaN | 2 | 2022-01-02 | 2022-01-01 | 2022-01-01 | None |
2 | 3 | inf | inf | 1.0 | 3 | 2022-01-03 | NaT | 2021-01-01 | NaN |
3 | 4 | NaN | NaN | NaN | 4 | 2022-01-04 | NaT | 1000-01-09 | nót eXpęćTęd |
4 | 5 | NaN | NaN | NaN | 5 | 2022-01-05 | NaT | 1850-01-09 |
Defining specification for the dataframe
MISSING_TYPES = {'date_not_delivered': '1850-01-09',
'date_other_missing_type': '1850-01-08',
'numeric_not_delivered': -999,
'character_not_delivered': 'missing'}
unexpected_exceptions = {
"col_names_types": "NONE",
"missing_values": ["NumericColumn_exepted"],
"missing_types": "NONE",
"inf_values": "NONE",
"date_format": "NONE",
"duplicates": "ALL",
"date_range": "NONE",
"numeric_range": "NONE"
}
replace_dict = {-996 : -999,
"1000-01-09": "1850-01-09"}
Initializing Refiner class
tns = Refiner(dataframe = df,
replace_dict = replace_dict,
loggerLvl = logging.DEBUG,
unexpected_exceptions_duv = unexpected_exceptions)
function for detecting column types
tns.get_type_dict_from_dataframe()
{'num_id': 'int64',
'NumericColumn': 'float64',
'NumericColumn_exepted': 'float64',
'NumericColumn2': 'float64',
'NumericColumn3': 'int64',
'DateColumn': 'datetime64[ns]',
'DateColumn2': 'datetime64[ns]',
'DateColumn3': 'object',
'CharColumn': 'object'}
adding expected types
types_dict_str = {'num_id' : 'int64',
'NumericColumn' : 'float64',
'NumericColumn_exepted' : 'float64',
'NumericColumn2' : 'float64',
'NumericColumn3' : 'int64',
'DateColumn' : 'datetime64[ns]',
'DateColumn2' : 'datetime64[ns]',
'DateColumn3' : 'datetime64[ns]',
'CharColumn' : 'object'}
Check independent conditions
tns.check_missing_types()
tns.check_missing_values()
tns.check_inf_values()
tns.check_col_names_types()
tns.check_date_format()
tns.check_duplicates()
tns.check_numeric_range()
WARNING:Refiner:Column DateColumn3: (1850-01-09) : 1 : 20.00%
WARNING:Refiner:Column NumericColumn: (NA) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn_exepted: (NA) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn2: (NA) : 4 : 80.00%
WARNING:Refiner:Column DateColumn2: (NA) : 4 : 80.00%
WARNING:Refiner:Column CharColumn: (NA) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn: (INF) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn_exepted: (INF) : 1 : 20.00%
WARNING:Refiner:Column DateColumn2 has non-date values or unexpected format.
moulding types
tns.set_types(type_dict = types_dict_str)
tns.get_type_dict_from_dataframe()
{'num_id': 'int64',
'NumericColumn': 'float64',
'NumericColumn_exepted': 'float64',
'NumericColumn2': 'float64',
'NumericColumn3': 'int64',
'DateColumn': 'datetime64[ns]',
'DateColumn2': 'datetime64[ns]',
'DateColumn3': 'datetime64[ns]',
'CharColumn': 'object'}
Using the main function to detect unexpected values
tns.detect_unexpected_values(earliest_date = "1920-01-01",
latest_date = "DateColumn3")
DEBUG:Refiner:=== checking column names and types
DEBUG:Refiner:=== checking for presence of missing values
WARNING:Refiner:Column CharColumn: (NA) : 2 : 40.00%
WARNING:Refiner:Column DateColumn2: (NA) : 4 : 80.00%
WARNING:Refiner:Column NumericColumn: (NA) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn2: (NA) : 4 : 80.00%
DEBUG:Refiner:=== checking for presence of missing types
WARNING:Refiner:Column DateColumn3: (1850-01-09) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn_exepted: (-999) : 1 : 20.00%
DEBUG:Refiner:=== checking propper date format
WARNING:Refiner:Column DateColumn2 has non-date values or unexpected format.
DEBUG:Refiner:=== checking expected date range
WARNING:Refiner:** Not all dates in DateColumn are later than DateColumn3
WARNING:Refiner:Column DateColumn : future date : 4 : 80.00%
DEBUG:Refiner:=== checking for presense of inf values in numeric colums
WARNING:Refiner:Column NumericColumn: (INF) : 2 : 40.00%
WARNING:Refiner:Column NumericColumn_exepted: (INF) : 1 : 20.00%
DEBUG:Refiner:=== checking expected numeric range
WARNING:Refiner:Percentage of passed tests: 50.00%
tns.duv_score
0.5
Using function to replace unexpected values with missing types
tns.replace_unexpected_values(numeric_lower_bound = "NumericColumn3",
numeric_upper_bound = 4,
earliest_date = "1920-01-02",
latest_date = "DateColumn2",
unexpected_exceptions = {"irregular_values": "NONE",
"date_range": "DateColumn",
"numeric_range": "NONE",
"capitalization": "NONE",
"unicode_character": "NONE"})
DEBUG:Refiner:=== replacing missing values in category cols with missing types
DEBUG:Refiner:=== replacing all upper case characters with lower case
DEBUG:Refiner:=== replacing character unicode to latin
DEBUG:Refiner:=== replacing missing values in date cols with missing types
DEBUG:Refiner:=== replacing missing values in numeric cols with missing types
DEBUG:Refiner:=== replacing values outside of expected date range
DEBUG:Refiner:=== replacing values outside of expected numeric range
DEBUG:Refiner:** Usable values in the dataframe: 44.44%
DEBUG:Refiner:** Uncorrected data quality score: 32.22%
DEBUG:Refiner:** Corrected data quality score: 52.57%
tns.dataframe.dtypes
num_id object
NumericColumn float64
NumericColumn_exepted float64
NumericColumn2 float64
NumericColumn3 int64
DateColumn datetime64[ns]
DateColumn2 datetime64[ns]
DateColumn3 datetime64[ns]
CharColumn object
dtype: object
Use complex targeted conditions
unexpected_conditions = {
'1': {
'description': 'Replace numeric missing with with zero',
'group': 'regex_columns',
'features': r'^Numeric',
'query': "{col} < 0",
'warning': True,
'set': 0
},
'2': {
'description': "Clean text column from '-ing' endings and 'not ' beginings",
'group': 'regex clean',
'features': ['CharColumn'],
'query': [r'ing', r'^not.'],
'warning': False,
'set': ''
},
'3': {
'description': "Detect/Replace numeric values in certain column with zeros if > 2",
'group': 'multicol mapping',
'features': ['NumericColumn3'],
'query': '{col} > 2',
'warning': True,
'set': 0
},
'4': {
'description': "Replace strings with values if some part of the string is detected",
'group': 'string check',
'features': ['CharColumn'],
'query': f"CharColumn.str.contains('cted', regex = True)",
'warning': False,
'set': 'miss'
}
}
- to detect unexpected values
tns.detect_unexpected_values(unexpected_conditions = unexpected_conditions)
DEBUG:Refiner:=== checking column names and types
DEBUG:Refiner:=== checking for presence of missing values
DEBUG:Refiner:=== checking for presence of missing types
WARNING:Refiner:Column CharColumn: (missing) : 3 : 60.00%
WARNING:Refiner:Column DateColumn2: (1850-01-09) : 4 : 80.00%
WARNING:Refiner:Column DateColumn3: (1850-01-09) : 4 : 80.00%
WARNING:Refiner:Column NumericColumn: (-999) : 4 : 80.00%
WARNING:Refiner:Column NumericColumn_exepted: (-999) : 4 : 80.00%
WARNING:Refiner:Column NumericColumn2: (-999) : 5 : 100.00%
WARNING:Refiner:Column NumericColumn3: (-999) : 1 : 20.00%
DEBUG:Refiner:=== checking propper date format
DEBUG:Refiner:=== checking expected date range
DEBUG:Refiner:=== checking for presense of inf values in numeric colums
DEBUG:Refiner:=== checking expected numeric range
DEBUG:Refiner:=== checking additional cons
DEBUG:Refiner:Replace numeric missing with with zero
WARNING:Refiner:Replace numeric missing with with zero :: 1
DEBUG:Refiner:Detect/Replace numeric values in certain column with zeros if > 2
WARNING:Refiner:Detect/Replace numeric values in certain column with zeros if > 2 :: 2
WARNING:Refiner:Percentage of passed tests: 75.00%
- to replace unecpected values
tns.replace_unexpected_values(unexpected_conditions = unexpected_conditions)
DEBUG:Refiner:=== replacing missing values in category cols with missing types
DEBUG:Refiner:=== replacing all upper case characters with lower case
DEBUG:Refiner:=== replacing character unicode to latin
DEBUG:Refiner:=== replacing with additional cons
DEBUG:Refiner:Replace numeric missing with with zero
DEBUG:Refiner:Clean text column from '-ing' endings and 'not ' beginings
DEBUG:Refiner:Detect/Replace numeric values in certain column with zeros if > 2
DEBUG:Refiner:Replace strings with values if some part of the string is detected
DEBUG:Refiner:=== replacing missing values in date cols with missing types
DEBUG:Refiner:=== replacing missing values in numeric cols with missing types
DEBUG:Refiner:=== replacing values outside of expected date range
DEBUG:Refiner:=== replacing values outside of expected numeric range
DEBUG:Refiner:** Usable values in the dataframe: 82.22%
DEBUG:Refiner:** Uncorrected data quality score: 88.89%
DEBUG:Refiner:** Corrected data quality score: 97.53%
tns.dataframe
<style scoped>
.dataframe tbody tr th:only-of-type {
vertical-align: middle;
}
.dataframe tbody tr th {
vertical-align: top;
}
.dataframe thead th {
text-align: right;
}
</style>
num_id | NumericColumn | NumericColumn_exepted | NumericColumn2 | NumericColumn3 | DateColumn | DateColumn2 | DateColumn3 | CharColumn | |
---|---|---|---|---|---|---|---|---|---|
0 | 1 | 1.0 | 1.0 | 0.0 | 1 | 2022-01-01 | 1850-01-09 | 1850-01-09 | fol |
1 | 2 | 0.0 | 0.0 | 0.0 | 2 | 2022-01-02 | 2022-01-01 | 2022-01-01 | miss |
2 | 3 | 0.0 | 0.0 | 0.0 | 0 | 2022-01-03 | 1850-01-09 | 1850-01-09 | miss |
3 | 4 | 0.0 | 0.0 | 0.0 | 0 | 2022-01-04 | 1850-01-09 | 1850-01-09 | miss |
4 | 5 | 0.0 | 0.0 | 0.0 | 0 | 2022-01-05 | 1850-01-09 | 1850-01-09 | miss |
tns.detect_unexpected_values(unexpected_exceptions = {
"col_names_types": "NONE",
"missing_values": "NONE",
"missing_types": "ALL",
"inf_values": "NONE",
"date_format": "NONE",
"duplicates": "ALL",
"date_range": "NONE",
"numeric_range": "NONE"
})
DEBUG:Refiner:=== checking column names and types
DEBUG:Refiner:=== checking for presence of missing values
DEBUG:Refiner:=== checking propper date format
DEBUG:Refiner:=== checking expected date range
DEBUG:Refiner:=== checking for presense of inf values in numeric colums
DEBUG:Refiner:=== checking expected numeric range
Scores
print(f'duv_score: {tns.duv_score :.4}')
print(f'ruv_score0: {tns.ruv_score0 :.4}')
print(f'ruv_score1: {tns.ruv_score1 :.4}')
print(f'ruv_score2: {tns.ruv_score2 :.4}')
duv_score: 1.0
ruv_score0: 0.8222
ruv_score1: 0.8889
ruv_score2: 0.9753
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
refineryframe-0.0.9.tar.gz
(24.8 kB
view hashes)
Built Distribution
Close
Hashes for refineryframe-0.0.9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d5c5ca62b75d9439583615dde807627c590a18044a942ff867f3947badc360b2 |
|
MD5 | 0a6dcc9991b82d2baef7bdd3c1ada81c |
|
BLAKE2b-256 | 7d8bd95b9740355b0bc0779293b39ee5ae04049236452edff2de4e88d563d42b |