Python - Luigi - 复制到 Postgres

Question

我想定义一个 Luigi 任务，它将在 AWS 的 Postgres 数据库中创建一个表。我尝试过不同的导入方式，例如:

import luigi.contrib.postgres.CopyToTable
from luigi.contrib.postgres import CopyToTable
import luigi.contrib.postgres
from luigi.contrib import postgres
import luigi.postgres ( i thing this is depreceated)

我收到了不同的错误，但总是相似的，比如:

AttributeError: module 'luigi.contrib' has no attribute 'postgres'
ModuleNotFoundError: No module named 'luigi.contrib.postgres'

谁知道问题出在哪里？接下来我的任务是:

class InsertToRDS(luigi.contrib.postgres.CopyToTable):

    def requires(self):
        return ReShape()

    host = ""
    database = ""
    user = ""
    password = ""  # ;)
    table = "extropy"

    columns = [("author", "TEXT"),
               ("file_id", "TEXT"),
               ("year.month_x", "DATE"),
               ("subject", "TEXT"),
               ("subject", "TEXT"),
               ("file_timestamp", "TEXT"),
               ("mail_content", "TEXT"),
               ("next_message", "TEXT"),
               ("prev_message", "TEXT"),
               ("year.month_y", "DATE"),]

提前致谢!

Answer 1

from luigi.contrib.postgres import CopyToTable

是正确的语法，然后你可以跟进......

class InsertToRDS(CopyToTable):

你确定 luigi 安装正确吗？在命令行检查输出:

pip show luigi

如果出现正确的版本，请在命令行运行 python 并再次尝试第一个导入行。如果它在那里工作，那么您运行程序的方式就很乏味。