1

我正在尝试使用 Python 创建一个工具，用于使用 Raspberry Pi 对 CF 卡进行映像。

在我使用dd.

当我尝试通过管道输出gzipto时，dd我失去了戳dd过程并取得进展的能力。

我尝试使用多个子进程，但不断出现管道损坏或没有此类文件错误。

下面是我的代码：

#!/usr/bin/env python
from Adafruit_CharLCD import Adafruit_CharLCD
import os
import sys
import time
import signal
from subprocess import Popen, PIPE
lcd = Adafruit_CharLCD()
lcd.begin(16,2)
imgpth = '/home/pi/image/image_V11.img.gz'
line0 = ""
line1 = ""
q = 0
r = 0
s = 0

def lcdPrint(column, row, message, clear=False):
    if ( clear == True ):
        lcd.clear()

    lcd.setCursor(column, row)
    lcd.message(message)

lcd.clear()                 
lcdPrint(0, 0, 'Preparing Copy', True)
lcdPrint(0, 1, '')

gz = Popen(['gunzip -c /home/pi/image/image_V11.img.gz'], stdout=PIPE)
dd = Popen(['dd of=/dev/sda'],stdin=gz.stdout, stderr=PIPE)                     

filebyte = os.path.getsize(imgpth)                                  
flsz = filebyte/1024000 

while dd.poll() is None:                                        
    time.sleep(1)
    dd.send_signal(signal.SIGUSR1)
    while 1:                                            
        l = dd.stderr.readline()
    if '(' in l:                                            
        param, value = l.split('b',1)                           
        line1 = param.rstrip()                              
        r = float(line1)                                    
        s = r/1024000
        break
lcdPrint(0, 0, 'Copying....', True)
q = round(s/flsz*100, 2)                                
per = str(q)        

lcdPrint(0, 1, per + '% Complete',)

lcdPrint(0, 0, 'Copy Complete', True)   
time.sleep(1)
exit()

我怎样才能解决这个问题？

4

1 回答 1

0

我偶然发现了这个问题，因为我正在做同样的事情。我的完整解决方案在这里：

我试图找出我所拥有的和你所拥有的之间的一些差异，这些差异可能会向你展示解决方案。

启动 dd 时，我将 stderr 和 stdout 都重定向到了管道。

dd = subprocess.Popen(['dd', 'of=/dev/sda', 'bs=1M'], bufsize=1, stdin=unzip.stdout, stdout=PIPE, stderr=STDOUT)

我不认为这真的应该有所作为。你需要的一切都应该去stderr，但由于某种原因，它似乎对我来说很混乱。

我使用一个单独的线程来获取 dd 的输出：

def read_pipe(out, queue):
    for line in iter(out.readline, b''):
        queue.put(str(line))
    out.close()

dd_queue = queue.Queue()
dd_thread = threading.Thread(target = read_pipe, args=(dd.stdout, dd_queue))
dd_thread.daemon = True
dd_thread.start()

然后当你打电话时：

dd.send_signal(signal.SIGUSR1)

输出被 dd_queue 捕获。

我还发现 gzip 文件的未压缩大小存储在最后 4 个字节中：

fl = open(str(imgpath), 'rb')
fl.seek(-4, 2)
r = fl.read()
fl.close()
size = struct.unpack('<I', r)[0]

os.path.getsize(imgpth) 只会给你压缩后的大小，所以百分比计算是错误的。

于 2014-01-24T22:10:36.053 回答