データ構造で応答またはタイムアウトを検索する非同期リクエストを処理する単純なhttpサーバーを作成しようとしています。
- リクエストが届きます
- 時間<タイムアウトの間、responseCollectorの応答を確認します（requestIdをキーとして使用）
- 応答する場合は、それを返します
- タイムアウトした場合は、タイムアウトメッセージを返します
私はツイストに不慣れで、非同期応答を行うための最良の方法は何であるか疑問に思っています。ねじれたDeferredドキュメントとcallLaterをいくつか調べましたが、正確に何をすべきかがわかりませんでした。現在、deferToThreadを使用してブロッキングメソッドを実行し、タイムアウトが経過するのを待ちます。据え置きメソッドで文字列呼び出し不可エラーが発生します：
Unhandled error in Deferred:
Traceback (most recent call last):
File "/System/Library/Frameworks/Python.framework/Versions/2.6/lib/python2.6/threading.py", line 497, in __bootstrap
self.__bootstrap_inner()
File "/System/Library/Frameworks/Python.framework/Versions/2.6/lib/python2.6/threading.py", line 522, in __bootstrap_inner
self.run()
File "/System/Library/Frameworks/Python.framework/Versions/2.6/lib/python2.6/threading.py", line 477, in run
self.__target(*self.__args, **self.__kwargs)
--- <exception caught here> ---
File "/System/Library/Frameworks/Python.framework/Versions/2.6/Extras/lib/python/twisted/python/threadpool.py", line 210, in _worker
result = context.call(ctx, function, *args, **kwargs)
File "/System/Library/Frameworks/Python.framework/Versions/2.6/Extras/lib/python/twisted/python/context.py", line 59, in callWithContext
return self.currentContext().callWithContext(ctx, func, *args, **kw)
File "/System/Library/Frameworks/Python.framework/Versions/2.6/Extras/lib/python/twisted/python/context.py", line 37, in callWithContext
return func(*args,**kw)
exceptions.TypeError: 'str' object is not callable
これが私のコードです：
from twisted.web import server, resource
from twisted.internet import reactor, threads
import json
import time
connectedClients = {}
responseCollector = {}
# add fake data to the collector
class FakeData(resource.Resource):
isLeaf = True
def render_GET(self, request):
request.setHeader("content-type", "application/json")
if 'rid' in request.args and 'data' in request.args:
rid = request.args['rid'][0]
data = request.args['data'][0]
responseCollector[str(rid)] = data
return json.dumps(responseCollector)
return "{}"
class RequestHandler(resource.Resource):
isLeaf = True
def render_GET(self, request):
#request.setHeader("content-type", "application/json")
if not ('rid' in request.args and and 'json' in request.args):
return '{"success":"false","response":"invalid request"}'
rid = request.args['rid'][0]
json = request.args['id'][0]
# TODO: Wait for data to show up in the responseCollector with same rid
# as our request without blocking other requests OR timeout
d = threads.deferToThread(self.blockingMethod(rid))
d.addCallback(self.ret)
d.addErrback(self.err)
def blockingMethod(self,rid):
timeout = 5.0
timeElapsed = 0.0
while timeElapsed<timeout:
if rid in responseCollector:
return responseCollector[rid]
else:
timeElapsed+=0.01
time.sleep(0.01)
return "timeout"
def ret(self, hdata):
return hdata
def err(self, failure):
return failure
reactor.listenTCP(8080, server.Site(RequestHandler()))
reactor.listenTCP(9080, server.Site(FakeData()))
reactor.run()
リクエストを行います（現在有用なものは何も返しません）：
http://localhost:8080/?rid=1234&json={%22foo%22:%22bar%22}
リクエストで使用する偽のデータを追加します。
http://localhost:9080/?rid=1234&data=foo
作業バージョンで更新
from twisted.web import server, resource
from twisted.internet import reactor, threads
import json
import time
connectedClients = {}
responseCollector = {}
# add fake data to the collector
class FakeData(resource.Resource):
isLeaf = True
def render_GET(self, request):
request.setHeader("content-type", "application/json")
if 'rid' in request.args and 'data' in request.args:
rid = request.args['rid'][0]
data = request.args['data'][0]
responseCollector[str(rid)] = data
return json.dumps(responseCollector)
return "{}"
class RequestHandler(resource.Resource):
isLeaf = True
def render_GET(self, request):
if not ('rid' in request.args and 'data' in request.args):
return '{"success":"false","response":"invalid request"}'
rid = request.args['rid'][0]
json = request.args['data'][0]
# TODO: Wait for data to show up in the responseCollector with same rid
# as our request without blocking other requests OR timeout
d = threads.deferToThread(self.blockingMethod,rid)
d.addCallback(self.ret, request)
d.addErrback(self.err)
return server.NOT_DONE_YET
def blockingMethod(self,rid):
timeout = 5.0
timeElapsed = 0.0
while timeElapsed<timeout:
if rid in responseCollector:
return responseCollector[rid]
else:
timeElapsed+=0.01
time.sleep(0.01)
return "timeout"
def ret(self, result, request):
request.write(result)
request.finish()
def err(self, failure):
return failure
reactor.listenTCP(8080, server.Site(RequestHandler()))
reactor.listenTCP(9080, server.Site(FakeData()))
reactor.run()