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
?