इवेंट्स अपने ही ब्रोकर पर स्ट्रीम करें
वर्कफ़्लो रिकॉर्ड Pub/Sub, Kafka, SNS, SQS या AMQP पर प्रकाशित करें — आपके टॉपिक, आपका इन्फ्रास्ट्रक्चर, exactly-once सेमांटिक्स।
उन टीमों के लिए जिन्हें एक्सपोर्ट नहीं, इवेंट्स चाहिए: message-queue एक्शन हर वर्कफ़्लो रिकॉर्ड को आपके स्वामित्व वाले ब्रोकर पर प्रकाशित करता है — Google Pub/Sub, Kafka, AWS SNS, SQS, या कोई भी AMQP ब्रोकर। प्रमाणीकरण परिपक्व है: Pub/Sub के लिए या तो एक समर्पित low-privilege पब्लिशर सर्विस अकाउंट को अपने टॉपिक की पहुँच दें (कोई secret संग्रहीत नहीं) या एक scoped key दें जो रेस्ट पर एन्क्रिप्टेड रहती है। डिलीवरी idempotency-आवृत है, प्रति-रिकॉर्ड ordering keys का समर्थन करती है, और भरोसा करने से पहले एक कनेक्टिविटी जाँच उपलब्ध है।
Workflow ट्रिगर
इनबाउंड: वेबहुक या शेड्यूल इस्तेमाल करें
कोई broker-consume ट्रिगर नहीं है — इनबाउंड पथ HTTP वेबहुक, पोलिंग रीड्स और हॉट फ़ोल्डर हैं। यह पेज इवेंट्स को भरोसेमंद ढंग से बाहर भेजने के बारे में है।
Workflow एक्शन
Pub/Sub, Kafka, SNS, SQS, AMQP पर प्रकाशित करें
एक एक्शन, पाँच ब्रोकर एडाप्टर — कनेक्शन चुनें, रिकॉर्ड मैसेज के रूप में प्रवाहित होते हैं।
ऑर्डरिंग और idempotency
जहाँ ब्रोकर समर्थन करे वहाँ प्रति-रिकॉर्ड ordering keys; dispatch-wrapped idempotency का मतलब है कि रीडिलीवरी कैश किया नतीजा दोहराती है, दोबारा प्रकाशित नहीं करती।
कनेक्टिविटी टेस्ट
एक delivery-test एंडपॉइंट प्रोडक्शन ट्रैफ़िक से पहले कनेक्शन सत्यापित करता है।
डेटा कैसे प्रवाहित होता है
डिज़ाइन से केवल आउटबाउंड — वेबहुक कॉलबैक का टिकाऊ विकल्प। सर्वे प्रतिक्रियाएँ, समृद्ध रिकॉर्ड और वर्कफ़्लो आउटपुट आपके टॉपिक्स पर पहुँचते हैं; बाकी काम आपके कंज़्यूमर करते हैं।
कनेक्शन: प्रति-ब्रोकर कनेक्शन एक बार बनते हैं, गंतव्य टॉपिक निर्माण के समय ही तय होता है। Pub/Sub IAM ग्रांट (कोई संग्रहीत secret नहीं) या एन्क्रिप्टेड scoped service-account key समर्थित करता है; अन्य ब्रोकर अपने नेटिव क्रेडेंशियल्स इस्तेमाल करते हैं।
व्यावहारिक उदाहरण: प्रतिक्रियाएँ इवेंट-शैली में आपके डेटा प्लेटफ़ॉर्म तक
एक Pub/Sub कनेक्शन बनाएं: पब्लिशर सर्विस अकाउंट को अपने टॉपिक पर roles/pubsub.publisher दें — कोई key का आदान-प्रदान नहीं।
ट्रिगर: हर सर्वे प्रतिक्रिया एक एनरिचमेंट वर्कफ़्लो चलाती है।
एक्शन: समृद्ध रिकॉर्ड उत्तरदाता id को ordering key बनाकर आपके टॉपिक पर प्रकाशित होता है।
आपकी Dataflow/कंज़्यूमर पाइपलाइन इसे किसी भी अन्य इवेंट स्रोत की तरह उठा लेती है।
सेटअप
1.
एक ब्रोकर कनेक्शन बनाएं (Pub/Sub IAM ग्रांट या scoped key; Kafka/SNS/SQS/AMQP के लिए नेटिव क्रेडेंशियल्स)।
2.
कनेक्टिविटी टेस्ट चलाएँ।
3.
किसी भी वर्कफ़्लो में message-queue एक्शन जोड़ें और कनेक्शन चुनें।
अक्सर पूछे जाने वाले प्रश्न
कौन-से ब्रोकर समर्थित हैं?
Google Pub/Sub, Kafka, AWS SNS, AWS SQS, और AMQP-संगत ब्रोकर — एक एक्शन, पाँच एडाप्टर।
Pub/Sub का प्रमाणीकरण कैसे होता है?
दो तरीके: हमारे समर्पित low-privilege पब्लिशर सर्विस अकाउंट को अपने टॉपिक पर roles/pubsub.publisher दें (कोई secret कभी संग्रहीत नहीं होता), या एक scoped service-account key दें, जो रेस्ट पर एन्क्रिप्टेड रहती है।
क्या SurveyAnalytica मेरे ब्रोकर से consume भी कर सकता है?
फ़िलहाल नहीं — इनबाउंड वेबहुक, शेड्यूल्ड पोलिंग रीड्स और हॉट फ़ोल्डर से होता है। स्ट्रीमिंग आउटबाउंड है।