Airflow添加用户登录

[webserver]
authenticate = True
auth_backend = airflow.contrib.auth.backends.password_auth

python

import airflow
from airflow import models, settings
from airflow.contrib.auth.backends.password_auth import PasswordUser

user = PasswordUser(models.User())
user.username = ‘usertest1‘
user.email = ‘usertest1@163.com‘
user.password = ‘usertest1‘
user.superuser = 1 //赋予管理员权限，如果是普通用户就不需要这个

session = settings.Session()
session.add(user)
session.commit()
session.close()
exit()

root@airflowdataxv2-copy-dfd9d84f4-9hr9b:/usr/local/airflow# python
Python 3.7.5 (default, Nov 15 2019, 02:58:08) 
[GCC 6.3.0 20170516] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import airflow
/usr/local/lib/python3.7/site-packages/airflow/configuration.py:226: FutureWarning: The task_runner setting in [core] has the old default value of ‘BashTaskRunner‘. This value has been changed to ‘StandardTaskRunner‘ in the running config, but please update your config before Apache Airflow 2.0.
  FutureWarning
/usr/local/lib/python3.7/site-packages/airflow/configuration.py:606: DeprecationWarning: Specifying both AIRFLOW_HOME environment variable and airflow_home in the config file is deprecated. Please use only the AIRFLOW_HOME environment variable and remove the config file entry.
  warnings.warn(msg, category=DeprecationWarning)
/usr/local/lib/python3.7/site-packages/airflow/utils/sqlalchemy.py:40: DeprecationWarning: get: Accessing configuration method ‘get‘ directly from the configuration module is deprecated. Please access the configuration from the ‘configuration.conf‘ object via ‘conf.get‘
  tz = conf.get("core", "default_timezone")
/usr/local/lib/python3.7/site-packages/airflow/utils/timezone.py:30: DeprecationWarning: get: Accessing configuration method ‘get‘ directly from the configuration module is deprecated. Please access the configuration from the ‘configuration.conf‘ object via ‘conf.get‘
  tz = conf.get("core", "default_timezone")
/usr/local/lib/python3.7/site-packages/airflow/config_templates/airflow_local_settings.py:65: DeprecationWarning: The elasticsearch_host option in [elasticsearch] has been renamed to host - the old setting has been used, but please update your config.
  ELASTICSEARCH_HOST = conf.get(‘elasticsearch‘, ‘HOST‘)
/usr/local/lib/python3.7/site-packages/airflow/config_templates/airflow_local_settings.py:67: DeprecationWarning: The elasticsearch_log_id_template option in [elasticsearch] has been renamed to log_id_template - the old setting has been used, but please update your config.
  ELASTICSEARCH_LOG_ID_TEMPLATE = conf.get(‘elasticsearch‘, ‘LOG_ID_TEMPLATE‘)
/usr/local/lib/python3.7/site-packages/airflow/config_templates/airflow_local_settings.py:69: DeprecationWarning: The elasticsearch_end_of_log_mark option in [elasticsearch] has been renamed to end_of_log_mark - the old setting has been used, but please update your config.
  ELASTICSEARCH_END_OF_LOG_MARK = conf.get(‘elasticsearch‘, ‘END_OF_LOG_MARK‘)
[2020-04-08 17:41:17,838] {settings.py:252} INFO - settings.configure_orm(): Using pool settings. pool_size=5, max_overflow=10, pool_recycle=1800, pid=21338
>>> from airflow import models, settings
>>> from airflow.contrib.auth.backends.password_auth import PasswordUser
>>> user = PasswordUser(models.User())
>>> user.username = ‘usertest‘
>>> user.email = ‘usertest@163.com‘
>>> user.password = ‘usertest‘
>>> session = settings.Session()
>>> session.add(user)
>>> session.commit()
>>> user = PasswordUser(models.User())
>>> user.username = ‘usertest1‘
>>> user.email = ‘usertest1@163.com‘
>>> user.password = ‘usertest1‘
>>> session = settings.Session()
>>> session.add(user)
>>> session.commit()
>>> session.close()
>>> exit()