在kedro中将csv转换为拼花

import pandas as pd
from kedro.extras.datasets.pandas import CSVDataSet

# catalog.yml

csv_dataset:
  type: pandas.CSVDataSet
  filepath: data/input_data.csv

pattern_dataset:
  type: pandas.CSVDataSet
  filepath: data/output_pattern.csv

# nodes.py

def csv_to_pattern(csv_dataset: CSVDataSet, pattern_dataset: CSVDataSet):
    # 读取CSV文件
    df = csv_dataset.load()

    # 进行转换操作，将CSV转换为拼花

    # 将转换后的结果保存为拼花文件
    pattern_dataset.save(df)

# pipeline.py

from kedro.pipeline import node, Pipeline

def create_pipeline(**kwargs):
    return Pipeline(
        [
            node(
                csv_to_pattern,
                inputs="csv_dataset",
                outputs="pattern_dataset",
                name="csv_to_pattern_node"
            ),
        ]
    )

kedro run