wake-up-neo.net

airflow

Airflow: Protokolldatei ist nicht lokal, nicht unterstützter Remote-Protokollspeicherort

Airflow-Aufgaben bleiben im Status "In Warteschlange" hängen und werden nie ausgeführt

So starten Sie eine fehlgeschlagene Task in Airflow neu

So stoppen/beenden Sie Airflow-Aufgaben auf der Benutzeroberfläche

Status der Airflow-Aufgabe innerhalb des Tags

Luftstrom: Übergeben Sie {{ds}} als Parameter an PostgresOperator

Welche wählen Sie für Apache Oozie oder Apache Airflow? Brauche einen Vergleich

Apache Airflow DAG kann kein lokales Modul importieren

Airflow-Authentifizierungseinstellungen schlagen mit "AttributeError: Attribut nicht setzen" fehl

Effiziente Methode zum Bereitstellen von DAG-Dateien im Luftstrom

Airflow Worker-Konfiguration

Airflow 1.9.0 steht in der Warteschlange, startet jedoch keine Aufgaben

Airflow Scheduler-Protokolle entfernen

So führen Sie Airflow unter Windows aus

execution_date in airflow: muss als Variable zugreifen

Auslösen einer Airflow-DAG vom Terminal aus funktioniert nicht

Wie installiere ich den Luftstrom?

Festlegen von Abhängigkeiten zwischen DAGs in Airflow

Luftstromparallelität

Luftstrom-Übergabeparameter an abhängige Aufgabe

Wie kann verhindert werden, dass der Luftstrom beim Nachfüllen von Dagläufen erfolgt?

Während airflow initdb kann ImportError: Name HiveOperator nicht importieren

Wie starte ich den airflow webserver neu?

Dynamische DAG und Task-IDs von Airflow

Airbnb Airflow gegen Apache Nifi

Airflow: SSH und Ausführen von BashOperator von einem anderen Server

Wie verwende ich AirFlow, um einen Ordner mit python Dateien auszuführen?

airflow trigger_dag execution_date ist der nächste tag, warum?

Wie führe ich Spark code in Airflow aus?

Airflow-Abgleichklärung

Airflow S3-Verbindung über die Benutzeroberfläche

So führen Sie eine Bash-Skriptdatei in Airflow aus

Airflow: Wie lösche ich eine DAG?

So erstellen Sie dynamische Workflows in Airflow

Luftstrom "Diese DAG ist im Webserver-DagBag-Objekt nicht verfügbar."

Luftstrom mit Vorlagendateien für PythonOperator

Ausführen einer einfachen Luftstrom-DAG

Apache Airflow: Kontrolle über die Protokollierung [Protokollierungsstufe deaktivieren/anpassen]

Ausführen eines Jobs bei Airflow basierend auf Webrequest

Luftstrom: dag_id wurde nicht gefunden

So entfernen Sie Standardbeispielfehler im Luftstrom

Beispiel: DAG bleibt auf unbestimmte Zeit im "laufenden" Zustand

Luftstrom: Aufgaben in der Warteschlange, werden jedoch nicht ausgeführt

Airflow-Aufgabenprotokolle entfernen

So erstellen Sie eine bedingte Aufgabe in Airflow

Airflow-Plugins können nicht importiert werden

s3 für Protokolle im Luftstrom einrichten

Speichern und greifen Sie auf das Passwort mit Apache Airflow zu

Luftstrom-Python-Gerätetest?

Airflow - Übergabe der xcom-Variablen an die Python function

Airflow-Aufgaben können aufgrund des Ausführungsdatums und des Startdatums nicht ausgeführt werden

docker-Compose Unbekannter MySQL-Server Host 'mysql' (Luftstrom)

Dynamische Aufgabendefinition in Airflow

Luftstrom + Sellerie oder Dask. Für was, wann?

So führen Sie Airflow PythonOperator in einer virtuellen Umgebung aus

Airflow DAG "scheint nur lokal zu existieren. Der Master Scheduler scheint sich seiner Existenz nicht bewusst zu sein."

Wie wähle ich meine Airflow- oder Python-Version mit Cloud Composer aus?

Python Airflow - Gibt das Ergebnis von PythonOperator zurück

Apache Airflow oder Apache Beam für die Datenverarbeitung und Jobplanung

Airflow protokolliert BrokenPipeException

Wie richte ich Airflow ein? E-Mail senden?

Apache-Airflow in der Conda-Umgebung installieren

Wie kann ich Apache Airflow mit Slack integrieren?

Fehler beim Installieren des Luftstroms: Standardmäßig installiert eine der Abhängigkeiten von Airflow eine GPL

APACHE NIFI gegen Apache AIRFLOW gegen Apache FALCON? Welche passt am besten in das unten stehende Szenario?

Wie kann ich bei Apache Airflow die Parameter übergeben, wenn die DAG manuell über die CLI ausgelöst wird?

Airflow SparkSubmitOperator - So senden Sie einen Funken auf einem anderen Server

Apache Airflow: Luftstrom initdb führt zu "ImportError: Kein Modul namens json"

Apache Airflow: Luftstrom initdb löst ModuleNotFoundError aus: Kein Modul mit dem Namen 'werkzeug.wrappers.json'; 'werkzeug.wrappers' ist kein Paketfehler

Der Luftstromplaner scheint nach dem Ausführen einer Aufgabe nicht ausgeführt zu werden

Apache-Luftstrom kann nach Neuinstallation nicht ausgeführt werden, python Importfehler

Fehler beim Installieren von Apache-airflow

Das Starten des Airflow-Webservers schlägt mit sqlalchemy.exc.NoInspection fehl. Verfügbar: Es ist kein Inspektionssystem verfügbar