python - 如何在 Python 中编写轮询函数？

Question

我正在尝试编写一个函数，每 1 分钟读取一次变量并返回每次的值。变量名为 proc:

proc = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', '--info=progress2', source12, destination], 
                                    stderr=subprocess.PIPE, stdout=subprocess.PIPE).communicate()[0]

进度存储在 proc 变量中。我希望函数每 1 分钟轮询一次变量并返回值。这样做直到变量被执行。最好的方法是什么？

尝试使用:

def doWork():
    while True:
        proc = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', '--info=progress2', source12, destination], 
                                    stderr=subprocess.PIPE, stdout=subprocess.PIPE).communicate()[0]stdout=subprocess.PIPE).communicate()[0]
        data = sort(proc)
        print data 
        time.sleep(10)

虽然运气不好!它同时打印整个进度并循环。

Answer 1

下面的代码将运行 rsync 并在命令可用时读取命令的任何输出。我使用 rsync 的 --progress 选项让它打印出它的进度。进度更新有时以 \n 结尾，有时以 \r 结尾。因此，我阅读单个字符，然后通过查找这两个字符中的任何一个来形成每一行字符。每当遇到新的进度线时，我都会将其打印到屏幕上。您可以选择执行任何操作，例如解析完成百分比和显示图形进度条。如果您有兴趣了解如何在终端中生成进度条 check this answer out .我放了一个同步函数的示例调用和示例输出。

代码

from subprocess import Popen, PIPE

def sync(src, dest, passwd):
    cmd = ['sshpass', '-p', passwd, 'rsync', '-avz', '--progress', src, dest]
    p = Popen(cmd, stdout=PIPE)
    line = ''
    while True:
        c = p.stdout.read(1)
        if not c:
            break
        if c in ['\n', '\r']:
            print 'rsync progress: %s' % line
            line = ''
        else:
            line += c

sync('/path/big.txt', 'myserver:/path/', 'mypassword')

输出

rsync progress: sending incremental file list
rsync progress: big.txt
rsync progress: 
rsync progress:        32768   0%    0.00kB/s    0:00:00  
rsync progress:     65798144  31%   62.72MB/s    0:00:02  
rsync progress:    131596288  62%   62.77MB/s    0:00:01  
rsync progress:    197427200  94%   62.79MB/s    0:00:00  
rsync progress:    209715200 100%   62.80MB/s    0:00:03 (xfer#1, to-check=0/1)
rsync progress: 
rsync progress: sent 204032 bytes  received 31 bytes  45347.33 bytes/sec
rsync progress: total size is 209715200  speedup is 1027.70