[PYTHON] Erstellen Sie eine Benutzerauthentifizierungsfunktion in Airflow

Die Authentifizierungsfunktion ist im Luftstrom mit der Standardeinstellung für den Webserver nicht aktiviert. Obwohl es von außen keinen operativen Zugang gibt, möchte ich ihn hinzufügen! Ich denke, es gibt Leute, die das sagen, also diese Methode. Oder besser gesagt, die Grundlagen sind im Dokument geschrieben. Wenn Sie hier nachsehen, können Sie alles tun. https://pythonhosted.org/airflow/security.html

Es gibt LDAP und GHE, aber diesmal ist die grundlegendste E-Mail vorbei

Vorbereitungen

Bei Verwendung der Authentifizierung ist zunächst "flask_bcrypt" erforderlich. Installieren Sie es daher

pip install flask_bcrypt

Danach sollten Sie in der Lage sein, mit dem Standard zu arbeiten

Änderungen an airflow.cfg

Da authenticate anfangs False ist, kommentieren Sie es aus oder setzen Sie es auf True.

authenticate = True
auth_backend = airflow.contrib.auth.backends.password_auth

Benutzer erstellen

Erstellen Sie einen Benutzer über die Befehlszeile.

Öffnen Sie die Konsole mit dem Befehl "python", ändern Sie die folgenden Benutzerinformationen und drücken Sie die Eingabetaste, um die Benutzererstellung abzuschließen.

import airflow
from airflow import models, settings
from airflow.contrib.auth.backends.password_auth import PasswordUser
user = PasswordUser(models.User())
user.username = '[Beliebiger Benutzername]'
user.email = '[Beliebige E-Mail-Adresse]'
user.password = '[Beliebiges Passwort]'
session = settings.Session()
session.add(user)
session.commit()
session.close()
exit()

Wenn Sie den Webserver damit neu starten, sollte der folgende Bildschirm angezeigt werden

Schließlich

Es scheint, dass Sie die Berechtigungen nicht festlegen können. ??