एक चल रहे पायथन डेमन

Question

के साथ संचार करना मैंने एक छोटा पायथन एप्लिकेशन लिखा जो डेमन के रूप में चलता है। यह थ्रेडिंग और कतार का उपयोग करता है।

मैं इस एप्लिकेशन को बदलने के लिए सामान्य दृष्टिकोण की तलाश में हूं ताकि मैं इसे चलाने के दौरान इसके साथ संवाद कर सकूं। अधिकतर मैं अपने स्वास्थ्य की निगरानी करने में सक्षम होना चाहता हूं।

संक्षेप में, मैं इस तरह कुछ करने के लिए सक्षम होने के लिए करना चाहते हैं:

python application.py check_queue_size # return info from the daemonized process 

:

python application.py start # launches the daemon 

बाद में, मैं के साथ आने के लिए सक्षम हो सकता है और कुछ ऐसा करना चाहते हैं

स्पष्ट होने के लिए, मुझे Django- प्रेरित वाक्यविन्यास को लागू करने में कोई समस्या नहीं है। मुझे क्या पता नहीं है कि कैसे करना है डिमनीकृत प्रक्रिया (प्रारंभ), या इस तरह के संकेतों को संभालने और प्रतिक्रिया देने के लिए डिमन लिखने के लिए सिग्नल भेजना है।

जैसा कि मैंने उपरोक्त कहा है, मैं सामान्य दृष्टिकोण की तलाश में हूं। केवल एक ही मैं देख सकता हूं कि डिमन लगातार फाइल को जरूरी सबकुछ लॉग कर रहा है, लेकिन मुझे उम्मीद है कि इसके बारे में जाने के लिए एक कम गन्दा तरीका है।

अद्यतन: वाह, बहुत सारे अच्छे उत्तर। बहुत बहुत धन्यवाद। मुझे लगता है कि मैं पाइरो और web.py/Werkzeug दृष्टिकोण दोनों को देखूंगा, क्योंकि ट्विस्टेड इस बिंदु पर काटने से थोड़ा अधिक है। मुझे लगता है कि अगली वैचारिक चुनौती, मुझे अपने लटकने वाले धागे से बात करने के बारे में बात करने के बारे में है।

फिर से धन्यवाद।

Answer 1

इसे http सर्वर चलाने के बारे में क्या?

यह पागलपन है, लेकिन अपने सर्वर की व्यवस्था के लिए एक सरल वेब सर्वर चल रहा है बस कुछ ही web.py

तुम भी एक यूनिक्स पाइप बनाने पर विचार कर सकते हैं का उपयोग कर लाइनों की आवश्यकता है।

Answer 2

मान लें कि आप * निक्स के अंतर्गत हैं, आप एक शेल से kill के साथ चल रहे प्रोग्राम (और कई अन्य वातावरण में एनालॉग) के साथ एक चल रहे प्रोग्राम को सिग्नल भेज सकते हैं। उन्हें अजगर के भीतर से संभालने के लिए signal मॉड्यूल देखें।

Answer 3

मैं एक नामित पाइप के साथ मुड़कर उपयोग करता हूं या बस एक सॉकेट खोलता हूं। गूंज सर्वर और क्लाइंट examples पर एक नज़र डालें। क्लाइंट द्वारा पारित कुछ स्ट्रिंग की जांच करने के लिए आपको गूंज सर्वर को संशोधित करने की आवश्यकता होगी और फिर जो भी अनुरोधित जानकारी के साथ जवाब दें।

पायथन के थ्रेडिंग मुद्दों के कारण आपको सूचना अनुरोधों का जवाब देने में परेशानी होगी, साथ ही साथ जो भी डेमॉन करने के लिए किया जाता है, वह करना जारी रखेगा। असीमित तकनीक या अन्य प्रक्रियाओं को फोर्क करना आपका एकमात्र वास्तविक विकल्प है।

Answer 4

# your server 

from twisted.web import xmlrpc, server 
from twisted.internet import reactor 

