解释如何使用 io.ReadAll 来符合特定模式

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《解释如何使用 io.ReadAll 来符合特定模式》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我正在使用golang docker sdk来输出容器日志。容器正在运行扫描并输出有关扫描作业开始时间、结束时间、平均扫描持续时间的具体信息，如下所示：

selected xml parser javax.xml.bind.util.jaxbsource$1 does not recognize the feature http://xml.org/sax/features/validation
    generated ./reports/csr1000v_rtr2.json
    generated ./reports/csr1000v_rtr6.json
    generated ./reports/csr1000v_rtr3.json
scan start time: mon aug 27 03:39:24 gmt 2018
scan end time:   mon aug 27 03:39:40 gmt 2018
mean target scan duration: 3906ms

我使用下面的代码将 io.reader 转换为字符串：

out, err := cli.containerlogs(ctx, resp.id, types.containerlogsoptions{
    showstdout: true,
    follow:     true})
if err != nil {
    panic(err)
}
defer out.close()
//io.copy(os.stdout, out)
b, err := ioutil.readall(out)

fmt.println(string(b))

在 golang 中如何仅解析最后 3 行并仅从标准输出捕获以下值：

fmt.Println("The scan has started at: " +startime)
fmt.Println("The scan has ended at: " +endtime)
fmt.Println("The scan job took xxx ms to scan each device")

解决方案

另一种解决方案是使用 bufio.scanner api。

如果您正在处理大量输出，并且不想将其全部存储在内存中进行处理，这可能会很有趣。

扫描器由读取器、输入数据和分割函数组成，用于创建有意义的数据块。

使用标准 api，可以利用提供的 bufio.scanlines 函数按行分割输出，然后简单的前缀相等将产生识别研究信息所需的信息。

package main

import (
    "bufio"
    "bytes"
    "fmt"
    "strings"
)

type result struct {
    start string
    end   string
    mean  string
}

func main() {
    raw := `
    selected xml parser javax.xml.bind.util.jaxbsource$1 does not recognize the feature http://xml.org/sax/features/validation
    generated ./reports/csr1000v_rtr2.json
    generated ./reports/csr1000v_rtr6.json
    generated ./reports/csr1000v_rtr3.json
scan start time: mon aug 27 03:39:24 gmt 2018
scan end time:   mon aug 27 03:39:40 gmt 2018
mean target scan duration: 3906ms
`
    scanner := bufio.newscanner(strings.newreader(raw))

    var res result
    // create a custom split function by wrapping the existing scanlines function.
    split := func(data []byte, ateof bool) (advance int, token []byte, err error) {
        advance, token, err = bufio.scanlines(data, ateof)
        if err == nil && token != nil {
            if pattern := []byte("scan start time:"); bytes.hasprefix(token, pattern) {
                res.start = strings.trimspace(string(token[len(pattern):]))
            } else if pattern := []byte("scan end time:"); bytes.hasprefix(token, pattern) {
                res.end = strings.trimspace(string(token[len(pattern):]))
            } else if pattern := []byte("mean target scan duration:"); bytes.hasprefix(token, pattern) {
                res.mean = strings.trimspace(string(token[len(pattern):]))
            }
        }
        return
    }
    // set the split function for the scanning operation.
    scanner.split(split)
    // drain the source
    for scanner.scan() {
    }

    if err := scanner.err(); err != nil {
        fmt.printf("invalid input: %s", err)
    }
    fmt.printf("%#v\n", res)
}

我使用了下面的代码，如果有人有更好的解决方案请告诉我：

RegexpMeanTime := regexp.MustCompile(`Mean target scan duration: (.*)`)
RegexpMeanTimeMatch := RegexpMeanTime.FindStringSubmatch(string(b))
fmt.Printf("Mean Scan Duration per device: %v\n", RegexpMeanTimeMatch[1])

RegexpStartTime := regexp.MustCompile(`Scan start time: (.*)`)
RegexpStartTimeMatch := RegexpStartTime.FindStringSubmatch(string(b))
fmt.Printf("Scan Job Start Time: %v\n", RegexpStartTimeMatch[1])

RegexpEndTime := regexp.MustCompile(`Scan end time: (.*)`)
RegexpEndTimeMatch := RegexpEndTime.FindStringSubmatch(string(b))
fmt.Printf("Scan Job End Time: %v\n", RegexpEndTimeMatch[1])

今天关于《解释如何使用 io.ReadAll 来符合特定模式》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！