我正在和BigQueryOperator一起试验气流。我想稍后我会使用,但我希望它首先在本地运行。我已经启动了气流,运行了一个BashOperator,我也可以运行airflow test <dag> <task>,其中task是我想要运行的大型查询任务,但是当我从UI触发DAG时,bigqueryimport datetime, timedelta
from airflow.contrib.operators.bigquery_operator import BigQue
我试着用气流从BigQueryOperator中获取结果,但是我找不到方法去做。我尝试在next()成员(在1.10中可用)中调用bq_cursor方法,但是它返回None。我就是这么做的import logging
from airflow.contrib.operators importbigquery_operator
from airflow.operators impor