在编写 Python 脚本时，如果希望它能够通过管道（pipe）接收输入，则可以使用标准输入流 `sys.stdin` 来读取数据。当脚本被管道连接符调用时，操作系统会将前一个命令的输出作为当前脚本的标准输入。 ### 使用 `sys.stdin` 读取管道输入 可以通过 `sys.stdin` 模块来读取来自管道的数据。以下是一个简单的示例，展示如何从管道中读取所有输入并进行处理： ```python import sys def main(): for line in sys.stdin: print(f"Received: {line.strip()}") if __name__ == "__main__": main() ``` 此脚本会在标准输入上逐行读取数据，并打印每一行内容。例如，假设这个脚本保存为 `read_pipe.py`，可以在命令行中这样使用它： ```bash echo "Hello, Pipe!" | python read_pipe.py ``` 脚本的输出将是： ``` Received: Hello, Pipe! ``` ### 处理缓冲问题 有时，在测试或调试过程中可能会遇到缓冲问题，尤其是在某些系统上（如 Linux 或 macOS）。为了确保脚本能立即接收到输入，而不是等待缓冲区填满，可以考虑禁用缓冲或按需刷新缓冲区。例如，可以使用 `-u` 参数运行 Python 脚本来启用无缓冲模式： ```bash echo "Hello, Pipe!" | python -u read_pipe.py ``` ### 使用 `input()` 和 `sys.stdin.read()` 除了逐行读取外，也可以一次性读取所有输入内容： ```python import sys def main(): data = sys.stdin.read() print(f"All input: {data}") if __name__ == "__main__": main() ``` 这段代码会一次性读取所有来自管道的数据，并将其作为一个字符串输出。 需要注意的是，`input()` 函数与 `sys.stdin.readline()` 类似，但会自动去除末尾的换行符[^1]。然而，在处理管道输入时，通常推荐使用 `sys.stdin` 相关方法以获得更灵活的控制。 ### 示例：结合字典统计输入内容 可以进一步扩展脚本功能，比如统计输入中的单词频率： ```python import sys from collections import defaultdict def process_input(data): counts = defaultdict(int) words = data.split() for word in words: counts[word] += 1 return counts def main(): data = sys.stdin.read() result = process_input(data) for word, count in result.items(): print(f"{word}: {count}") if __name__ == "__main__": main() ``` 此脚本会对管道输入的所有文本进行分词并统计每个单词出现的次数[^2]。 ---