0
我正在寻找管道HTTP POST或PUT的内容到STDIN的过程。我使用的克莱因库,并有下面的代码:管道扭曲的请求内容到STDIN的过程
from klein import run, route
from twisted.internet import reactor, defer, protocol
import os
class CurlProcProtocol(protocol.ProcessProtocol):
def __init__(self, data):
self.data = data
def connectionMade(self):
self.transport.write(self.data)
self.transport.closeStdin()
def outReceived(self, data):
return 'got ' + str(data)
@route('/')
def home(request):
d = defer.Deferred()
reactor.spawnProcess(CurlProcProtocol(request.channel),
'/usr/bin/curl',
args=['curl', '-T', '-', 'ftp://localhost/test.txt'],
env={'HOME': os.environ['HOME']},
usePTY=False)
d.addCallback(reactor.run)
return d
run("localhost", 8080)
我挣扎的问题是什么Request
一部分我通过了我的CurlProcProtocol
,以及如何再依次把它传递给self.transport
?