Ingest Data From Apache Kafka - Plato AiStream V2.1

প্লেটো দ্বারা প্রকাশিত

অনুসরণকারী: 0

এটি অংশ শেখার পথ: IBM স্ট্রিম দিয়ে শুরু করুন.

সারাংশ

এই ডেভেলপার কোড প্যাটার্নে, আমরা আপনাকে Apache Kafka দ্বারা চালিত একটি স্ট্রিমিং অ্যাপ্লিকেশন তৈরি করার মূল বিষয়গুলি নিয়ে চলেছি, রিয়েল-টাইম ডেটা পাইপলাইন এবং স্ট্রিমিং অ্যাপ তৈরির জন্য ব্যবহৃত সবচেয়ে জনপ্রিয় ওপেন সোর্স বিতরণকৃত ইভেন্ট-স্ট্রিমিং প্ল্যাটফর্মগুলির মধ্যে একটি। অ্যাপ্লিকেশনটি ডেটার জন্য IBM Cloud Pak®-এ IBM স্ট্রিম ব্যবহার করে তৈরি করা হবে।

বিবরণ

এই প্যাটার্নে, আমরা আপনাকে Apache Kafka দ্বারা চালিত একটি স্ট্রিমিং অ্যাপ্লিকেশন তৈরি করার মূল বিষয়গুলি নিয়ে চলেছি। আমাদের অ্যাপটি ডেটার জন্য IBM Cloud Pak-এ IBM স্ট্রিম ব্যবহার করে তৈরি করা হবে। IBM স্ট্রীমস একটি বিল্ট-ইন IDE (স্ট্রিম ফ্লোস) প্রদান করে যা আপনাকে দৃশ্যত একটি স্ট্রিমিং অ্যাপ তৈরি করতে দেয়। ডেটা প্ল্যাটফর্মের জন্য আইবিএম ক্লাউড পাক অতিরিক্ত সহায়তা প্রদান করে, যেমন একাধিক ডেটা উত্সের সাথে একীকরণ, অন্তর্নির্মিত বিশ্লেষণ, জুপিটার নোটবুক এবং মেশিন লার্নিং।

আমাদের Apache Kafka পরিষেবার জন্য, আমরা IBM ক্লাউডে IBM ইভেন্ট স্ট্রীম ব্যবহার করব, যা কাফকা প্ল্যাটফর্মে নির্মিত একটি উচ্চ-থ্রুপুট বার্তা বাস। নিম্নলিখিত উদাহরণগুলিতে, আমরা এটিকে একটি উত্স এবং ক্লিকস্ট্রিম ডেটার লক্ষ্য হিসাবে দেখাব — ব্যবহারকারীর ক্লিকগুলি থেকে নেওয়া ডেটা যখন তারা অনলাইন শপিং ওয়েবসাইটগুলি ব্রাউজ করে।

ফ্লো

flow

ব্যবহারকারী আইবিএম স্ট্রিমগুলিতে স্ট্রিমিং অ্যাপ তৈরি করে।
স্ট্রিমিং অ্যাপ বার্তা পাঠাতে/প্রাপ্তির জন্য IBM ইভেন্ট স্ট্রীমের মাধ্যমে কাফকা পরিষেবা ব্যবহার করে।
জুপিটার নোটবুকটি আইবিএম স্ট্রিম অ্যাপ থেকে তৈরি করা হয়েছে।
ব্যবহারকারী জুপিটার নোটবুকে স্ট্রিমিং অ্যাপ চালায়।
জুপিটার নোটবুক আইবিএম ইভেন্ট স্ট্রীমের মাধ্যমে বার্তা পাঠাতে/গ্রহণ করতে কাফকা পরিষেবা অ্যাক্সেস করে।