3

私は Haskell の初心者で、コンジット ライブラリに頭を悩ませようとしています。

私はこのようなことを試しましたが、コンパイルされません:

import Data.Conduit
import Data.Conduit.Binary as CB
import Data.ByteString.Char8 as BS

numberLine :: Monad m => Conduit BS.ByteString m BS.ByteString
numberLine = conduitState 0 push close
  where
    push lno input = return $ StateProducing (lno + 1) [BS.pack (show lno ++ BS.unpack input)]
    close state = return state

main = do
  runResourceT $ CB.sourceFile "wp.txt" $= CB.lines $= numberLine $$ CB.sinkFile "test.txt"

コンジットステートの状態は、コンジットの入力タイプと同じタイプでなければならないようです。または、少なくともそれがエラーメッセージから私が理解していることです:

$ ghc --make exp.hs
[1 of 1] Compiling Main             ( exp.hs, exp.o )

exp.hs:8:27:
    Could not deduce (Num [ByteString]) arising from the literal `0'
    from the context (Monad m)
      bound by the type signature for
                 numberLine :: Monad m => Conduit ByteString m ByteString
      at exp.hs:(8,1)-(11,30)
    Possible fix:
      add (Num [ByteString]) to the context of
        the type signature for
          numberLine :: Monad m => Conduit ByteString m ByteString
      or add an instance declaration for (Num [ByteString])
    In the first argument of `conduitState', namely `0'
    In the expression: conduitState 0 push close
    In an equation for `numberLine':
        numberLine
          = conduitState 0 push close
          where
              push lno input
                = return
                  $ StateProducing (lno + 1) [pack (show lno ++ unpack input)]
              close state = return state

これは、コンジットを使用してどのように行うことができますか? ファイルから行を読み取り、各行に行番号を追加したい。

4

3 に答える 3

6

はい、できます。私はヘルパー関数を使用することを好み、可能であればData.Conduit.List回避します。Data.ByteString.Char8あなたのファイルはUTF-8でエンコードされていると思います。

import Data.Conduit
import Data.Conduit.Binary as CB
import Data.Conduit.List as Cl
import Data.Conduit.Text as Ct
import Data.Monoid ((<>))
import Data.Text as T

numberLine :: Monad m => Conduit Text m Text
numberLine = Cl.concatMapAccum step 0 where
  format input lno = T.pack (show lno) <> T.pack " " <> input <> T.pack "\n"
  step input lno = (lno+1, [format input lno])

main :: IO ()
main =
  runResourceT
     $ CB.sourceFile "wp.txt"
    $$ Ct.decode Ct.utf8
    =$ Ct.lines
    =$ numberLine
    =$ Ct.encode Ct.utf8
    =$ CB.sinkFile "test.txt"
于 2012-06-16T18:29:22.230 に答える
2 
close state = return state

ここにタイプエラーがあります。関数のcloseタイプは(state -> m [output])（ドキュメントのとおり）である必要があります。あなたの場合state = Int（タイプアノテーションを追加して、確実に選択されるようにすることができますInt）とoutput = BS.ByteString、おそらく空のリストを返すだけです。コンジットを閉じた時点では、ByteString生成するsなどを実際に保存していないためです。 。

close _ = return []

特に、その議論についてはドキュメントから注意してください。

状態は二度と使用されないため、戻す必要はありません。

于 2012-06-18T09:37:19.017 に答える
0

パイプ 3.0を使用した代替ソリューションですが、ByteString の代わりに文字列を使用します。私の考えでは、主な利点は、通常の状態のモナド メソッド get と put を使用できることです。もう 1 つの利点は、開始行番号が addLineNumber(numberLine) に隠されていないため、任意の行番号から簡単に開始できることです。

import System.IO
import Data.Monoid ((<>))
import Control.Proxy
import qualified Control.Proxy.Trans.State as S

addLineNumber r = forever $ do
    n <- S.get
    line <- request r -- request line from file
    respond $ show n <> " " <> line
    S.put (n + 1) -- increments line counter

main = 
    withFile "wp.txt" ReadMode    $ \fin  ->
    withFile "test.txt" WriteMode $ \fout ->
    runProxy $ S.execStateK 1 -- start at line number at 1
             $ hGetLineS fin >-> addLineNumber >-> hPutStrLnD fout

pipes-safe のアナウンス ブログ投稿で、よりきめ細かいリソース管理を行う方法を確認してください。.

于 2012-12-19T22:03:09.890 に答える