csv格式文件读取的列数

wgm107

Csv.Document，读取的时候，需要设置[Columns = 15]。但假如我有很多个csv文件一起读取，而且列数不尽相同，怎么能够动态获取呀？哪位高手知道这个，谢谢了

zpy2

let
    Source = Folder.Files("你的文件夹路径"),
    // 读取所有文件但不指定列数
    ProcessEachFile = Table.AddColumn(Source, "Data", each
        Csv.Document(
            [Content],
            [Delimiter=",", Encoding=TextEncoding.Utf8, QuoteStyle=QuoteStyle.Csv]
        )
    ),
    // 找到最大列数
    #"Added MaxColumns" = Table.AddColumn(
        ProcessEachFile,
        "ColumnCount",
        each Table.ColumnCount([Data])
    ),
    maxColumns = List.Max(#"Added MaxColumns"[ColumnCount]),
   
    // 为所有表格添加缺失的列（如果需要）
    StandardizedData = Table.AddColumn(
        #"Added MaxColumns",
        "StandardData",
        each
            let
                current = [Data],
                currentCols = Table.ColumnNames(current),
                missingCols = maxColumns - List.Count(currentCols),
                // 如果有缺失列，添加空列
                result = if missingCols > 0 then
                    let
                        newCols = List.Transform(
                            {1..missingCols},
                            each "Column" & Text.From(Table.ColumnCount(current) + _)
                        ),
                        addColumns = List.Accumulate(
                            newCols,
                            current,
                            (state, colName) => Table.AddColumn(state, colName, each null)
                        )
                    in
                        addColumns
                else
                    current
            in
                result
    ),
   
    // 提升标题（如果CSV有标题行）
    PromotedData = Table.AddColumn(
        StandardizedData,
        "PromotedData",
        each
            let
                data = [StandardData],
                promoted = Table.PromoteHeaders(data, [PromoteAllScalars=true])
            in
                promoted
    ),
   
    // 展开数据
    #"Expanded PromotedData" = Table.ExpandTableColumn(
        PromotedData,
        "PromotedData",
        List.Distinct(List.Transform({1..maxColumns}, each "Column" & Text.From(_)))
    ),
   
    result = #"Removed Columns" // 继续清理数据
in
    result

zpy2

let
    Source = Folder.Files("你的文件夹路径"),
    // 添加自定义列处理每个文件
    ProcessEachFile = Table.AddColumn(Source, "Data", each
        let
            csv = Csv.Document(
                [Content],
                [Delimiter=",", Encoding=TextEncoding.Utf8]
            ),
            // 获取实际列数
            columnCount = Table.ColumnCount(csv),
            // 动态生成列名
            promotedHeaders = Table.PromoteHeaders(
                Table.TransformColumns(
                    csv,
                    {"Column1", each if _ = null then "" else _}
                ),
                [PromoteAllScalars=true]
            )
        in
            promotedHeaders
    ),
    // 展开数据
    #"Expanded Data" = Table.ExpandTableColumn(
        ProcessEachFile,
        "Data",
        List.Distinct(List.Combine(List.Transform(ProcessEachFile[Data], each Table.ColumnNames(_))))
    ),
    // 删除不需要的列
    #"Removed Columns" = Table.RemoveColumns(#"Expanded Data",{"Content"}),
   
    result = #"Removed Columns"
in
    result