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

Question

我想通过nodes.py文件中的Classes来组织节点函数。例如，与清理数据相关的函数在"CleanData"类中，带有@staticmethod装饰器，而其他函数将留在"other"类中不带任何装饰器(这些类的名称仅具有代表性(。在管道文件中，我尝试导入类的名称、节点的名称和以下方式：CleanData.function1(出现错误(，但都不起作用。如果可能的话，我如何从类中调用节点？

Answer 1

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

nodes.py具有：

class CleanData:
def clean(arg1):
pass

CCD_ 3具有

from kedro.pipeline import Pipeline, node
from .nodes import CleanData
def create_pipeline(**kwargs):
return Pipeline(
[
node(
CleanData.clean,
"example_iris_data",
None,
)
]
)

这应该行得通。