10

ファイルのダウンロード/アップロードに速度制限を設定しようとしていますが、twisted が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ました。私は Twisted を初めて使用し、別の方法でそれを行う方法がわかりません。

4

2 に答える 2

1

すべてのプロデューサーは、（最終的には）データを消費したいものに登録する必要があります。ここでは登録が行われていません。多分それはあなたが抱えている問題ですか？

Twistedは、Friendsterのようないくつかの大規模なプロジェクトで使用されていますが、すべてのコールバックは、Pythonで書く通常の方法ではうまくいきません（関数型プログラミングの経験もあります）。geventに切り替えました。

geventライブラリを使用している場合は、詳細（非同期機能を提供するコールバック/ジェネレーター）の多くが抽象化されているため、通常は、コードにモンキーパッチを適用して通常のオブジェクト指向スタイルで記述するだけで済みます。に慣れた。js / lispのようなコールバックの多い言語に慣れていない人と一緒にプロジェクトに取り組んでいるなら、彼らはツイストよりもgeventを高く評価するでしょう。

于 2012-11-30T14:51:32.143 に答える
1

egbutterが言ったように、プロデューサーを登録する必要があります。したがって、これの代わりに：

tsite.protocol.producer = producer

registerProducerメソッドを明示的に呼び出す必要があります。

tsite.protocol.registerProducer( ... )

または、FileSenderをプロデューサーとして使用している場合は、そのbeginFileTransferメソッドを呼び出します。

file_to_send = open( ... )
producer.beginFileTransfer(file_to_send, tsite.protocol)
于 2013-09-20T11:09:22.173 に答える