Tornado Async Aufruf an eine Funktion

Question

Ich mache eine Web-Anwendung mit Python + Tornado, die im Grunde Dateien an Benutzer dient. Ich habe keine Datenbank.

Die Dateien werden entweder direkt abgeholt und bedient, wenn sie verfügbar sind, oder spontan generiert, wenn nicht.

Ich möchte, dass die Clients in einer asynchronen Weise bedient werden, weil einige Dateien möglicherweise bereits verfügbar sind, während andere generiert werden müssen (also müssen sie warten, und ich möchte nicht, dass sie andere Benutzer blockieren).

Ich habe eine Klasse, die die Kommissionierung oder Generierung von Dateien verwaltet, und ich muss nur von Tornado anrufen.

Was ist der beste Weg (am effizientesten auf CPU und RAM), um das zu erreichen? Soll ich einen Thread verwenden? Ein Unterprozess? Eine einfache gen.Task like this one?

Außerdem möchte ich, dass meine Implementierung in Google App Engines funktioniert (ich denke, sie erlauben nicht, dass Unterprozesse erzeugt werden?).

Ich bin relativ neu in der async Web-Service, so dass jede Hilfe willkommen ist. Das genTask Beispiel ist in der Tat der beste Weg, einen Asynchron-Aufruf zu implementieren, und es ist aufgrund der Tatsache, dass das Beispiel eines Python Koroutine zu verwenden ist, die ich didn‘:

Answer 1

Ich habe die Antworten auf meine Fragen gefunden t verstehe auf den ersten Blick, weil ich dachte Ausbeute wurde nur verwendet, um einen Wert für Generatoren zurückgeben.

Konkretes Beispiel:

class MyHandler(tornado.web.RequestHandler): 

    @asynchronous 
    @gen.engine 
    def get(self): 
     response = yield gen.Task(self.dosomething, 'argument') 

Was wichtig ist, ist hier die Kombination von zwei Dingen:

• Ausbeute, die in der Tat eine Koroutine laicht (oder pseudo-Thread, der ist sehr effizient und sind sehr parallel-freundlich). http://www.python.org/dev/peps/pep-0342/

• gen.Task(), die eine nicht-blockierende (async) Funktion, denn wenn man eine Koroutine auf einer Sperrfunktion laichen, wird es nicht async sein. gen.Task() wird von Tornado zur Verfügung gestellt, speziell um mit der Coroutinsyntax von Python zu arbeiten. Mehr Infos: http://www.tornadoweb.org/documentation/gen.html

So ein kanonisches Beispiel eines Asynchron-Aufruf in Python mit Koroutinen:

response = yield non_blocking_func(**kwargs) 

Answer 2

Jetzt Documentation haben Lösung.

Einfaches Beispiel:

import os.path 
import tornado.web 
from tornado import gen 

class MyHandler(tornado.web.RequestHandler): 

    @gen.coroutine 
    def get(self, filename): 
     result = yield self.some_usefull_process(filename) 
     self.write(result) 

    @gen.coroutine 
    def some_usefull_process(self, filename): 
     if not os.path.exists(filename): 
      status = yield self.generate_file(filename) 
      result = 'File created' 
     else: 
      result = 'File exists' 

     raise gen.Return(result) 

    @gen.coroutine 
    def generate_file(self, filename): 
     fd = open(filename, 'w') 
     fd.write('created') 
     fd.close()