您的位置 首页 编程知识

Go 命令行工具:管道数据

unix 因倡导命令应该做一件事并做好它的理念而闻名。 复杂的数据处理和转换操作通常可以使用 shell 管道…

Go 命令行工具:管道数据

unix 因倡导命令应该做一件事并做好它的理念而闻名。

复杂的数据处理和转换操作通常可以使用 shell 管道运算符将命令链接在一起来执行,以便一个命令的输出成为另一个命令的输入,操作和转换数据以实现所需的结果。

例如:

# sort file names. ls | sort  # count files. ls -l | count -l  # print out unique file extensions. #  1. list all files that have extensions #  2. transform the data (discard everything but extensions) #  3. sort the list (data must be sorted to identify duplicates) #  4. filter out duplicates #  5. browse the results ls *.* | sed 's/.*.//' | sort | uniq | less 
登录后复制

使用 go,程序员可以创建高效且高性能的命令来处理数据。我们将通过以下片段来讨论这个问题。

添加行号到输出

可用于管道操作的命令的本质是从 stdin 读取并写入 stdout。

add-line-numbers.go

package main  import (     "bufio"     "fmt"     "os" )  func main() {      // buffered input that splits input on lines.     input := bufio.newscanner(os.stdin)      // buffered output.     output := bufio.newwriter(os.stdout)      lineno := 0      // scan until eof (no more input).     for input.scan() {         text := input.text()         lineno++         s := fmt.sprintf("%03d %sn", lineno, text)          // it would be simpler to just use fmt.println,         // but want to emphasize piping stdin to stdout         // explicitly.         // intentionally ignoring return values.         _, _ = output.writestring(s)      }      // always explicitly flush remaining buffered output.     _ = output.flush() } 
登录后复制

此示例从 stdin 一次读取一行,并将其写回到 stdout,每行都以行号为前缀。在这里,我们使用程序文件本身作为输入来生成编号的输出。

$ cat add-line-numbers.go | go run add-line-numbers.go 001 package main 002  003 import ( 004     "bufio" 005     "fmt" 006     "os" 007 ) 008  009 func main() { 010  011     // buffered input that splits input on lines. 012     input := bufio.newscanner(os.stdin) 013  014     // buffered output. 015     output := bufio.newwriter(os.stdout) 016  017     lineno := 0 018  019     // scan until eof (no more input). 020     for input.scan() { 021         text := input.text() 022         lineno++ 023         s := fmt.sprintf("%03d %sn", lineno, text) 024  025         // it would be simpler to just use fmt.println, 026         // but want to emphasize piping stdin to stdout 027         // explicitly. 028         // intentionally ignoring return values. 029         _, _ = output.writestring(s) 030  031     } 032  033     // always explicitly flush remaining buffered output. 034     _ = output.flush() 035  036 } 
登录后复制

base64编码输入

此示例从 stdin 一次读取一行,base64 对其进行编码,然后将其写回到 stdout。

package main  import (     "bufio"     "encoding/base64"     "os" )  func main() {      // buffered input that splits input on lines.     input := bufio.newscanner(os.stdin)      // base64 encoder/writer.     encoder := base64.newencoder(         base64.stdencoding,         os.stdout)      // scan until eof (no more input).     for input.scan() {         bytes := input.bytes()         _, _ = encoder.write(bytes)         _, _ = encoder.write([]byte{'n'})     }      // close the encoder and ensure it flushes remaining output     _ = encoder.close() } 
登录后复制

由于扫描器会分割换行符 (n) 而不返回它们,因此有必要在写入每一行后显式写入换行符。

$ cat base64-encode.go | go run base64-encode.go cgfja2fnzsbtywlucgppbxbvcnqgkaojimj1zmlvigojimvuy29kaw5nl2jhc2u2ncikcsjvcyikkqokznvuyybtywlukckgewokcs8viej1zmzlcmvkigluchv0ihroyxqgc3bsaxrzigluchv0ig9uigxpbmvzlgojaw5wdxqgoj0gynvmaw8utmv3u2nhbm5lcihvcy5tdgrpbikkcgkvlybcyxnlnjqgrw5jb2rlci93cml0zxiucgllbmnvzgvyido9igjhc2u2nc5ozxdfbmnvzgvykaojcwjhc2u2nc5tdgrfbmnvzgluzywkcqlvcy5tdgrvdxqpcgojly8gu2nhbib1bnrpbcbft0ygkg5vig1vcmugaw5wdxqplgojzm9yigluchv0llnjyw4oksb7cgkjynl0zxmgoj0gaw5wdxquqnl0zxmokqojcv8sif8gpsblbmnvzgvylldyaxrlkgj5dgvzkqojcv8sif8gpsblbmnvzgvylldyaxrlkftdynl0zxsnxg4nfskkcx0kcgkvlybdbg9zzsb0agugzw5jb2rlcibhbmqgzw5zdxjligl0igzsdxnozxmgcmvtywluaw5nig91dhb1daojxya9igvuy29kzxiuq2xvc2uokqp9cg== 
登录后复制

您可以通过将编码结果传输到系统 base64 命令( 和 )进行解码来确认文本是否正确编码:

$ cat base64-encode.go | go run base64-encode.go | base64 -D package main  import (     "bufio"     "encoding/base64"     "os" )  func main() {      // Buffered input that splits input on lines.     input := bufio.NewScanner(os.Stdin)      // Base64 Encoder/writer.     encoder := base64.NewEncoder(         base64.StdEncoding,         os.Stdout)      // Scan until EOF (no more input).     for input.Scan() {         bytes := input.Bytes()         _, _ = encoder.Write(bytes)         _, _ = encoder.Write([]byte{'n'})     }      // Close the encoder and ensure it flushes remaining output     _ = encoder.Close() } 
登录后复制

这篇文章摘录自我编写的关于 go 功能的简短介绍性指南,这些功能对于创建命令行工具非常有用:go for cli 应用程序和工具。

以上就是Go 命令行工具:管道数据的详细内容,更多请关注php中文网其它相关文章!

本文来自网络,不代表四平甲倪网络网站制作专家立场,转载请注明出处:http://www.elephantgpt.cn/2120.html

作者: nijia

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

联系我们

联系我们

18844404989

在线咨询: QQ交谈

邮箱: 641522856@qq.com

工作时间:周一至周五,9:00-17:30,节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

关注微博
返回顶部