Kom igångKom igång gratis

Variabler som inte riktigt stämmer

Din chef ber dig undersöka ett problem där en försäljningsrapport inte genereras. Du har nyligen implementerat variabler i en av dina DAG:ar (process_sales), som bearbetar diverse försäljningsdata och skriver ut rapporten din chef efterfrågar. När du granskar loggarna inser du att filen inte skrivs till den avsedda platsen, utan till en standardplats.

Den uppgift som bearbetar rapporten gör följande:

@task()
  def parse_file():
    output_path = Variable.get("Output_Path", default="/home")
    output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
    save_file("{output_path}/{output_fn}")

Filen ska lagras som /data/sales/sales_report.pdf.

Kör kommandot airflow dags test process_sales för att visa loggens utdata.

Vilket av följande alternativ är orsaken till felet, och hur skulle du åtgärda det?

Den här övningen är en del av kursen

Introduktion till Apache Airflow i Python

Visa kurs

Interaktiv övning med praktiskt arbete

Gör teori till handling med en av våra interaktiva övningar

Starta övningen