बस किसी भी OPC सर्वर सेंसर को narodmon.ru प्रोजेक्ट से कैसे कनेक्ट करें

नमस्ते

हाल ही में, मुझे पता चला कि एक सरल लेकिन उपयोगी परियोजना है "पीपुल्स मॉनिटरिंग"। इसका अर्थ संक्षेप में, कई असमान पर्यावरण निगरानी सेंसर को एक स्थान पर संयोजित करना है। यह एक बात है, उदाहरण के लिए, इंटरनेट पर मौसम के पूर्वानुमान को देखने के लिए और यह वास्तव में देखने के लिए एक और दूसरी चीज़ है कि समय के साथ तापमान, आर्द्रता, दबाव और उनके परिवर्तन क्या हैं।

या उदाहरण के लिए, यदि खिड़की से बाहर थर्मामीटर को देखना और उठना बहुत आलसी है)



यह परियोजना आपको डेटा परिवर्तनों के इतिहास को "स्टोर" करने, प्रदर्शित करने और देखने की अनुमति देती है। सामान्य तौर पर, खुशी के लिए जो कुछ भी आवश्यक है, वह है। आप सेंसर को सार्वजनिक या निजी बना सकते हैं।

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

इसके अलावा, SCADA प्रणालियों में कई सेंसर हैं और उनमें से कई भौगोलिक स्थानों की एक विस्तृत विविधता में पर्यावरणीय मापदंडों को प्रतिबिंबित कर सकते हैं। यह मैं आपको इसके बारे में बताना चाहता हूं - उपरोक्त सेवा के लिए किसी भी SCADA सिस्टम के किसी भी OPC सर्वर सेंसर को कैसे फास्ट किया जाए।

तो हमें जरूरत है:

1. पायथन 2.7
2. अजगर के लिए ओपीसी खोलें
3. विंडोज एक्सटेंशन के लिए पायथन

यह सब उस मशीन पर स्थापित किया जाता है, जहां ओपीसी सर्वर कताई, या दूर से होता है। मैंने स्थानीय स्तर पर स्थापित किया।

इसके बाद, बस मेरी स्क्रिप्ट चलाएं, जो अपनी जटिलता में अद्भुत है:

import OpenOPC import time import socket while True: try: opc = OpenOPC.client() opc.connect("OWEN.RS485") s = socket.socket( socket.AF_INET, socket.SOCK_DGRAM ) # UDP addr = ('narodmon.ru',1234) # ip:port    " " val = opc['Com1/TRM138(8bit adr=24)/ChannelData3/rEAd'] buf = "#123456789ABCDE\n#123456789ABCDE10#" +"%.1f#"%val + "\n##" s.sendto(buf,addr) opc.close() s.close() except : pass time.sleep(180) 

जैसा कि आप देख सकते हैं, मैं ओपीसी सर्वर "OWEN.RS485" से कनेक्ट करता हूं और "आइटम" 'Com1 / TRM138 (8bit adr = 24) / ChannelData3 / rEAd' का मूल्य पढ़ता हूं। इस प्रकार, आप ओपीसी सर्वर के किसी भी "आइटम" का मूल्य पढ़ सकते हैं।

वैसे, यदि आप OpenOPC के लिए प्रलेखन का अध्ययन करते हैं, तो आपको वहां कई उपयोगी कार्य मिलेंगे जो कि बनाने के लिए पर्याप्त हैं, उदाहरण के लिए, एक छोटा सा दृश्य।

भेजने के लिए पैकेज अद्वितीय डिवाइस आईडी 123456789ABCDE से बनाया गया है (आप अपने खुद के बारे में सोच सकते हैं, लेकिन सेंसर या इनपुट मॉड्यूल के सीरियल नंबर का उपयोग करना बेहतर है) और एक अद्वितीय सेंसर आईडी। मैंने डिवाइस आईडी में 0x10 जोड़कर उत्तरार्द्ध प्राप्त किया, जिसका अर्थ है कि यह एक तापमान संवेदक है। आप डेवलपर्स के लिए अनुभाग में प्रोजेक्ट वेबसाइट पर अधिक पढ़ सकते हैं।

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

उन लोगों के लिए जो आसान तरीके नहीं खोज रहे हैं, मैं एक विंडोज़ सेवा सूची जोड़ूंगा जो समान है:

 # -*- coding: utf-8 -*- import win32serviceutil import win32service import win32event import servicemanager import OpenOPC import socket class AppServerSvc (win32serviceutil.ServiceFramework): _svc_name_ = "ServiceForNarodmon" _svc_display_name_ = "ServiceForNarodmon" _svc_description_ = "Service For Narodmon.ru" def __init__(self,args): win32serviceutil.ServiceFramework.__init__(self,args) self.hWaitStop = win32event.CreateEvent(None,0,0,None) self.hWaitResume = win32event.CreateEvent(None, 0, 0, None) self.timeout = 60000 #        self.resumeTimeout = 1000 self._paused = False def SvcStop(self): self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING) win32event.SetEvent(self.hWaitStop) #servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE, #servicemanager.PYS_SERVICE_STOPPED, #(self._svc_name_, '')) def SvcPause(self): self.ReportServiceStatus(win32service.SERVICE_PAUSE_PENDING) self._paused = True self.ReportServiceStatus(win32service.SERVICE_PAUSED) #servicemanager.LogInfoMsg("The %s service has paused." % (self._svc_name_, )) def SvcContinue(self): self.ReportServiceStatus(win32service.SERVICE_CONTINUE_PENDING) win32event.SetEvent(self.hWaitResume) self.ReportServiceStatus(win32service.SERVICE_RUNNING) #servicemanager.LogInfoMsg("The %s service has resumed." % (self._svc_name_, )) def SvcDoRun(self): #servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE, # servicemanager.PYS_SERVICE_STARTED, # (self._svc_name_,"")) self.main() #      def main(self): #       #servicemanager.LogInfoMsg("Hello! Im a Narodmon.ru Service.") while 1: #      #servicemanager.LogInfoMsg("I'm still here.") try: opc = OpenOPC.client() opc.connect("OWEN.RS485") s = socket.socket( socket.AF_INET, socket.SOCK_DGRAM ) # UDP addr = ('narodmon.ru',1234) # ip:port    " " val = opc['Com1/TRM138(8bit adr=24)/ChannelData3/rEAd'] buf = "#123456789ABCDE\n#123456789ABCDE10#" +"%.1f#"%val + "\n##" s.sendto(buf,addr) opc.close() s.close() except : pass #        rc = win32event.WaitForSingleObject(self.hWaitStop, self.timeout) if rc == win32event.WAIT_OBJECT_0: #       #servicemanager.LogInfoMsg("Bye!") break #       if self._paused: pass #servicemanager.LogInfoMsg("I'm paused... Keep waiting...") #   while self._paused: #        rc = win32event.WaitForSingleObject(self.hWaitResume, self.resumeTimeout) if rc == win32event.WAIT_OBJECT_0: self._paused = False #        #servicemanager.LogInfoMsg("Yeah! Let's continue!") break if __name__ == '__main__': win32serviceutil.HandleCommandLine(AppServerSvc) 

सिस्टम लॉग में संदेश लिखने के सभी प्रयासों पर टिप्पणी की जाती है क्योंकि वे WinXP में काम नहीं करते हैं। मैं आगे नहीं समझ पाया क्योंकि Win7 पर सब कुछ ठीक है। आप "लाठी और आसान प्रोवेंस की महिलाओं के साथ" अपनी सेवा "गश" कर सकते हैं।

सौभाग्य है