使用管道 csv 删除行



尝试使用 csv 文件并删除前 4 行,然后继续我的解析:

parsePowerCsv
  :: MonadThrow m
  => ConduitT () ByteString m () -> m [PowerFields]
parsePowerCsv bs = do
  runConduit $
       bs
      .| CL.consume
      .| (dropC 4 >> intoCSV defCSVSettings)

所以我能够生成一个Text列表,但希望能够轻松转换为我的PowerFields类型,因为我有From/To NamedRecord实例,但我想删除前 4 行。

所以dropC之后我无法将[Text]解析为[PowerFields]

data PowerFields =
  PowerFields
    { VA_avg         :: Maybe Double
    , A_avg          :: Maybe Double
    , Wh_sum         :: Maybe Double
    ...
    } deriving (Eq, Show, Read)

由于intoCSV希望在整个文件中流式传输,而不是读取行流,因此您需要使用可以直接从输入字节串流分析和删除行的管道,而不是尝试使用行列表。

类似以下内容的内容应该有效:

parsePowerCsv bs = do
  runConduit $
      bs
      .| (replicateM_ 4 (lineAsciiC sinkNull) >>
          intoCSV defCSVSettings)
      .| sinkList -- (dropC 4 >> sinkList)

最新更新