Python queue с задержкой

Question

У меня есть веб-сервер, работающий на Django. Пользователи могут создавать события, отложенные во времени.

Эти события должны быть записаны в очередь и обработаны на другом сервере.

Первоначально я думал взять витую. что-то вроде:

#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-сервер с скрученным и используйте urllib на стороне django для отправки данных на витой сервер.