גישה לממשק שורת הפקודה (CLI) של Airflow

‫Managed Airflow (דור 3) | Managed Airflow (דור 2) | Managed Airflow (דור 1 מדור קודם)

ל-Apache Airflow יש ממשק שורת פקודה (CLI) שבעזרתו אפשר לבצע משימות כמו הפעלה וניהול של DAG, קבלת מידע על הפעלות ומשימות של DAG, הוספה ומחיקה של חיבורים ומשתמשים.

פקודות נתמכות ב-Airflow CLI

‫Airflow ב-Managed Airflow (Legacy Gen 1) מספק שני סוגים שונים של תחביר לפקודות CLI:

רשימה מלאה של פקודות Airflow CLI נתמכות זמינה במאמר בנושא הפקודה gcloud composer environments run.

לפני שמתחילים

כדי להריץ פקודות Airflow CLI דרך Google Cloud CLI:

  • לחשבון Google שלכם צריכות להיות הרשאות לשימוש ב-Google Cloud CLI עם Managed Airflow ולהרצת פקודות Airflow CLI.

  • פקודות Airflow CLI שמופעלות דרך Google Cloud CLI צורכות את environments.executeAirflowCommand המכסה.

הרצת פקודות Airflow CLI באמצעות ה-CLI של gcloud

כדי להריץ פקודות של Airflow CLI בסביבות שלכם, משתמשים ב-CLI של gcloud:

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

מחליפים את מה שכתוב בשדות הבאים:

  • ‫ENVIRONMENT_NAME: השם של הסביבה.
  • ‫LOCATION: האזור שבו נמצאת הסביבה.
  • ‫SUBCOMMAND: אחת מהפקודות הנתמכות של Airflow CLI.
  • ‫SUBCOMMAND_ARGUMENTS עם ארגומנטים לפקודת Airflow CLI.

מפריד של ארגומנטים של פקודות משנה

מפרידים בין הארגומנטים של פקודת Airflow CLI שצוינה באמצעות --:

Airflow 2

  • מציינים פקודות מורכבות ב-CLI כפקודת משנה.
  • אם מזינים פקודות מורכבות, צריך לציין את הארגומנטים שלהן כארגומנטים של פקודות משנה, אחרי המפריד --.

דוגמה:

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

Airflow 1

  • מציינים פקודות CLI כפקודת משנה.
  • מציינים את הארגומנטים אחרי המפריד --.

דוגמה:

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

מיקום ברירת המחדל

רוב הפקודות של gcloud composer דורשות מיקום. אפשר לציין את המיקום באמצעות הדגל --location או על ידי הגדרת מיקום ברירת מחדל.

לדוגמה, כדי להפעיל DAG בשם sample_quickstart עם המזהה 5077 בסביבת Managed Airflow:

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

המאמרים הבאים