我试图制作 mysqloperator dags,它从一个文件存储每个表的处理的文件中执行查询。
但我面临以下错误:
*** Reading local log.
[2018-07-17 10:42:53,897] {cli.py:374} INFO - Running on host joseongbins-MacBook-Air.local
[2018-07-17 10:42:53,913] {models.py:1197} INFO - Dependencies all met for <TaskInstance: dw_airflow_trial.dw_goods_md_info_period 2018-07-17 01:42:45.505791 [queued]>
[2018-07-17 10:42:53,916] {models.py:1197} INFO - Dependencies all met for <TaskInstance: dw_airflow_trial.dw_goods_md_info_period 2018-07-17 01:42:45.505791 [queued]>
[2018-07-17 10:42:53,916] {models.py:1407} INFO -
--------------------------------------------------------------------------------
Starting attempt 1 of 1
--------------------------------------------------------------------------------
[2018-07-17 10:42:53,925] {models.py:1428} INFO - Executing <Task(MySqlOperator): dw_goods_md_info_period> on 2018-07-17 01:42:45.505791
[2018-07-17 10:42:53,925] {base_task_runner.py:115} INFO - Running: ['bash', '-c', 'airflow run dw_airflow_trial dw_goods_md_info_period …Run Code Online (Sandbox Code Playgroud)