트위스트로 두 번 연결하는 방법 - 올바르게 수행하는 방법?

Question

별표 서버에 연결하기 위해 twisted (별표 ami의 프로토콜 구현 인 StarPy)를 사용하고 싶습니다. 응용 프로그램에서 발신 팩스를 시작합니다. 내 문제에 대한 몇 가지 힌트를 찾았지만 올바르게 처리하는 방법을 찾을 수 없습니다.

첫 번째 팩스가 올바르게 발송됩니다.

문제는 내가 두 번째 트위스트 호출하는 경우, 응용 프로그램이 메인 루프에 걸려 을 유지합니다.

나는 내가 여기처럼 이렇게하지 않을 수 있습니다 알고

from starpy import manager 
from twisted.internet import reactor 

def main(): 
    f = manager.AMIFactory(cUser, cPass) 
    print "Login" 
    df = f.login(cServer, cPort) 

    def onLogin(protocol): 
     print "Logoff again" 
     df = protocol.logoff() 

     def onLogoff(result): 
      print "Logoff erfolgt" 
      reactor.stop() 

     return df.addCallbacks(onLogoff, onLogoff) 

    def onFailure(reason): 
     print "Login failed" 
     print reason.getTraceback() 

    df.addCallbacks(onLogin, onFailure) 
    return df 

if __name__ == "__main__": 
    reactor.callWhenRunning(main) 
    reactor.run(installSignalHandlers=0) 
    print "runned the first time" 

    reactor.callWhenRunning(main) 
    reactor.run(installSignalHandlers=0) 
    print "will never reach this point" 

내가 코드를 단순화 - 그것은 다시 로그인 + 로그 오프 것보다 ​​아무것도하지 않습니다. 그것은 두 번째 reactor.run() 호출에서 결코 돌아 오지 않을 것입니다.

어떻게 제대로 수행 할 수 있습니까? 나는 여기에 붙어있어 - 미리 감사드립니다.

안녕하십니까, 플로리안.

Answer 1

덕분에, 지금 당장 솔루션을 구현하지 않은하지만 난 지금 할 수있는 방법을 알고있다. 짧은

첫째, - 내가 트위스트와 함께했던 문제 :

1. 나는 트위스트의 비동기 기본을 이해하지 못했다. 나는 GUI 프레임 워크에서 그런 것을 사용했지만 오랫동안 이익을 보지 못했습니다.
2. 둘째, 이벤트 루프의 동기 호출을 여러 번 생각했습니다. 한 번에 둘 이상의 보내는 팩스 회선을 사용할 수 없기 때문에 이것은 내 마음에 필요했습니다. 꼬인 이벤트 루프는 재시작 할 수 없기 때문에 옵션이 없습니다. 문서에서 "deferToThread"를 읽으면 여기에서 도움이 될 수 있지만 최선의 해결책은 아니라고 생각합니다. 내 개념에서

나는 이러한 문제를 해결 :

• 제가 여기 예를 발견 1. 에 동시성을 제한 할 수 있습니다 defer.DeferredSemaphore()의 사용 : http://oubiwann.blogspot.com/2008/06/async-batching-with-twisted-walkthrough.html
• 호출을 임의로 비틀어서 Deferes가 업무를 수행하도록하십시오 (팩스 보내기)
• 팩스 상태를 데이터베이스에 쓰고 영수증을 보내려면
로 전화하십시오.

나는 많은 생각을 다시해야했지만 최대한 빨리 얻었습니다.

귀하의 도움을 위해 iny 및 Jean-Paul Calderone에게 감사드립니다.

Answer 2

원자로를 재시작 할 수 없습니다. 즉, reactor.run()을 한 번만 호출 할 수 있습니다.

대신 하나의 원자로에서 필요한 모든 작업을 수행 할 수 있습니다.

Answer 3

iny가 말했듯이 reactor.run과 reactor.stop을 한 번만 호출하면 모든 작업을 수행해야합니다. 우리는 당신이 게시 된 예제 코드를 고려하면

, 우리는 다음 단계에 소요되는 참조 :

정지에게 원자로를 분리

는, 원자로
• 연결을 시작 팩스를 보내
• 을
• 반응기 시작
• 팩스 연결, 연결 해제
• 중지 th 전자 우리는 3 단계와 4 단계를 삭제하면 다음 프로그램이 실제로 꽤 합리적인 일을 할 것입니다

반응.

reactor.callWhenRunning(main) 
reactor.run(installSignalHandlers=0) 

그래서, 일반적인 생각 : 4 단계의 구현을위한 길을 삭제,

def onLogoff(result): 
    print "Logoff erfolgt" 
    reactor.stop() 

이

가 reactor.run의 최초의 호출이 반환 원인 : 여기

은 3 단계를 구현하는 방법은 3 단계와 4 단계 대신 5 단계로 바로 넘어갈 것입니다. onLogoff을 다음과 같이 재정의하면 어떻게 될지 생각하십시오.

def onLogoff(result): 
    print "Logoff erfolgt" 
    main() 

및 예제의 마지막 세 줄을 삭제하십시오.두 번째 연결 해제 후 동일한 onLogoff이 실행되고 세 번째 연결을 시작하기 때문에 실제로 무한 루프가 발생합니다. 그러나 다시 시작 동작을 제어하기 위해 main 함수에 대한 매개 변수를 사용하여이 문제를 해결할 수 있습니다.

이 내용이 적합하면 main 기능과 __main__ 블록에 정의 된 콜백으로 재시도 로그 아웃을 이동하는 것이 좋습니다. 이것은 Deferreds의 강점 중 하나입니다. 이벤트 소스 구현 (이 경우 팩스 전송 기능)과 결과 이벤트 처리를위한 코드 (두 번째 팩스 전송 또는 이 경우 종료). 여기

에게 ... 내가 배운 것들의 짧은 요약을 귀하의 답변

Answer 4

아직도 해결책을 찾고 있다면 ... 나는 똑같은 문제가 있습니다. Twisted를 사용하여 원격 서버에서 프로그램을 실행하는 스크립트가 있습니다. 장고 애플리케이션 내에서 동 기적으로 스크립트를 실행하는 방법이 필요했습니다. 내가 한 일은 Twisted 스크립트가 원격 서버를 호출하고 stdout으로 출력하는 것입니다. 그런 다음 내 Django 응용 프로그램 내에서 Subprocess.Popen을 통해 해당 스크립트를 실행하고 표준 출력 = PIPE를 설정하여 Twisted 스크립트의 출력을 캡처하여 장고 응용 프로그램에서 사용할 수있게했습니다.

이것은 이상적인 것이 아니며 Twisted의 목적을 거의 무효로합니다. 그러나 Twisted 스크립트가 자체 프로세스로 실행되기 때문에 reactor.run()을 두 번째 호출 할 수 없게됩니다. 시간.

이것은 훌륭한 결과를 얻었으며, 당신이있는 상황과 매우 비슷하게 들린다. 나는 이것이 도움이되기를 바란다. 행운을 빌어. (행운을 빌어. 도움, 그냥 알려주세요).