【问题标题】:BigQueryCheckAsyncOperator in airflow does not exist气流中的 BigQueryCheckAsyncOperator 不存在
【发布时间】:2022-11-20 05:36:35
【问题描述】:

我正在尝试对 bigquery 使用异步运算符;然而,

from airflow.providers.google.cloud.operators.bigquery import BigQueryCheckAsyncOperator

给出错误:

ImportError: cannot import name 'BigQueryCheckOperatorAsync' from 'airflow.providers.google.cloud.operators.bigquery'

https://airflow.apache.org/docs/apache-airflow-providers-google/stable/operators/cloud/bigquery.html 中的文档提到 BigQueryCheckAsyncOperator 存在。

我正在使用气流 2.4。

如何导入?

【问题讨论】:

  • 我不确定它是否相关,错误消息提供了不同的导入名称 BigQueryCheckOperatorAsync 而不是 BigQueryCheckAsyncOperator?第一个 sn-p 是您代码中的导入行吗? (

标签: google-bigquery airflow


【解决方案1】:

您尝试导入的运算符从未发布。 它在PR 中添加并在PR 中删除,两者都是 Google provider 8.4.0 版本的一部分,因此总体而言,BigQueryCheckAsyncOperator 类从来都不是该版本的一部分。

您可以通过将deferrable参数设置为True来在现有类BigQueryCheckOperator中使用延迟模式。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2020-06-12
    • 1970-01-01
    • 2023-01-25
    • 1970-01-01
    • 2023-03-15
    • 1970-01-01
    • 2021-04-19
    相关资源
    最近更新 更多