class MyServer(xmlrpc.XMLRPC): 

    def xmlrpc_monitor(self, params):   
     return server_related_info 

if __name__ == '__main__': 
    r = MyServer() 
    reactor.listenTCP(8080, Server.Site(r)) 
    reactor.run() 

ग्राहक xmlrpclib का उपयोग कर लिखा जा सकता है, उदाहरण के कोड here की जाँच करें।

Answer 5

werkzeug का उपयोग करें और अपने डेमॉन को HTTP- आधारित WSGI सर्वर शामिल करें।

आपके डेमॉन में स्थिति जानकारी के साथ प्रतिक्रिया देने के लिए छोटे डब्लूएसजीआई ऐप्स का संग्रह है।

आपका क्लाइंट बस POST बनाने या स्थानीयहोस्ट को अनुरोध प्राप्त करने के लिए urllib2 का उपयोग करता है: somePort। आपके ग्राहक और सर्वर को पोर्ट नंबर (और यूआरएल) पर सहमत होना चाहिए।

यह लागू करने और बहुत स्केलेबल करने के लिए बहुत आसान है। नए आदेश जोड़ना एक मामूली व्यायाम है।

ध्यान दें कि आपके डिमन को HTML में जवाब देना नहीं है (हालांकि यह अक्सर आसान होता है)। हमारे डेमॉन जेएसओएन-एनकोडेड स्टेटस ऑब्जेक्ट्स के साथ डब्लूएसजीआई-अनुरोधों का जवाब देते हैं।

Answer 6

फिर भी एक और दृष्टिकोण: Pyro (पायथन रिमोटिंग ऑब्जेक्ट्स) का उपयोग करें।

पायरो मूल रूप से आपको पाइथन ऑब्जेक्ट इंस्टेंस को उन सेवाओं के रूप में प्रकाशित करने की अनुमति देता है जिन्हें दूरस्थ रूप से कहा जा सकता है। मैंने आपके द्वारा वर्णित सटीक उद्देश्य के लिए पाइरो का उपयोग किया है, और मैंने इसे बहुत अच्छी तरह से काम करने के लिए पाया है।

डिफ़ॉल्ट रूप से, एक पाइरो सर्वर डिमन हर जगह से कनेक्शन स्वीकार करता है। इसे सीमित करने के लिए, या तो स्थानीय कनेक्शन के लिए सुनने के लिए Daemon कन्स्ट्रक्टर में कनेक्शन सत्यापनकर्ता (दस्तावेज़ीकरण देखें) का उपयोग करें, या host='127.0.0.1' की आपूर्ति करें।

उदाहरण Pyro प्रलेखन से लिया कोड:

सर्वर

 
import Pyro.core 

class JokeGen(Pyro.core.ObjBase): 
     def __init__(self): 
       Pyro.core.ObjBase.__init__(self) 
     def joke(self, name): 
       return "Sorry "+name+", I don't know any jokes." 

Pyro.core.initServer() 
daemon=Pyro.core.Daemon() 
uri=daemon.connect(JokeGen(),"jokegen") 

print "The daemon runs on port:",daemon.port 
print "The object's uri is:",uri 

daemon.requestLoop() 

ग्राहक

 
import Pyro.core 

# you have to change the URI below to match your own host/port. 
jokes = Pyro.core.getProxyForURI("PYROLOC://localhost:7766/jokegen") 

print jokes.joke("Irmen") 

एक और ऐसी ही परियोजना RPyC है। मैंने आरपीवाईसी की कोशिश नहीं की है।

Answer 7

आप इसे पायरो (http://pythonhosted.org/Pyro4/) पायथन रिमोट ऑब्जेक्ट से जोड़ सकते हैं। यह आपको पाइथन वस्तुओं को दूरस्थ रूप से एक्सेस करने देता है। यह आसानी से कार्यान्वित करने के लिए है, कम ओवरहेड है, और मुड़ के रूप में आक्रामक नहीं है।