Mengakses antarmuka command line Airflow

Managed Airflow (Gen 3) | Managed Airflow (Gen 2) | Managed Airflow (Gen 1 Lama)

Apache Airflow memiliki antarmuka command line (CLI) yang dapat Anda gunakan untuk melakukan tugas seperti memicu dan mengelola DAG, mendapatkan informasi tentang tugas dan eksekusi DAG, serta menambahkan dan menghapus koneksi dan pengguna.

Perintah Airflow CLI yang didukung

Airflow di Managed Airflow (Gen 1 Lama) menyediakan dua sintaksis yang berbeda untuk perintah CLI:

• Sintaksis CLI Airflow 1.10, tersedia di lingkungan Managed Airflow dengan Airflow 1.10.

• Sintaksis CLI Airflow 2, tersedia di lingkungan Managed Airflow dengan Airflow 2.

Untuk daftar lengkap perintah Airflow CLI yang didukung, lihat referensi untuk perintah gcloud composer environments run.

Sebelum memulai

Untuk menjalankan perintah Airflow CLI melalui Google Cloud CLI:

• Akun Google Anda harus memiliki izin untuk menggunakan Google Cloud CLI dengan Managed Airflow dan menjalankan perintah Airflow CLI.

  Perhatian: Pengguna dengan composer.environments.executeairflowcommand izin dapat menjalankan kode Python yang tersedia untuk komponen Airflow atas nama akun layanan lingkungan. Untuk mengetahui informasi selengkapnya, lihat Kontrol akses.

• Perintah Airflow CLI yang dijalankan melalui Google Cloud CLI menggunakan environments.executeAirflowCommand kuota.

  Penting: Jika Anda ingin memicu DAG dalam jumlah besar, sebaiknya lakukan dengan Airflow REST API. Memicu DAG melalui Google Cloud CLI dapat menyebabkan lingkungan Anda mencapai batas kuota, dan akibatnya, perintah Airflow CLI tidak akan lagi dijalankan.

Menjalankan perintah Airflow CLI dengan gcloud CLI

Untuk menjalankan perintah Airflow CLI di lingkungan Anda, gunakan gcloud CLI:

gcloud composer environments run ENVIRONMENT_NAME \
    --location LOCATION \
    SUBCOMMAND \
    -- SUBCOMMAND_ARGUMENTS

Ganti kode berikut:

• ENVIRONMENT_NAME: nama lingkungan Anda.
• LOCATION: region tempat lingkungan berada.
• SUBCOMMAND: salah satu perintah Airflow CLI yang didukung.
• SUBCOMMAND_ARGUMENTS dengan argumen untuk perintah Airflow CLI.

Pemisah argumen sub-perintah

Pisahkan argumen untuk perintah Airflow CLI yang ditentukan dengan --:

Airflow 2

• Tentukan perintah CLI gabungan sebagai sub-perintah.
• Tentukan argumen untuk perintah gabungan sebagai argumen sub-perintah, setelah pemisah --.

Contoh:

gcloud composer environments run example-environment \
    dags list -- --output=json

Airflow 1

• Tentukan perintah CLI sebagai sub-perintah.
• Tentukan argumen setelah pemisah --.

Contoh:

gcloud composer environments run example-environment \
    list_dags -- --report

Lokasi default

Sebagian besar perintah gcloud composer memerlukan lokasi. Anda dapat menentukan lokasi dengan flag --location, atau dengan menetapkan lokasi default.

Misalnya, untuk memicu DAG bernama sample_quickstart dengan ID 5077 di lingkungan Managed Airflow Anda:

Airflow 2

gcloud composer environments run example-environment \
    --location us-central1 dags trigger -- sample_quickstart \
    --run-id=5077

Airflow 1

gcloud composer environments run example-environment \
    --location us-central1 trigger_dag -- sample_quickstart \
    --run_id=5077

Langkah berikutnya

• Mengakses UI Airflow
• Kontrol akses (Airflow CLI)