这个错误是由于BigQueryCreateEmptyTableOperator中的if_exists参数设置为“skip”,但是该参数值不支持。解决方法是将if_exists参数设置为“fail”,这样在表已存在的情况下,会抛出一个错误,而不是忽略该操作。
代码示例:
from airflow.providers.google.cloud.operators.bigquery import BigQueryCreateEmptyTableOperator
create_op = BigQueryCreateEmptyTableOperator(
task_id='create_table',
table_id='my_dataset.my_table',
schema_fields=[{'name': 'column1', 'type': 'INTEGER'}, {'name': 'column2', 'type': 'STRING'}],
project_id='my_project',
dataset_id='my_dataset',
if_exists='fail'
)