ट्विस्ट

Question

का उपयोग करके बैंडविड्थ थ्रॉटलिंग मैं फ़ाइलों को डाउनलोड/अपलोड करने पर गति सीमा निर्धारित करने की कोशिश कर रहा हूं और पाया कि मुड़ता इस काम को संभालने के लिए twisted.protocols.policies.ThrottlingFactory प्रदान करता है, लेकिन मैं इसे सही नहीं समझ सकता। मैंने readLimit और writeLimit सेट किया है, लेकिन फ़ाइल अभी भी अधिकतम गति पर डाउनलोड हो रही है। मैं क्या गलत कर रहा हूं?

from twisted.protocols.basic import FileSender 
from twisted.protocols.policies import ThrottlingFactory 
from twisted.web import server, resource 
from twisted.internet import reactor 
import os 

class DownloadPage(resource.Resource): 
    isLeaf = True 

    def __init__(self, producer): 
     self.producer = producer 

    def render(self, request): 
     size = os.stat(somefile).st_size 
     request.setHeader('Content-Type', 'application/octet-stream') 
     request.setHeader('Content-Length', size) 
     request.setHeader('Content-Disposition', 'attachment; filename="' + somefile + '"') 
     request.setHeader('Accept-Ranges', 'bytes') 

     fp = open(somefile, 'rb') 
     d = self.producer.beginFileTransfer(fp, request) 

     def err(error): 
      print "error %s", error 

     def cbFinished(ignored): 
      fp.close() 
      request.finish() 
     d.addErrback(err).addCallback(cbFinished) 

     return server.NOT_DONE_YET 


producer = FileSender() 
root_resource = resource.Resource() 
root_resource.putChild('download', DownloadPage(producer)) 
site = server.Site(root_resource) 
tsite = ThrottlingFactory(site, readLimit=10000, writeLimit=10000) 
tsite.protocol.producer = producer 
reactor.listenTCP(8080, tsite) 
reactor.run() 

अद्यतन

तो कुछ समय बाद मैं इसे चलाने

:

2012-10-25 09:17:03+0600 [-] Unhandled Error 
Traceback (most recent call last): 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/application/app.py", line 402, in startReactor 
     self.config, oldstdout, oldstderr, self.profiler, reactor) 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/application/app.py", line 323, in runReactorWithLogging 
     reactor.run() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/internet/base.py", line 1169, in run 
     self.mainLoop() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/internet/base.py", line 1178, in mainLoop 
     self.runUntilCurrent() 
    --- <exception caught here> --- 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/internet/base.py", line 800, in runUntilCurrent 
     call.func(*call.args, **call.kw) 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/protocols/policies.py", line 334, in unthrottleWrites 
     p.unthrottleWrites() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/protocols/policies.py", line 225, in unthrottleWrites 
     self.producer.resumeProducing() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/protocols/basic.py", line 919, in resumeProducing 
     self.consumer.unregisterProducer() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/web/http.py", line 811, in unregisterProducer 
     self.transport.unregisterProducer() 
     File "/home/chambylov/environments/transfer/local/lib/python2.7/site-packages/twisted/protocols/policies.py", line 209, in unregisterProducer 
     del self.producer 
    exceptions.AttributeError: ThrottlingProtocol instance has no attribute 'producer' 

मुझे लगता है कि मैं निर्माता आवंटित करने के लिए है कि मैं tsite.protocol.producer = producer पता है चाहिए नहीं कर रहा हूँ, मैं करने के लिए नया हूँ मुड़ गया और मुझे नहीं पता कि यह कैसे एक और तरीका है।

Answer 1

Every producer needs (eventually) to be registered with whatever you want to consume the data। मुझे यहां कहीं भी पंजीकरण नहीं दिख रहा है। शायद यही वह मुद्दा है जो आप कर रहे हैं?

ट्विस्टर का इस्तेमाल फ्रेंडस्टर जैसी कुछ बड़ी-कभी परियोजनाओं पर किया गया है, लेकिन सभी कॉलबैक सामान्य रूप से पायथन में लिखने के सामान्य तरीके से नहीं बैठते हैं (और मेरे पास कार्यात्मक प्रोग्रामिंग के साथ कुछ अनुभव है)। मैं gevent पर स्विच किया।

यदि आप गीवेंट पुस्तकालयों के साथ काम कर रहे हैं, तो कई विवरण (कॉलबैक/जनरेटर जो एसिंक्रोनस कार्यक्षमता प्रदान करते हैं) को समेकित किया जाता है, ताकि आप आम तौर पर अपने कोड को पैच करने और सामान्य ऑब्जेक्ट में लिखने के लिए बंद हो जाएं - केंद्रित शैली का उपयोग आप कर रहे हैं। यदि आप किसी परियोजना पर काम कर रहे हैं, जो कॉलबैक-भारी भाषा जैसे जेएस/लिस्प से अपरिचित है, तो मुझे लगता है कि वे मुड़ने पर भूगर्भ की सराहना करेंगे।

Answer 2

egbutter ने कहा, आपको एक निर्माता को पंजीकृत करना होगा। तो यह करने के बजाय:

tsite.protocol.producer = producer 

आप एक registerProducer विधि स्पष्ट रूप से कॉल करनी होगी:

tsite.protocol.registerProducer(...) 

या, यदि आप एक निर्माता के रूप में FileSender उपयोग कर रहे हैं, अपने beginFileTransfer विधि कॉल , हमारे मामले में:

file_to_send = open(...) 
producer.beginFileTransfer(file_to_send, tsite.protocol)