Luigi在任務之間傳遞小數據

Question

使用Luigi我想在我的postgres數據庫上做一個查詢來獲得一個緯度/經度座標對，然後將該對傳遞給另一個任務。

我有一個任務QueryPostgres（），它將一個SQL字符串作爲輸入並執行查詢。有沒有更簡潔的方式將查詢結果傳遞到下一個任務而不是將其寫入本地文件？畢竟只有兩個數字我需要通過。

謝謝！

Answer 1

您可以將結果寫入數據庫，redis等的另一個表中。檢查luigi.contrib包是否適用於各種輸出目標類型。 http://luigi.readthedocs.io/en/stable/api/luigi.contrib.html