| 核心对象 | DataSource / Batch / Validator / Expectation Suite |
|---|---|
| 典型用法 | 对 DataFrame 或 SQL 结果做期望检查 |
| 输出 | 校验结果与 Data Docs 报告 |
| 集成 | Airflow、Spark、dbt 等 |
DataFrame 校验示例
DataFrame 校验示例
import pandas as pd
import great_expectations as gx
df = pd.read_csv("data/orders.csv")
context = gx.get_context()
validator = context.sources.pandas_default.read_dataframe(df)
validator.expect_column_values_to_not_be_null("order_id")
validator.expect_column_values_to_be_unique("order_id")
result = validator.validate()
print(result.success)GX 不同大版本的 API 差异较大(上下文与数据源写法多次调整),升级前对照官方迁移指南改代码。