polars管道

 

def lowercase(df: pl.DataFrame) -> pl.DataFrame:

    """将 DataFrame 所有列名转换为小写"""

    return df.rename({col: col.lower() for col in df.columns})

    person = (

        pl.read_csv(

            "/mnt/c/Users/Administrator/Downloads/标准库接种率+v1.0.9-2024-12-27/标准库数据/person_standard.csv",

        )

        .pipe(lowercase)

        .with_columns(

            pl.col("birth_weight").replace("", None)

        )

        .cast({

            "id": pl.String,

            "birth_date": pl.String,

            "hepatitis_mothers": pl.String,

            "current_management_code": pl.String,

            "birth_weight": pl.Float64,

        })

    )