3

mongo コレクションの読み取りへの非同期アクセスに Motor ドライバーを使用しました。アプリケーションを実行すると、None 値が返されます。PyMongo と同期して実行すると、正常に実行されます。私は両方の例に従いました: http://blog.mongodb.org/post/30927719826/motor-asynchronous-driver-for-mongodb-and-pythonとhttp://emptysquare.net/motor/pymongo/api /motor/tutorial.html .

ここに私のコードの一部があります:

import tornado.httpserver
import tornado.websocket
import tornado.ioloop
import tornado.web
import tornado.options
from tornado import gen
from bson import json_util
import json
import os.path
import motor

events = []

class WSHandler(tornado.websocket.WebSocketHandler):
    @tornado.web.asynchronous
    @gen.engine

    def open(self):
        import traceback
        global events
        print "tailing for events %s...." % events

        try:
            coll = db.blah_tail  
            cursor = coll.find(
                { "$and" : [
                        {"term": {"$in": events}}, 
                        { "$or" : [
                                {"coordinates.type" : "Point"}, 
                                {"place.full_name" : {"$ne" : None}}
                        ]}
                    ]}, 
                           {"coordinates" : 1, "place.full_name" : 1}, 
                            tailable = True, timeout  = False )      

            while cursor.alive:

                    try:
                        doc = yield motor.Op(cursor.next_object)
                        print doc
                        self.write_message(json.dumps(doc, default = json_util.default))
                    except StopIteration:
                        pass



db = motor.MotorConnection().open_sync().blah

if __name__ == "__main__":
    print 'Server is alive.....'
    app = tornado.web.Application(
    handlers=[(r'/', MainHandler),                                   
    (r'/ws', WSHandler)
    ], db=db,
    template_path=os.path.join(os.path.dirname(__file__), "templates"),
    debug=True)

    tornado.options.parse_command_line()
    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

Motor はアプリケーションを非同期にしますが、基本的にデータベース内のコレクションから何も読み取らない理由がわかりません。

ありがとう

4

1 に答える 1

2

コードを次のように修正することで修正できました：

doc = yield motor.Op(cursor.next_object)
if doc:
    print doc
    self.write_message(json.dumps(doc, default = json_util.default))

このため、最初の呼び出しでドキュメントが返されない場合は、Noneを返さないようにします。Motorの作成者による抜粋は、次のように説明しています。「問題は、cursor.aliveがTrueであるからといって、next_objectが実際にドキュメントを返すことを本当に保証するものではありません。見つかったドキュメントがまったく一致しない場合、最初の呼び出しはNoneを返します。 。"、（http://emptysquare.net/blog/category/motor/）。

于 2012-11-16T21:14:11.830 に答える