zu verwenden Ich lerne Luigi und sehe, dass vor allem die Ausgabe Datei auf Dateisystem ist.Ist es in Luigi Python möglich, Datenbankzeile als Ausgabe
Wenn diese Datei existiert dann Luigi denke, dass die Aufgabe erledigt ist.
In meinem Fall, anstatt Datei zu schreiben, ich möchte Databas Erecord mit Status DONE in Postgres aktualisieren.
Ich möchte, dass wissen, ist es möglich, in luigi
einen Blick auf Luigi contribs nehmen. Es gibt mindestens 3 Pakete, die Sie interessieren könnten: mssqldb, mysqldb, rdbms, sqla und redshift. Wenn Sie einen von ihnen öffnen, suchen Sie nach Unterklassen luigi.Target.
Zum Beispiel haben Sie in luigi.contribs.mysqldbMySqlTarget. Es gibt Ihnen eine Funktionalität wie die, über die Sie oben gesprochen haben: Die Aufgabe prüft, ob die "Markertabelle" existiert (wenn nicht, erstellt diese Aufgabe sie) und trifft dann eine Auswahl, um zu prüfen, ob die Aufgabe bereits erfolgreich ausgeführt wurde. Wenn nicht, fügt es einen "Marker" für die Aufgabe ein und sagt, dass es FERTIG ist.
Wenn Sie bereits eine "Marker-Tabelle" haben, können Sie diese Task-Klasse untergliedern oder eine ähnliche erstellen, indem Sie ihren Code kopieren und die Teile anpassen, die Sie benötigen oder nicht benötigen.