Cloud Composer 3 | Cloud Composer 2 | Cloud Composer 1
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, menambahkan dan menghapus koneksi serta pengguna.
Perintah Airflow CLI yang didukung
Airflow di Cloud Composer 1 menyediakan dua sintaksis yang berbeda untuk perintah CLI:
Sintaksis CLI Airflow 1.10, tersedia di lingkungan Cloud Composer dengan Airflow 1.10.
Sintaksis CLI Airflow 2, lingkungan Cloud Composer yang tersedia dengan Airflow 2.
Untuk mengetahui daftar lengkap perintah Airflow CLI yang didukung, lihat referensi untuk perintah gcloud composer environments run
.
Sebelum memulai
Anda harus memiliki izin untuk menggunakan Google Cloud CLI dengan Cloud Composer dan menjalankan perintah Airflow CLI.
Menjalankan perintah Airflow CLI
Untuk menjalankan perintah CLI Airflow 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 apa pun untuk perintah gabungan sebagai argumen sub-perintah,
setelah pemisah
--
.
Contoh:
gcloud composer environments run example-environment \
dags list -- --output=json
Aliran udara 1
- Tentukan perintah CLI sebagai sub-perintah.
- Tentukan argumen apa pun 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 tanda --location
, atau dengan menetapkan lokasi default.
Misalnya, untuk memicu DAG bernama sample_quickstart
dengan ID 5077
di lingkungan Cloud Composer Anda:
Airflow 2
gcloud composer environments run example-environment \
--location us-central1 dags trigger -- sample_quickstart \
--run-id=5077
Aliran udara 1
gcloud composer environments run example-environment \
--location us-central1 trigger_dag -- sample_quickstart \
--run_id=5077