Ingest Data From Apache Kafka - Plato AiStream V2.1

प्लेटो द्वारा पुनर्प्रकाशित

अनुयायियों: 0

यह का हिस्सा है सीखने का रास्ता: आईबीएम धाराओं के साथ आरंभ करें.

सारांश

इस डेवलपर कोड पैटर्न में, हम आपको अपाचे काफ्का द्वारा संचालित स्ट्रीमिंग एप्लिकेशन बनाने की मूल बातें बताते हैं, जो वास्तविक समय डेटा पाइपलाइन और स्ट्रीमिंग ऐप्स बनाने के लिए उपयोग किए जाने वाले सबसे लोकप्रिय ओपन सोर्स वितरित इवेंट-स्ट्रीमिंग प्लेटफार्मों में से एक है। डेटा के लिए आईबीएम क्लाउड पाक® पर आईबीएम स्ट्रीम का उपयोग करके एप्लिकेशन बनाया जाएगा।

Description

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

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

फ्लो

flow

उपयोगकर्ता आईबीएम स्ट्रीम में स्ट्रीमिंग ऐप बनाता है।
स्ट्रीमिंग ऐप संदेश भेजने/प्राप्त करने के लिए आईबीएम इवेंट स्ट्रीम के माध्यम से काफ्का सेवा का उपयोग करता है।
ज्यूपिटर नोटबुक आईबीएम स्ट्रीम ऐप से तैयार किया गया है।
उपयोगकर्ता ज्यूपिटर नोटबुक में स्ट्रीमिंग ऐप निष्पादित करता है।
ज्यूपिटर नोटबुक संदेश भेजने/प्राप्त करने के लिए आईबीएम इवेंट स्ट्रीम के माध्यम से काफ्का सेवा तक पहुंचता है।