如何从nodes.py文件中的类运行函数？

Question

我想在nodes.py文件中按类来组织节点函数。例如，与清理数据相关的函数在“CleanData”类中，带有@staticmethod 装饰器，而其他函数将留在“Other”类中，没有任何装饰器（这些类的名称只是代表）。在管道文件中，我尝试导入类的名称、节点的名称和以下方式：CleanData.function1（它给出了一个错误）并且它们都不起作用。如果可能的话，如何从类中调用节点？

Answer 1

我不完全确定您遇到的错误是什么。如果你真的试图做from .nodes import CleanData.function1 那是行不通的。导入在 Python 中不是这样工作的。如果你这样做：

nodes.py 有：

class CleanData:
    def clean(arg1):
        pass

而pipeline.py 有：

from kedro.pipeline import Pipeline, node
from .nodes import CleanData

def create_pipeline(**kwargs):
    return Pipeline(
        [
            node(
                CleanData.clean,
                "example_iris_data",
                None,
            )
        ]
    )

应该可以的。