Telegraf का उपयोग करते हुए .NET अनुप्रयोगों से मैट्रिक्स लीजिए

सिस्टम के डिजाइन में सबसे महत्वपूर्ण कार्यों में से एक बड़ी संख्या में सेवाओं सहित सभी नोड्स की स्थिति की निगरानी करने वाला संगठन है। ऐसी स्थितियों में जब इसके लिए अतिरिक्त बल और धन आवंटित नहीं किया जाता है, तो तैयार-किए गए समाधानों का अधिकतम उपयोग करना आवश्यक है।

मुझे लगता है कि कई लोगों के लिए परियोजना में चित्र कुछ इस तरह है:

कुछ को कहीं भेजा जा रहा है, किसी तरह संसाधित किया गया है और एक नाखून पर रखा गया है। कार्य सभी बिंदुओं से डेटा प्रोसेसिंग के आंकड़े एकत्र करना और उन्हें एक स्थान पर रखना था, फिर ग्राफ बनाना और रिपोर्ट लिखना था।

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

मैं स्थापना प्रक्रिया को छोड़ दूंगा और कॉन्फ़िगरेशन के लिए तुरंत आगे बढ़ूंगा। इसलिए, टेलीग्राफ को tcp, udp चैनलों पर मैट्रिक्स के साथ संदेश मिल सकते हैं, साथ ही साथ unixsocket:

[[inputs.socket_listener]] #service_address = "unixgram:///tmp/telegraf.sock" service_address = "udp4://:14230" data_format = "json" json_name_key = "name" namepass = ["query_pass"] tag_keys = ["appname","fromip"] 

अगले पैकेट के संसाधित होने पर हर बार संदेश भेजेंगे, इसलिए हम एकत्रीकरण को भी कॉन्फ़िगर करेंगे। किसी विशेष प्रणाली के भार के आधार पर 10 सेकंड का अंतराल काफी होता है।

 [[aggregators.basicstats]] period = "10s" drop_original = true stats = ["sum"] namepass = ["query_pass"] fieldpass = ["pass","fail"] 

आइए मापदंडों के माध्यम से चलते हैं: query_pass - मीट्रिक का नाम जो भविष्य के माप को जोड़ती है, पास - सफल प्रसंस्करण, असफल - नहीं। इसके अतिरिक्त, मेट्रिक्स को ऐपनाम और डिकिप टैग के साथ टैग किया जाएगा।

अब थोड़ा कोड। मुझे udp और unixsocket के माध्यम से मेट्रिक्स भेजना पसंद है, हालांकि अन्य विकल्प आपके लिए काम कर सकते हैं।

 UdpClient udpClient = new UdpClient("127.0.0.1", 14230); byte[] datagramBytes= Encoding.UTF8.GetBytes("{\"name\":\"query_pass\",\"pass\":1,\"fromip\":\"127.0.0.1\",\"appname\":\"application\"}"); udpClient.Send(datagramBytes, datagramBytes.Length); datagramBytes= Encoding.UTF8.GetBytes("{\"name\":\"query_pass\",\"fail\":1,\"fromip\":\"127.0.0.1\",\"appname\":\"application\"}"); udpClient.Send(datagramBytes, datagramBytes.Length); 

यह सब पूरी तरह से संक्षेप में है और डेटाबेस में जोड़ा गया है, मेरे मामले में यह इलास्टिक्सर्च ( स्क्रीनशॉट ) है।

 [[outputs.elasticsearch]] urls = [ "http://localhost:9200" ] # required. timeout = "5s" health_check_interval = "5s" index_name = "telegraf-%Y.%m.%d" # required. manage_template = true template_name = "tp_telegraf" overwrite_template = true 

सभी बिल्लियों।

पुनश्च: यहाँ net.core के तहत मैट्रिक्स भेजने की अंतिम परियोजना है