معماری مبتنی بر رویداد (EDA) یک الگوی طراحی است که سیستم ها را قادر می سازد تا به رویدادها در زمان واقعی پاسخ دهند، این به طور گسترده در برنامه های مورد نیاز پردازش داده فوری و پاسخگویی استفاده می شود.این مقاله بررسی یک مطالعه موردی از طراحی EDA برای پردازش داده های زمان واقعی است.

پروژه

این پروژه شامل ایجاد یک سیستم قادر به پردازش داده های جریان جریان از منابع مختلف مانند سنسورها، تعاملات کاربر و API های خارجی بود.هدف این بود که اطمینان حاصل شود تاخیر پایین و مقیاس پذیری بالا برای رسیدگی به حجم داده های افزایش یافته به طور موثر.

سیستم معماری

معماری در اطراف اجزای کلیدی طراحی شده است: تولید کنندگان رویداد، یک کارگزار پیام و تولید کنندگان رویداد، رویدادهای داده را تولید می کنند که از طریق یک کارگزار پیام به مصرف کنندگان مختلف منتقل می شوند که پردازش و تجزیه و تحلیل داده ها در زمان واقعی است.

کارگزار پیام مورد استفاده Apache کافکا بود که برای تحمل بالا و خطا انتخاب شده بود. مصرف کنندگان شامل ماژول های تجزیه و تحلیل داده، سیستم های هشدار و خدمات ذخیره سازی بودند.

جزئیات اجرایی

منابع داده ارسال حوادث به موضوعات کافکا. مصرف کنندگان به موضوعات مرتبط برای پردازش داده ها بلافاصله.سیستم به کار گرفته شده چارچوب پردازش جریان مانند Apache Flink برای انجام تجزیه و تحلیل و تحولات زمان واقعی.

مقیاس پذیری با استقرار چندین مورد از مصرف کنندگان و تقسیم موضوعات کافکا به دست آمد.این تنظیمات به سیستم اجازه داد تا بارهای داده های افزایش یافته را بدون تخریب عملکرد کنترل کند.

نتایج و مزایای

معماری اجرا شده پردازش داده های تأخیر پایین را فراهم کرد، که به موقع تصمیم گیری را امکان پذیر می کند، همچنین انعطاف پذیری سیستم و مقیاس پذیری، قابلیت های افزایش داده ها را به طور موثر بهبود بخشید.