如何推遲在龍捲風中執行python任務？

Question

我有一個互聯網網站在龍捲風上運行，具有視頻功能（轉換，剪切，合併）。

這段視頻是非常長的，所以我想把它移動到另一個python進程，並儘可能保持龍捲風過程。

我將mongo數據庫用於通信db功能，同步，因爲db將保持輕微。

Answer 1

使用芹菜推遲任務

video.py：

@task 
def convert(video): 
    ... 

tornadoserver.py

import video 
... 
def get(self): 
    paramvideo=... 
    convert.delay(paramvideo) 
    ... 

Answer 2

使用蒙戈推遲任務

video.py：

def convert(): 
    ... 
db = Connection().my_db 
cursor = db.tasks.find(tailable=True) 
while cursor.alive: 
    try: 
     next = cursor.next() 
     if next.t=='convert': 
      convert(next.d) 
    except StopIteration: 
     time.sleep(1) 

tornadoserver.py

... 
def get(self): 
    ... 
    paramvideo=... 
    conn.tasks.insert({t:'convert',d:paramvideo})