可以在AIRFLOW的配置文件中设置CSRF令牌来解决此问题。具体操作如下:
打开AIRFLOW的配置文件 airflow.cfg
找到以下配置项并取消注释:
#csrf_enabled = True #csrf_token_key = csrf_token
csrf_enabled = True csrf_token_key = my_csrf_token
from airflow import models from airflow.settings import Session
session = Session()
def my_view(): csrf_token = session.query(models.Variable).filter_by(key='my_csrf_token').first()
if csrf_token is None:
# handle missing CSRF token
elif request.form['csrf_token'] != csrf_token.val:
# handle invalid CSRF token
else:
# handle valid CSRF token
通过以上方法,就可以在AIRFLOW中使用CSRF会话令牌解决此问题。
上一篇:Airflow中清除任务
下一篇:Airflow中任务的粒度