【发布时间】:2017-11-03 18:50:25
【问题描述】:
我想使用 Luigi 对我的 postgres 数据库进行查询以获取 lat/lng 坐标对,然后将该对传递给另一个任务。
我有一个任务 QueryPostgres(),它将 SQL 字符串作为输入并执行查询。有没有更简洁的方式将查询结果传递给下一个任务,而不是将其写入本地文件?毕竟我只需要传递两个数字。
谢谢!
【问题讨论】:
标签: python postgresql scheduled-tasks luigi
我想使用 Luigi 对我的 postgres 数据库进行查询以获取 lat/lng 坐标对,然后将该对传递给另一个任务。
我有一个任务 QueryPostgres(),它将 SQL 字符串作为输入并执行查询。有没有更简洁的方式将查询结果传递给下一个任务,而不是将其写入本地文件?毕竟我只需要传递两个数字。
谢谢!
【问题讨论】:
标签: python postgresql scheduled-tasks luigi
您可以将结果写入数据库、redis 等中的另一个表中。检查 luigi.contrib 包以了解各种输出目标类型。 http://luigi.readthedocs.io/en/stable/api/luigi.contrib.html
【讨论】: