一、Airflow 安装
1. 安装 airflow
pip install apache-airflow==1.10.10
2. 指定 airflow 目录
export AIRFLOW_HOME=/home/airflow
3. 初始化数据库
airflow db init
在 airflow 的目录下会生成以下文件
4. 修改 airflow.cfg 文件，配置一些关键信息
dags_folder = /home/airflow/dags (扫描 DAG 目录)
base_log_folder = /home/airflow/logs （日志）
default_timezone = Asia/Shanghai (时区)
executor = LocalExecutor （执行器）
sql_alchemy_conn=mysql://username:pwd@ip:3306/schema （配置元数据库）
5. 启动
airflow webserver -D
airflow scheduler -D
二、代码环境搭建
idea 代码结构
operators 目录下的文件是自定义的插件，需要放到 airflow 的插件目录下:
/home/airflow/.local/lib/python2.7/site-packages/airflow/operators
在/home/airflow/tunnel_streaming/tools 目录下的文件：
资源评论
