下面我提供了一个代码示例,它使用来自 Redis 的数据简单地响应 HTTP GET 请求:
请求: http://example.com:8888/?auth=zefDWDd5mS7mcbfoDbDDf4eVAKb1nlDmzLwcmhDOeUc
响应: get: u'"True"'
此代码的目的是用作响应请求的 REST 服务器(这就是我使用lazyConnectionPool 的原因),并使用来自 Redis 的数据(读/写)。
我需要做什么:
- 在 IndexHandler 的 render_GET 中对 Redis 运行多个请求(如 GET、HMGET、SET 等)
- 在 IndexHandler 的 render_GET 内的事务中运行多个请求
我尝试了多种方法来做到这一点(包括来自 txredisapi 库的示例),但由于缺乏经验未能做到这一点。您能否就问题 1) 和 2) 提出建议。
提前致谢。
import txredisapi as redis
from twisted.application import internet
from twisted.application import service
from twisted.web import server
from twisted.web.resource import Resource
class Root(Resource):
isLeaf = False
class BaseHandler(object):
isLeaf = True
def __init__(self, db):
self.db = db
Resource.__init__(self)
class IndexHandler(BaseHandler, Resource):
def _success(self, value, request, message):
request.write(message % repr(value))
request.finish()
def _failure(self, error, request, message):
request.write(message % str(error))
request.finish()
def render_GET(self, request):
try:
auth = request.args["auth"][0]
except:
request.setResponseCode(404, "not found")
return ""
d = self.db.hget(auth, 'user_add')
d.addCallback(self._success, request, "get: %s\n")
d.addErrback(self._failure, request, "get failed: %s\n")
return server.NOT_DONE_YET
# Redis connection parameters
REDIS_HOST = '10.10.0.110'
REDIS_PORT = 6379
REDIS_DB = 1
REDIS_POOL_SIZE = 1
REDIS_RECONNECT = True
# redis connection
_db = redis.lazyConnectionPool(REDIS_HOST, REDIS_PORT, REDIS_DB, REDIS_POOL_SIZE)
# http resources
root = Root()
root.putChild("", IndexHandler(_db))
application = service.Application("web")
srv = internet.TCPServer(8888, server.Site(root), interface="127.0.0.1")
srv.setServiceParent(application)