vorlauf 1.0.0

是什么？

Vorlauf是一个非常小巧的工具，可以帮助你创建进程管道（在shell意义上）。它还帮助分离出进程的定义和运行该进程的过程，包括给定的stdin、stdout和stderr。

为什么？

因为链式连接进程的subprocess API很繁琐，而且文档也不太完善。

怎么做？

这个库基本上什么也不做——它的实现不到100行。有两个类可用，分别是Process和Pipeline。

critical_grepper = Process('grep', 'CRITICAL')

syslog = open('/var/log/syslog', 'r')
apachelog = open('/var/log/httpd/error.log', 'r')

filtered = open('critical.log', 'w')

for logfile in (syslog, apachelog):
  critical_grepper.run(stdin=logfile, stdout=filtered)

示例

from vorlauf import Pipeline, Process

pipeline = Pipeline()
pipeline.add(Process('cat', 'foo.txt'))
pipeline.add(Process('grep', 'something'))
pipeline.add(Process('uniq'))

with open('new.txt', 'wb') as fd:
    pipeline.run(stdout=fd)

由于Process和Pipeline类内置了操作符重载，这可以简化为

from vorlauf import Process as P

pipeline = P('cat', 'foo.txt') | P('grep', 'something') | P('uniq')
with open('new.txt', 'wb') as fd:
    pipeline.run(stdout=fd)

最后，您可以使用Process类创建可重用组件

from vorlauf import Process

class GPG(Process):

    def __init__(self, passphrase):
        super(GPG, self).__init__('gpg', '-c', '--passphrase', passphrase, '-')


class MySQLDump(Process):

    def __init__(self, password, dbname, **kwargs):
        super(MySQLDump, self).__init__(
            'mysqldump', '-u', 'root', '-p{}'.format(password), dbname
        )


with open('mysql.dump', 'wb') as fd:
    pipeline = MySQLDump('loldongs', 'foo') | GPG('supersekrit')
    pipeline.run(stdout=fd)

测试

运行

virtualenv venv
venv/bin/pip install -e .
venv/bin/python test.py