airflow配置

修改数据库为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 airflow
from airflow import models, settings
from airflow.contrib.auth.backends.password_auth import PasswordUser
user = 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()