擅长:python、mysql、java
<p>好的,我把这个修好了。这意味着,在执行dag时,使用并执行文件中的sql代码。不确定这是不是一个优化的解决方案。因此,欢迎您提出更多建议。你知道吗</p>
<pre><code>//define
class SQLTemplatedPythonOperator(PythonOperator):
template_ext = ('.sql',)
//modify function
def loadCSV(**kwargs):
print("inside loadCSV")
query = kwargs['templates_dict']['query']
big_query_count = bigquery_operator.BigQueryOperator(
task_id='my_bq_query',
sql=query,
//dag - task
SQLTemplatedPythonOperator(
task_id='invalidBBDToCSV',
templates_dict={'query': 'invalidBBD.sql'},
provide_context=True,
python_callable=loadCSV,
dag=dag,
//dag
dag = DAG('invalidBBDLoad',
default_args=default_args,
description='DAG data',
schedule_interval="0 11 * * *",
catchup=False,
template_searchpath=['/home/stgairflow/dags/sqls'],
user_defined_macros={'myProjectId': myProjectId,}
)
</code></pre>