Jak przenieść żądanie db (które wykorzystuje wydajność) w innej funkcji?

Question

Gram z tornadem i mongodb, z asynchronicznym silnikiem kierowcy. Podczas pracy z callbackami wszystko jest w porządku. Wtedy odkryłem możliwość korzystania motor.Op lub tornado.gen.Task wykonać wniosek w jednej funkcji tylko:

Tak to działa:

class Contact_handler(Main_handler): 

    @web.asynchronous 
    @gen.coroutine 
    def get(self, other_id): 

     event = events.Event_send_contact_request(self.user_id) 
     result = yield motor.Op(db.users.update, 
        {'_id': ObjectId(other_id)}, 
        {'$push': {'evts': event.data}} 
        ) 

     self.finish("ok") 

Ale chciałbym, aby przenieść tę bazę danych żądanie w swojej własnej funkcji w innym module. Problem polega na tym, że naprawdę nie rozumiem, jak działa tutaj wydajność (mimo, że czytałem DUŻO pytań dotyczących plonów). Więc to próbowałem, ale to nie działa:

#------ file views.py ------------- 

class Contact_handler(Main_handler): 

    def get(self, other_id): 

     event = events.Event_send_contact_request(self.user_id) 
     result = model.push_event_to_user(other_id, event) 

     self.finish("ok") 

a połączenia w innej funkcji:

#------ file model.py ------------- 

@gen.coroutine 
def push_event_to_user(user_id, event): 

    ## Ajout de la demande dans les events du demandé: 
    yield motor.Op(db.users.update, 
        {'_id': ObjectId(user_id)}, 
        {'$push': {'evts': event}} 
        ) 

Gdybym zbadać z WPB:

(Pdb) l 
157    event = events.Event_send_contact_request(self.user_id) 
158    result = model.push_event_to_user(other_id, event) 
159    
160    import pdb; pdb.set_trace() 
161    
162 ->   self.finish("ok") 
163   

(Pdb) result 
<tornado.concurrent.TracebackFuture object at 0xa334b8c> 
(Pdb) result.result() 
*** Exception: DummyFuture does not support blocking for results 

Każda pomoc docenione , dzięki.

Answer 1

Znalazłem inny sposób robienia tego, dzięki this post, który używa tornado.gen.Return. Nadal muszę realizować swoją główną funkcję, ale program jest prosty.

Oto mój kod teraz:

#------ file views.py ------------- 

@web.asynchronous 
@gen.coroutine 
class Contact_handler(Main_handler): 

    def get(self, other_id): 

     event = events.Event_send_contact_request(self.user_id) 
     result = yield model.push_event_to_user(other_id, event) 

     self.finish("ok") 

i wezwanie w innej funkcji:

#------ file model.py ------------- 

@gen.coroutine 
def push_event_to_user(user_id, event): 

    ## Ajout de la demande dans les events du demandé: 
    result = yield motor.Op(db.users.update, 
          {'_id': ObjectId(user_id)}, 
          {'$push': {'evts': event}} 
          ) 
    raise gen.Return(result)