airflow

19calore

5risposta

execution_date in airflow: necessario accedere come variabile

Sono davvero un principiante in questo forum. Ma ho giocato con il flusso d'aria, per qualche tempo, per la nostra azienda. Scusa se questa domanda sembra davvero stupida. Sto scrivendo una pipeline u

7calore

2risposta

Che cosa significa il tempo di atterraggio nel flusso d'aria?

C'è una sezione chiamata "tempo di atterraggio" nella vista DAG sulla console Web del flusso d'aria. An example screen shot taken from airbnb's blog: Ma cosa vuol dire? Non c'è alcuna definizione nei

5calore

3risposta

configurazione del flusso d'aria di lavorare con CeleryExecutor

provo a configurare Airbnb AirFlow per utilizzare il CeleryExecutor come questo: ho cambiato il executer nel airflow.cfg da SequentialExecutor a CeleryExecutor: # The executor class that airflow shoul

5calore

2risposta

TemplateNotFound quando si utilizza PostgresOperator di Airflow con il templating di Jinja e SQL

Quando si tenta di utilizzare le funzionalità di template di Airflow (tramite Jinja2) con PostgresOperator, non sono riuscito a ottenere le cose da eseguire. È possibile che stia facendo qualcosa di s

8calore

2risposta

flusso d'aria non si pianifica correttamente Python

Codice: Python versione 2.7.x e il flusso d'aria versione 1.5.1 mio script dag è questo from airflow import DAG from airflow.operators import BashOperator from datetime import datetime, timedelta

12calore

4risposta

Attivazione di un DAG del flusso d'aria dal terminale non funzionante

Sto provando a utilizzare il flusso d'aria per definire un flusso di lavoro specifico che desidero attivare manualmente dalla riga di comando. Creo il DAG e aggiungo una serie di attività. dag = airfl

9calore

3risposta

Come eseguire flusso d'aria su Windows

Le istruzioni usuali per l'esecuzione del flusso d'aria non applicare su un ambiente Windows: # airflow needs a home, ~/airflow is the default, # but you can lay foundation somewhere else if you pref

9calore

2risposta

Parallelismo del flusso d'aria

l'Esecutore locale genera nuovi processi durante la pianificazione delle attività. C'è un limite al numero di processi che crea. Dovevo cambiarlo. Devo sapere qual è la differenza tra "max_threads" de

6calore

2risposta

Flusso d'aria: modifica del tempo di crontab per un DAG nel flusso d'aria

Ho un DAG in esecuzione tutti i giorni alle 3:00, è andato bene nelle ultime settimane. Ho aggiornato la data per l'esecuzione ora alle 7:00, ma a quanto pare per gli ultimi 2 giorni non è stata esegu

12calore

1risposta

Come funziona esattamente il subDAG in Airflow? Che cosa significa che un subDAG deve essere abilitato?

Ho guardato la sezione del flusso d'aria subDAG e cercato di trovare qualsiasi altra cosa online che sarebbe utile, ma non ho trovato nulla che ha spiegato nel dettaglio come fare un lavoro subDAG. Un