0
Je cherche à canaliser le contenu d'un HTTP POST ou PUT à STDIN d'un processus. J'utilise la bibliothèque Klein et ont le code suivant:Pipe Twisted Demande de contenu à STDIN du processus
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)
Le problème que je me bats avec ce que une partie de Request
passe-je dans mon CurlProcProtocol
, et comment à son tour passer à self.transport
?