gpt4 book ai didi

haskell - Attoparsec Iteratee

转载 作者:行者123 更新时间:2023-12-04 03:23:13 26 4
gpt4 key购买 nike

我想,只是为了了解一些关于 Iteratees 的知识,使用 Data.Iteratee 和 Data.Attoparsec.Iteratee 重新实现我制作的一个简单的解析器。不过,我很难过。下面我有一个简单的例子,它能够解析文件中的一行。我的解析器一次读取一行,所以我需要一种向迭代器提供行的方法,直到它完成。我已经阅读了我在谷歌上搜索到的所有内容,但是很多关于 iteratee/enumerators 的 Material 都非常先进。这是重要的代码部分:

-- There are more imports above.
import Data.Attoparsec.Iteratee
import Data.Iteratee (joinI, run)
import Data.Iteratee.IO (defaultBufSize, enumFile)

line :: Parser ByteString -- left the implementation out (it doesn't check for
new line)

iter = parserToIteratee line

main = do
p <- liftM head getArgs
i <- enumFile defaultBufSize p $ iter
i' <- run i
print i'

此示例将解析并打印多行文件中的一行。原始脚本将解析器映射到 ByteStrings 列表。所以我想在这里做同样的事情。我找到了 enumLines在Iteratee中,但我一生都无法弄清楚如何使用它。也许我误解了它的目的?

最佳答案

由于您的解析器一次只运行一行,因此您甚至不需要使用 attoparsec-iteratee。我会这样写:

import Data.Iteratee as I
import Data.Iteratee.Char
import Data.Attoparsec as A

parser :: Parser ParseOutput
type POut = Either String ParseOutput

processLines :: Iteratee ByteString IO [POut]
processLines = joinI $ (enumLinesBS ><> I.mapStream (A.parseOnly parser)) stream2list

理解这一点的关键是“enumeratee”,它只是流转换器的迭代术语。它采用一种流类型的流处理器(迭代器)并将其转换为与另一种流一起使用。两个 enumLinesBSmapStream是被枚举者。

要将解析器映射到多行, mapStream足够了:
i1 :: Iteratee [ByteString] IO (Iteratee [POut] IO [POut]
i1 = mapStream (A.parseOnly parser) stream2list

嵌套的迭代只是意味着这将转换 [ByteString] 的流到 [POut] 的流,并且当运行最终迭代(stream2list)时,它将该流返回为 [POut] .所以现在你只需要 lines 的 iteratee 等价物创建 [ByteString] 的流,这就是 enumLinesBS做:
i2 :: Iteratee ByteString IO (Iteratee [ByteString] IO (Iteratee [POut] m [POut])))
i2 = enumLinesBS $ mapStream f stream2list

但是由于所有的嵌套,这个函数使用起来非常笨拙。我们真正想要的是一种直接在流转换器之间管道输出的方法,最后将所有内容简化为单个迭代。为此,我们使用 joinI , (><>) , 和 (><>) :
e1 :: Iteratee [POut] IO a -> Iteratee ByteString IO (Iteratee [POut] IO a)
e1 = enumLinesBS ><> mapStream (A.parseOnly parser)

i' :: Iteratee ByteString IO [POut]
i' = joinI $ e1 stream2list

相当于我上面写的, e1内联。

尽管如此,仍然有重要的元素。此函数仅以列表的形式返回解析结果。通常,您会想做其他事情,例如将结果与折叠结合起来。

编辑: Data.Iteratee.ListLike.mapM_通常对创建消费者有用。此时流的每个元素都是一个解析结果,所以如果你想打印它们,你可以使用
consumeParse :: Iteratee [POut] IO ()
consumeParse = I.mapM_ (either (\e -> return ()) print)

processLines2 :: Iteratee ByteString IO ()
processLines2 = joinI $ (enumLinesBS ><> I.mapStream (A.parseOnly parser)) consumeParse

这将只打印成功的解析。您可以轻松地向 STDERR 报告错误,或以其他方式处理它们。

关于haskell - Attoparsec Iteratee,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6360963/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com