修改数据库为mysql
sql_alchemy_conn = mysql://root:123@localhost:3066/airflow?charset=utf8
修改celery的broker为redis
broker_url = redis://localhost:6379/0# rabbitmq: amqp://guest:guest@localhost:5672//celery_result_backend = redis://localhost:6379/0
添加user
import airflowfrom airflow import models, settingsfrom airflow.contrib.auth.backends.password_auth import PasswordUseruser = PasswordUser(models.User())user.username = 'test_user'user.email = 'test_user@example.com'user.password = 'test_user'session = settings.Session()session.add(user)session.commit()session.close()exit()