此问题通常发生在您尝试使用GCSToBigQueryOperator将数据从Google Cloud Storage导入BigQuery时,表结构或架构发生变化导致任务失败。 为了解决此问题,您可以考虑使用BigQueryUpdateTableOperator手动更新BigQuery表的架构。以下是一个示例:
from airflow.contrib.operators.bigquery_operator import BigQueryUpdateTableOperator
update_table = BigQueryUpdateTableOperator(
task_id="update_table",
table_id="
您可以通过传递schema_fields参数来指定要向表中添加的新字段的名称和数据类型及模式。然后,您可以使用BigQueryUpdateTableOperator将此新字段添加到表格中。