AttributeError: 'NoneType' object has no attribute 'sink'

AttributeError: 'NoneType' object has no attribute 'sink'

我需要开发一个演示 ETL 系统,该系统需要 运行 遵循流畅的 python 格式

ETL().source(source_args).sink(sink_args).run()

我做了 class ETL() 之后我在 class 中做了一个函数 source 和函数 sink。 代码如下所示:

class ETL:

    def source(self, data_source: str):
        if data_source == 'Simulation':
            simulation()
        elif data_source == 'File':
            main()

    def sink(self, data_sink: str):
        if data_sink == 'Console':
            command = 'Continue'
            user_command = input('Please type to Continue or to Stop!')
            while command != 'Stop':
                simulation()

        else:
            pass

ETL().source('Simulation').sink('Console')

当我 运行 文件时,我收到此错误:

AttributeError: 'NoneType' object has no attribute 'sink'

我错在哪里以及如何添加最后一个方法.run()? 我从另一个文件中获取 simulation() 函数,但这不是问题所在。

NoneType 意味着您实际上得到的不是您要调用的 ETL 实例,而是 None。那是因为函数调用失败或return产生了意外结果。

改变这种情况的一种方法是在您的函数中添加 return。

标准 运行() 方法调用传递给对象构造函数的可调用对象作为目标参数,顺序参数和关键字参数分别取自 args 和 kwargs 参数。每次创建对象时都会调用一个方法。该方法被命名为构造函数。

构造函数是用函数 init 创建的。作为参数,我们写了 self 关键字,它指的是它自己(对象)。函数 init(self) 构建你的对象。您不仅可以在此处设置变量,还可以调用 class 方法。初始化对象所需的一切。它可能看起来像这样:

def __init__(self):
       self.source()
       self.sink()

我认为这里的问题是您的方法 source() 没有 return 任何东西,因此您将 None 作为输出。然后,当应用第二种方法 (sink()) 时,您不再使用 ETL 的实例,而是使用 ETL().source('Simulation') 的输出。你应该尝试这样的事情:

foo = ETL()
foo.source('Simulation')
foo.sink('Console')

另一个解决方案(尽管我认为这不是最好的方法)是您在 source 方法中 returned self。这将允许您继续使用 class 的实例和 运行 您想要的代码行。

无论如何你已经找到了答案,但我会在你的代码中添加一些return self

class ETL:

    def source(self, data_source: str):
        if data_source == 'Simulation':
            simulation()
        elif data_source == 'File':
            main()
        return self

    def sink(self, data_sink: str):
        if data_sink == 'Console':
            command = 'Continue'
            user_command = input('Please type to Continue or to Stop!')
            while command != 'Stop':
                simulation()
        return self

ETL().source('Simulation').sink('Console')

以上代码现在可以正常运行了。

但是,您还询问了run()方法。我想知道那应该做什么。对我来说,它看起来像 sink() 方法,有一个 while 循环正在做 运行 事情。

也许你打算这样做:

# code elided ...
    def sink(self, data_sink: str):
        self.data_sink = data_sink
        return self

    def run(self):
        if self.data_sink == 'Console':
            command = 'Continue'
            user_command = input('Please type to Continue or to Stop!')
            while command != 'Stop':
                simulation()

# Now this will work:
ETL().source(source_args).sink(sink_args).run()