Saya memutakhirkan ke Airflow 2. Dari kode di bawah ini di entrypoint.sh saya, saya punya airflow connections --delete --conn_id, tetapi saya telah mengubahnya ke bawah sesuai dengan dokumen (https://airflow.Apache.org/docs/Apache-airflow/stable/ cli-and-env-variables-ref.html)

Sekarang saya mendapatkan kesalahan berikut untuk setiap koneksi:

kesalahan perintah aliran udara: argumen tidak dikenal: aliran udara_db aliran udara.. aws_default... azure_container_instances_default .. azure_cosmos_default

 delete_default_connections() {
      declare -a DEFAULT_CONNECTIONS=(
        "airflow_db"
        "aws_default"
        "azure_container_instances_default"
        "azure_cosmos_default"
      )
       for CONN in "${DEFAULT_CONNECTIONS[@]}"   do
    su -c "airflow connections delete conn_id $CONN" airflow   done }
0
KristiLuna 23 April 2021, 01:44

1 menjawab

Jawaban Terbaik

Ubah perintah menjadi berikut, conn_id adalah argumen posisi.

 delete_default_connections() {
      declare -a DEFAULT_CONNECTIONS=(
        "airflow_db"
        "aws_default"
        "azure_container_instances_default"
        "azure_cosmos_default"
      )
       for CONN in "${DEFAULT_CONNECTIONS[@]}"   do
    su -c "airflow connections delete $CONN" airflow   done }
0
kaxil 22 April 2021, 23:18