1

下面是我尝试以非阻塞方法从 get 请求写入 redis 的代码。下面也是我得到的错误。这是一个 500 错误。我只是不明白旋风附带的 txredisapi 的文档。它确实写入了redis，但应用程序

import cyclone.web
import sys
from twisted.internet import reactor
from twisted.python import log
import cyclone.redis as redis
from twisted.internet import defer
from twisted.internet import reactor

@defer.inlineCallbacks
def redisPixelWrite(remote_ip):
    rc = yield redis.Connection()
    yield rc.set("foo", 'itwodasdfred')
    v = yield rc.get("foo")
    print "foo:", v
    yield rc.disconnect()

class Application(cyclone.web.Application):
    def __init__(self):
        handlers = [
            (r"/", MainHandler),
        ]
        settings = {"xheaders": True,"static_path": "./static"}
        cyclone.web.Application.__init__(self, handlers, **settings)       

class MainHandler(cyclone.web.RequestHandler):
    def get(self):
        remote_ip = self.request.remote_ip
        redisPixelWrite(remote_ip).addcallback()
        self.set_header('Content-Type', 'text/html')
        self.write(remote_ip)

def main():
    log.startLogging(sys.stdout)
    reactor.listenTCP(8051, Application(), interface="127.0.0.1")
    reactor.run()

if __name__ == "__main__":
    main()


2012-05-07 21:12:10+0800 [-] Log opened.
2012-05-07 21:12:10+0800 [-] Application starting on 8051
2012-05-07 21:12:10+0800 [-] Starting factory <__main__.Application instance at 0x228af38>
2012-05-07 21:12:14+0800 [HTTPConnection,0,127.0.0.1] Starting factory <cyclone.redis.RedisFactory instance at 0x261a680>
2012-05-07 21:12:14+0800 [HTTPConnection,0,127.0.0.1] Uncaught exception GET / (127.0.0.1) :: HTTPRequest(protocol='http', host='127.0.0.1:8051', method='GET', uri='/', version='HTTP/1.1', remote_ip='127.0.0.1', body='', headers={'Connection': 'keep-alive', 'Accept-Language': 'en-us,en;q=0.5', 'Accept-Encoding': 'gzip, deflate', 'Cache-Control': 'max-age=0', 'Host': '127.0.0.1:8051', 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8', 'User-Agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:11.0) Gecko/20100101 Firefox/11.0'})
2012-05-07 21:12:14+0800 [HTTPConnection,0,127.0.0.1] 500 GET / (127.0.0.1) 2.07ms
2012-05-07 21:12:14+0800 [RedisProtocol,client] foo: itwodasdfred
2012-05-07 21:12:14+0800 [RedisProtocol,client] Stopping factory <cyclone.redis.RedisFactory instance at 0x261a680>
4

2 回答 2

2

你错过了代码中的一些东西。

  1. 该get函数必须用 装饰inlineCallbacks，并且应该yield redisPixelWrite(remote_ip)
  2. 您可能不想在每次请求时都与 redis 建立新连接。设置持久连接池并在新请求上重用它更有效。

这可能是您正在寻找的：

import cyclone.redis
import cyclone.web
import sys

from twisted.python import log
from twisted.internet import defer
from twisted.internet import reactor


class RedisMixin(object):
    redis = None

    @classmethod
    def setup(self):
        RedisMixin.redis = cyclone.redis.lazyConnectionPool()


class Application(cyclone.web.Application):
    def __init__(self):
        handlers = [(r"/", MainHandler)]
        RedisMixin.setup()
        settings = {"debug": True, "xheaders": True, "static_path": "./static"}
        cyclone.web.Application.__init__(self, handlers, **settings)


class MainHandler(cyclone.web.RequestHandler, RedisMixin):
    @defer.inlineCallbacks
    def get(self):
        try:
            yield self.redis.set("foo", self.request.remote_ip)
            ip = yield self.redis.get("foo")
        except:
            raise cyclone.web.HTTPError(503)  # Service Unavailable
        else:
            self.set_header('Content-Type', 'text/html')
            self.write(ip)


def main():
    log.startLogging(sys.stdout)
    reactor.listenTCP(8051, Application(), interface="127.0.0.1")
    reactor.run()

if __name__ == "__main__":
    main()

请注意，所有Connection方法的默认行为是在 redis 停止或重新启动时自动重新连接。它将以 HTTP 503（服务不可用）响应，直到重新建立连接并恢复与 redis 的通信。

于 2012-06-11T06:38:33.280 回答
1

这一行：

redisPixelWrite(remote_ip).addcallback()

提高AttributeError。您可能应该针对 Cyclone 提交错误报告，因为它应该在某处报告此问题（或者，确保您实际上正在查看将报告异常的日志）。

redisPixelWrite返回 aDeferred因为它用inlineCallbacks. 上没有addcallback方法Deferred。有一种addCallback方法，我想这可能是你想要使用的。但是，它至少需要一个参数，而不是零，因此您还需要修复它。

于 2012-05-08T12:50:48.177 回答