延遲時間的Python隊列

Question

我有一臺運行在Django上的web服務器。 用戶可以創建推遲的事件。

這些事件必須記錄在隊列中並在另一臺服務器上處理。

最初我以爲要採取扭曲。例如：

#client - django server 
factory = pb.PBClientFactory() 
reactor.connectTCP(server_ip, server_port, factory) 
d = factory.login(credentials.UsernamePassword(login, paswd),) 
d.addCallbacks(self.good_connected,self.bad_connected) 
d.addCallback(self.add_to_queue) 
reactor.run() 

def add_to_queue(self, p) 
    p.callRemote("pickup", data) 


#server - twisted server 
def perspective_pickup(self, data) 
    reactor.callLater(timeout, self.pickup_from_queue) 

但現在我對這種方法有很大的懷疑。也許不要使用扭曲？或者用Django以不同的方式連接它

Answer 1

無論如何，在Django中運行扭曲並不是一個好主意。因此，請嘗試Celery或運行扭曲的HTTP服務器，並在django端使用urllib將數據發送到扭曲的服務器。