当前位置:网站首页>airflow db init 报错
airflow db init 报错
2022-08-02 22:25:00 【schwert_ddd】
报错一:
[2022-08-01 11:34:38,224] {manager.py:763} WARNING - No user yet created, use flask fab command to do it.
INFO [alembic.runtime.migration] Running upgrade a13f7613ad25 -> 97cdd93827b8, Add queued_at column to dagrun table
INFO [alembic.runtime.migration] Running upgrade 97cdd93827b8 -> 092435bf5d12, Add max_active_runs column to dagmodel table
INFO [alembic.runtime.migration] Running upgrade 092435bf5d12 -> ccde3e26fe78, Add index on state, dag_id for queued dagrun
INFO [alembic.runtime.migration] Running upgrade ccde3e26fe78 -> 83f031fd9f1c, improve mssql compatibility
INFO [alembic.runtime.migration] Running upgrade 83f031fd9f1c -> e9304a3141f0, make xcom pkey columns non-nullable
INFO [alembic.runtime.migration] Running upgrade e9304a3141f0 -> 30867afad44a, Rename concurrency column in dag table to max_active_tasks
INFO [alembic.runtime.migration] Running upgrade 30867afad44a -> 54bebd308c5f, Add trigger table and task info
INFO [alembic.runtime.migration] Running upgrade 54bebd308c5f -> 142555e44c17, Add data_interval_[start|end] to DagModel and DagRun.
INFO [alembic.runtime.migration] Running upgrade 142555e44c17 -> 7b2661a43ba3, TaskInstance keyed to DagRun
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/airflow/models/crypto.py", line 86, in get_fernet
[Fernet(fernet_part.encode('utf-8')) for fernet_part in fernet_key.split(',')]
File "/usr/local/lib/python3.6/site-packages/airflow/models/crypto.py", line 86, in <listcomp>
[Fernet(fernet_part.encode('utf-8')) for fernet_part in fernet_key.split(',')]
File "/usr/local/lib64/python3.6/site-packages/cryptography/fernet.py", line 35, in __init__
"Fernet key must be 32 url-safe base64-encoded bytes."
ValueError: Fernet key must be 32 url-safe base64-encoded bytes.报错二:
File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 112, in create_default_connections
extra='''{"account_url": "<ACCOUNT_URL>"}''',
File "<string>", line 4, in __init__
File "/usr/local/lib64/python3.6/site-packages/sqlalchemy/orm/state.py", line 433, in _initialize_instance
manager.dispatch.init_failure(self, args, kwargs)
File "/usr/local/lib64/python3.6/site-packages/sqlalchemy/util/langhelpers.py", line 70, in __exit__
with_traceback=exc_tb,
File "/usr/local/lib64/python3.6/site-packages/sqlalchemy/util/compat.py", line 182, in raise_
raise exception
File "/usr/local/lib64/python3.6/site-packages/sqlalchemy/orm/state.py", line 430, in _initialize_instance
return manager.original_init(*mixed[1:], **kwargs)
File "/usr/local/lib/python3.6/site-packages/airflow/models/connection.py", line 146, in __init__
self.extra = extra
File "<string>", line 1, in __set__
File "/usr/local/lib/python3.6/site-packages/airflow/models/connection.py", line 272, in set_extra
fernet = get_fernet()
File "/usr/local/lib/python3.6/site-packages/airflow/models/crypto.py", line 90, in get_fernet
raise AirflowException(f"Could not create Fernet object: {value_error}")
airflow.exceptions.AirflowException: Could not create Fernet object: Incorrect padding原因是airflow.cfg缺少了fernet_key没填写导致
# Secret key to save connection passwords in the db
fernet_key =
具体操作如下:
1 把airflow的数据库表清空
2 生成一个fernet_key,用于airflow db init阶段使用(确保有cryptography的包)
python3 -c "from cryptography.fernet import Fernet; print(Fernet.generate_key().decode())"
3 填入上面生成的key,保存
fernet_key = xxxxx
4 重新运行airflow db init,报错解决
边栏推荐
- IDEA 重复代码的黄色波浪线取消设置
- 同样月薪6K,为什么同事跳槽月薪翻倍,而你只涨了1000?
- Image recognition from zero to write DNF script key points
- go context 包
- Towards a General Purpose CNN for Long Range Dependencies in ND
- CodeTON Round 2 A - D
- CWE4.8:2022年危害最大的25种软件安全问题
- No-code development platform form styling steps introductory course
- 买母婴产品先来京东“券民空间站”抢券!大牌好物低至5折
- 【学习笔记】博弈论
猜你喜欢
随机推荐
一个很少见但很有用的SQL功能
如何通过开源数据库管理工具 DBeaver 连接 TDengine
采用QT进行OpenGL开发(三)着色器编程
TDengine 在中天钢铁 GPS、 AIS 调度中的落地
threejs 动态调整相机位置,使相机正好能看到对象
go context 包
today‘s task
工业元宇宙的价值和发展
牛客刷题:数组排序
CWE4.8:2022年危害最大的25种软件安全问题
无代码开发平台数据ID入门教程
1 - vector R language self-study
IDO预售代币合约系统开发技术说明及源码分析
【UE5 骨骼动画】全形体IK导致Two Bone IK只能斜着移动,不能平移
创建型模式 - 简单工厂模式StaticFactoryMethod
严格反馈非线性系统基于事件触发的自抗扰预设有限时间跟踪控制
【C语言】带头双向循环链表(list)详解(定义、增、删、查、改)
WAF WebShell Trojan free to kill
记一次mysql查询慢的优化历程
Auto.js实现朋友圈自动点赞









