docker - Airflow 2.0，关系“连接”不存在

Question

我们正在迁移到气流 2.0，我看到连接错误。我的 entrypoint.sh 文件具有以下默认连接：

delete_default_connections() {
  declare -a DEFAULT_CONNECTIONS=(
    "airflow_db"
    "aws_default"
    "azure_container_instances_default"
    "azure_cosmos_default"
    "azure_data_lake_default"
    "beeline_default"
    "bigquery_default"
    "cassandra_default"
    "databricks_default"
    "dingding_default"
    "druid_broker_default"
    "druid_ingest_default"
    "emr_default"
    "fs_default"
    "facebook_default"
    "google_cloud_default"
    "hive_cli_default"
    "hiveserver2_default"
    "http_default"
    "local_mysql"
    "metastore_default"
    "mongo_default"
    "mssql_default"
    "mysql_default"
    "opsgenie_default"
    "pig_cli_default"
    "postgres_default"
    "presto_default"
    "qubole_default"
    "redis_default"
    "segment_default"
    "sftp_default"
    "spark_default"
    "sqlite_default"
    "sqoop_default"
    "ssh_default"
    "vertica_default"
    "wasb_default"
    "webhdfs_default"
  )

  for CONN in "${DEFAULT_CONNECTIONS[@]}"
  do
    su -c "airflow connections delete $CONN" airflow
  done
}

但我在运行后看到了错误

docker-compose build --no-cache

然后

docker-compose run --rm webserver initdb

这是错误，为 default_connections 中的每个值填充此错误：

sqlalchemy.exc.ProgrammingError：（psycopg2.errors.UndefinedTable）关系“连接”不存在第2行：FROM连接^

[SQL: SELECT connection.password AS connection_password, connection.extra AS connection_extra, connection.id AS connection_id, connection.conn_id AS connection_conn_id, connection.conn_type AS connection_conn_type, connection.description AS connection_description, connection.host AS connection_host, connection.schema AS connection_schema，connection.login AS connection_login，connection.port AS connection_port，connection.is_encrypted AS connection_is_encrypted，connection.is_extra_encrypted AS connection_is_extra_encrypted FROM connection WHERE connection.conn_id = %(conn_id_1)s] [参数：{'conn_id_1': 'webhdfs_default'} ]

， ETC。

我在想也许问题出在这条线上：

su -c "airflow connections delete $CONN" airflow

我试过 --delete 和 --delete --conn 但没有运气。

标签： dockerairflow