- 查看BigQueryInsertJobOperator的源代码以确定所有必要参数
- 检查您的代码中是否包含必要参数,并确保参数名称正确
- 如果您仍然无法确定缺少哪个参数,请参考以下示例代码,该代码包含了BigQueryInsertJobOperator所需的所有参数
from airflow.contrib.operators.bigquery_operator import BigQueryInsertJobOperator
from airflow import DAG
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval='@once')
task = BigQueryInsertJobOperator(
task_id='bigquery_insert',
dag=dag,
project_id='my_project',
configuration={
'query': {
'query':"SELECT * FROM my_table",
'useLegacySql': False
},
'destinationTable': {
'projectId': 'my_project',
'datasetId': 'my_dataset',
'tableId': 'my_table'
}
}
)