luigi Pythonでデータベース行を出力として使用することは可能ですか

Question

私はluigiを学んでおり、そのほとんどはファイルシステム上のファイルです。

そのファイルが存在する場合、luigiはタスクが完了したと考えます。

私の場合、ファイルを書くのではなく、ポストグラムにステータスDONEのdatabas erecordを更新したいと思います。

私はそれはそれはLuigi contribsを見てみましょうルイジ

Answer 1

に可能であるかを知りたいです。興味のあるパッケージは少なくとも3つあります：mssqldb、mysqldb、rdbms、sqlaおよびredshiftです。いずれかを開く場合は、luigi.Targetサブクラスを探します。

たとえば、luigi.contribs.mysqldbにはMySqlTargetがあります。これはあなたが上記のような機能を提供します。タスクは "マーカーテーブル"が存在するかどうかをチェックします（そうでなければ、このタスクはそれを作成します）。そして、タスクが既に正常に実行されたかどうかをチェックします。そうでない場合は、タスクが終了したことを示す「マーカー」を挿入します。

すでに「マーカーテーブル」がある場合は、このタスククラスをサブクラス化するか、コードをコピーして必要な部分や必要のない部分をカスタマイズすることで同様のものを作成できます。