इस प्रोजेक्ट के बारे में

यह रिज़ॉर्टरी गूगल क्लाउड प्लेटफ़ॉर्म पर कम-लेटेन्सी वाली वेब ट्रैफ़िक एनालिटिक्स सोल्यूशन बनाने का तरीक़ा दिखाती है। आर्किटेक्चर चार मुख्य भागों से मिलकर बना है: 1. **ईवेंट इनजेस्शन** – एक Pub/Sub टॉपिक एक साधारण पाइथन ईवेंट जेनरेटर द्वारा उत्पन्न क्लिक-स्ट्रीम संदेशों को प्राप्त करता है। Pub/Sub एक स्थिर, वैश्विक रूप से उपलब्ध मैसेज बस प्रदान करता है जो उत्पादकों को उपभोक्ताओं से अलग रखता है। 2. **स्ट्रीमिंग प्रोसेसिंग** – एक Apache Beam पाइपलाइन Dataflow (runner=DataflowRunner) पर स्ट्रीमिंग मोड में चलती है। पाइपलाइन Pub/Sub ईवेंट्स को पढ़ती है, प्रासंगिक फ़ील्ड्स को निकालती है और Cloud Memorystore (Redis) में मेट्रिक्स काउंटर अपडेट करती है। Redis को इन-मेमोरी स्टोर के रूप में उपयोग किया जाता है क्योंकि इसके मौलिक सेट और HyperLogLog कमांड (`SCARD`, `SINTERSTORE`, `PFADD`, `PFCOUNT`) यूनीक-विज़िटर काउंटिंग और सेट-आधारित एनालिटिक्स को बहुत अधिक कुशल बनाते हैं। 3. **मेट्रिक्स स्टोर** – Cloud Memorystore (Redis) रियल-टाइम मेट्रिक्स को संभालता है। Redis के इनबिल्ट डेटा संरचनाओं का लाभ उठाकर, सोल्यूशन कस्टम एग्रीगेशन कोड से बचता है और सेकंड के भीतर क्वेरी लेटेन्सी प्राप्त करता है। 4. **विज़ुअलाइज़ेशन** – एक Spring Boot एप्लीकेशन (`dashboard/` फ़ोल्डर में स्थित) Jedis क्लाइंट के माध्यम से Redis से कनेक्ट होता है, एग्रीगेटेड मान पढ़ता है और Google Charts के साथ उन्हें रेंडर करता है। UI में ऑटो-रीफ़्रेश की सुविधा होती है, जिससे मार्केटर्स या ऑपरेटर्स सक्रिय उपयोगकर्ताओं, प्रयोग भागीदारी, कनवर्जन दरों और उपयोगकर्ता ओवरलैप जैसे KPIs की निगरानी कर सकते हैं। रिज़ॉर्टरी में स्क्रिप्ट्स और निर्देश शामिल हैं: - आवश्यक GCP सर्विसेज (Pub/Sub, Dataflow, Memorystore, Cloud Storage, VPC नेटवर्किंग) को सेटअप करना। - Maven का उपयोग करके Dataflow पाइपलाइन डिप्लॉय करना। - पाइथन वर्चुअल एनवायरनमेंट में डमी ईवेंट जेनरेटर चलाना। - VPC-रिस्ट्रिक्टेड Redis एक्सेस के लिए प्रॉक्सी VM के पीछे Spring Boot डैशबोर्ड लॉन्च करना। - Cloud Shell वेब प्रीव्यू के माध्यम से लाइव डैशबोर्ड देखना। सभी कॉम्पोनेंट्स पूरी तरह से मैनेज्ड सर्विसेज हैं, इसलिए सोल्यूशन स्वचालित रूप से स्कैल होता है और न्यूनतम ऑपरेशनल ओवरहेड की आवश्यकता होती है। यह GCP पर रियल-टाइम वेब एनालिटिक्स, A/B-टेस्ट मॉनिटरिंग, या किसी भी क्लिक-स्ट्रीम-आधारित KPI रिपोर्टिंग की आवश्यकता वाले किसी भी व्यक्ति के लिए एक स्टार्टर किट के रूप में कार्य करता है।