开始使用免费开始使用

对任务函数进行单元测试

对 Airflow 代码进行单元测试的关键在于:将 @task 函数中的业务逻辑提取到独立的 Python 函数中,这样无需运行 Airflow 也能测试。您的团队已经在 dags/data_cleaning.py 中完成了这一点,编写了 clean_record 函数,用于去除姓名两侧的空白并将邮箱转换为小写。

接下来,您将为此函数补全单元测试。

本练习是课程的一部分

使用 Airflow 构建数据流水线

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习