我已经创建了示例DAG,其中我有DAG配置,如下所示.
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': one_min_ago,
'email': ['admin@airflow.com'],
'email_on_failure': True,
'email_on_retry': True,
'retries': 5,
'retry_delay': timedelta(hours=30))
Run Code Online (Sandbox Code Playgroud)
有了这个,当我运行气流网络服务器时,我正在收到消息.
/home/af_user/anaconda/lib/python3.5/site-packages/flask/exthook.py:71:
ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use
flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2017-12-18 12:41:27,967] [17328] {models.py:167} INFO - Filling up the
DagBag from /home/af_user/airflow/dags
[2017-12-18 12:41:28 +0000] [16648] [INFO] Handling signal: ttou
[2017-12-18 12:41:57 +0000] [16655] [INFO] Worker exiting (pid: 16655)
Run Code Online (Sandbox Code Playgroud)
DAG也将只在运行状态.
如果有人遇到过这个问题并且已经修好了,请告诉我.
我们正在使用气流来安排我们的数据管道,作为其中的一部分,我们还在气流管理中添加了一些连接和变量.
在DEV中一切正常,现在我们想要设置PROD环境.我们如何将这些值迁移到PROD环境中.