如何将HackRF输出的uint8原始流通过Linux管道接入Python程序？

我之前也碰到过类似的需求——把HackRF输出的原始二进制流接入Python做中间处理，再传给其他应用。其实用Python的sys和subprocess两个标准库就能完美解决，不用额外装包。下面一步步给你讲怎么做：

核心思路 #

1. 从Shell管道读取HackRF输出的原始uint8字节流（注意是二进制，不是文本）
2. 在Python里对字节流做自定义处理（抽取、滤波、转换等）
3. 把处理后的字节流转发给目标子进程，或者再通过管道输出给其他Shell命令

完整代码示例 #

import sys
import subprocess

def process_hackrf_data(raw_data):
    """这里写你的自定义处理逻辑，输入是bytes对象，输出也是bytes对象"""
    # 示例1：抽取每2个字节中的第一个（降采样一半）
    processed = raw_data[::2]
    
    # 示例2：阈值过滤，只保留大于127的字节（替换成你需要的逻辑）
    # processed = bytes([b if b > 127 else 0 for b in raw_data])
    
    return processed

def main():
    # 如果你要把数据转发给某个子进程（比如另一个处理程序），可以这样启动它
    # 替换成你的目标应用命令，比如["another_application", "--arg1", "value"]
    target_process = subprocess.Popen(
        ["cat"],  # 用cat做测试，实际替换成你的应用
        stdin=subprocess.PIPE,
        bufsize=0  # 无缓冲，实时转发数据
    )
    
    try:
        # 循环读取管道数据，每次读4096字节（可根据需求调整）
        while True:
            raw_bytes = sys.stdin.buffer.read(4096)
            if not raw_bytes:
                break  # 数据流结束
            
            # 处理数据
            processed_bytes = process_hackrf_data(raw_bytes)
            
            # 把处理后的数据写入目标进程的stdin
            if processed_bytes:
                target_process.stdin.write(processed_bytes)
                target_process.stdin.flush()  # 确保数据立即发送，不缓冲
                
    except KeyboardInterrupt:
        # 捕获Ctrl+C，优雅关闭进程
        print("\nStopping...")
    finally:
        # 清理资源
        target_process.stdin.close()
        target_process.wait()

if __name__ == "__main__":
    main()

使用方法 #

方式1：Python脚本作为中间管道，转发给Shell命令 #

直接在Shell里把HackRF的输出管道到你的Python脚本，再管道到目标应用：

hackrf_transfer -r /dev/stdout -f 92700000 -s 8000000 - | python3 your_script.py | another_application

这种情况下，你可以把代码里的target_process部分删掉，直接把处理后的数据写到sys.stdout.buffer：

# 替换main函数里的转发逻辑
sys.stdout.buffer.write(processed_bytes)
sys.stdout.buffer.flush()

方式2：在Python里直接启动目标子进程 #

如果你的目标应用需要由Python直接启动（比如需要传递特定参数），就用代码里的subprocess.Popen方式，直接运行：

hackrf_transfer -r /dev/stdout -f 92700000 -s 8000000 - | python3 your_script.py

关键细节说明 #

• 用sys.stdin.buffer而非sys.stdin：因为HackRF输出的是原始二进制uint8流，sys.stdin默认是文本模式，会把字节转成字符串并处理换行符，破坏原始数据。buffer属性直接操作字节流，不会做任何转换。
• 缓冲设置：bufsize=0让子进程的stdin无缓冲，确保数据实时转发，适合实时信号处理场景。
• 分块读取：每次读4096字节（或其他合适的块大小），避免一次性读入大量数据占用内存，同时保证处理效率。

你只需要把process_hackrf_data函数里的逻辑替换成你自己的抽取或处理逻辑就行，比如抽取特定位置的字节、做简单的数学运算、或者转换成其他格式。

内容的提问来源于stack exchange，提问作者user6754791