python - Twisted:建议使用需要的 txredisapi 库

Question

下面我提供了一个代码示例，它使用来自 Redis 的数据简单地响应 HTTP GET 请求:

请求: http://example.com:8888/?auth=zefDWDd5mS7mcbfoDbDDf4eVAKb1nlDmzLwcmhDOeUc响应: get: u'"True"'

这段代码的目的是作为一个 REST 服务器(这就是我使用 lazyConnectionPool 的原因)响应请求，并使用来自 Redis 的数据(读/写)。

我需要做的:

1. 在 IndexHandler 的 render_GET 中对 Redis 运行多个请求(如 GET、HMGET、SET 等)
2. 在 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)

Answer 1

关于第一个问题:

有几种方法可以概括为在单个 HTTP 请求中发出多个数据库请求。

例如，您可以发出多个请求:

d1 = self.db.hget(auth, 'user_add')
d2 = self.db.get('foo')

然后，当所有这些同时 请求完成时，您可以获得回调以触发(参见twisted.internet.defer.DeferredList)。

或者，如果您需要顺序 请求，您可以使用inlineCallbacks。例如:

@inlineCallbacks
def do_redis(self):
    foo = yield self.db.get('somekey')
    bar = yield self.db.hget(foo, 'bar') # Get 'bar' field of hash foo

但是您需要阅读更多有关将 inlineCallbacks 与 twisted.web 相结合的内容(关于该主题，您应该查阅 SO questions)。

关于问题2:

如果不使用 inlineCallbacks，事务真的很难看。在 txredisapi homepage 有一个例子使用 inlineCallbacks 显示它。