登录Apache Airflow 2.1.3后出现dag.last_parsed_time列缺失报错如何解决?
错误原因
报错是Airflow元数据库表结构与当前运行的Airflow版本不匹配导致的:dag.last_parsed_time是Airflow 2.x版本dag表的必要字段,安装完成后未执行数据库迁移命令,会导致元数据表没有更新到对应版本的结构,访问时就会触发字段不存在的错误。
解决步骤
- 先停止所有正在运行的Airflow相关进程,包括webserver、scheduler、worker等
- 执行Airflow数据库迁移命令,自动同步元数据表结构到对应版本:
airflow db upgrade
- 迁移完成后如果之前创建的管理员用户异常丢失,可以重新执行用户创建命令:
airflow users create \ --role Admin \ --username <替换为你的用户名> \ --email <替换为你的邮箱> \ --firstname <替换为你的名字> \ --lastname <替换为你的姓氏>
- 重新启动Airflow webserver和scheduler服务,再次登录即可恢复正常
内容的提问来源于stack exchange,提问作者Faustina Leonita
相关产品推荐
相关产品推荐

