使用 Great Expectations 的数据质量入门
Davina Moossazadeh
Data Scientist
条件化期望 —— 针对数据子集的期望
原因:有些变量取决于其他变量的取值
例如:
review_count 为 0 时,列 star_rating 的值必须为 0 的期望通过增加两个参数可将数据集期望转换为条件化期望:
row_conditioncondition_parserrow_condition 语法的字符串在 pandas 中实现条件化期望时,该参数必须设为 "pandas"
expectation = gx.Expect...(
**kwargs,
condition_parser="pandas",
row_condition=...
)
df["foo"] == 'Two Two'
df["foo"].notNull()
df["foo"] <= datetime.date(2023, 3, 13)
(df["foo"] < 5) & (df["foo"] >= 3.14)
df["foo"].str.startswith("bar")
row_condition'foo == "Two Two"'
'foo.notNull()'
'foo <= datetime.date(2023, 3, 13)'
'(foo > 5) & (foo <= 3.14)'
'foo > 5 and foo <= 3.14'
'foo.str.startswith("bar")'
在{{1}}内不要用单引号
row_condition="foo=='Two Two'" row_condition='foo=="Two Two"' 
不要在{{3}}内换行
row_condition="""
foo=="Two Two"
"""
row_condition='foo=="Two Two"' 
expectation = gx.expectations.\
ExpectColumnValuesToBeBetween(
column="price_usd",
max_value=10,
)
validation_results = batch.validate(
expect=expectation
)
print(validation_results.success)
False
expectation = gx.expectations.\
ExpectColumnValuesToBeBetween(
column="price_usd",
max_value=10,
condition_parser='pandas',
row_condition='mark_price_usd < 10',
)
validation_results = batch.validate(
expect=expectation
)
print(validation_results.success)
True
使用 Great Expectations 的数据质量入门