IoT (Nesnelerin \u0130nterneti) teknolojileri, g\u00fcnl\u00fck hayat\u0131m\u0131zdan end\u00fcstriyel \u00fcretime kadar her alanda devrim yaratmaya devam ediyor. Milyarlarca cihaz\u0131n birbirine ba\u011fland\u0131\u011f\u0131 ve s\u00fcrekli veri \u00fcretti\u011fi bu ekosistemde, verimli veri toplama, i\u015fleme, depolama ve analiz yetenekleri, projelerin ba\u015far\u0131s\u0131 i\u00e7in kritik \u00f6neme sahiptir. Geleneksel veri y\u00f6netimi yakla\u015f\u0131mlar\u0131, IoT’nin getirdi\u011fi muazzam veri hacmi ve h\u0131z\u0131 kar\u015f\u0131s\u0131nda yetersiz kal\u0131rken, modern, \u00f6l\u00e7eklenebilir ve ger\u00e7ek zamanl\u0131 \u00e7\u00f6z\u00fcmlere olan ihtiya\u00e7 giderek artmaktad\u0131r. Bu makale, IoT projelerinizi h\u0131zland\u0131rmak ve g\u00fc\u00e7l\u00fc analitik yetenekleri kazanmak i\u00e7in Coreflux MQTT Broker’\u0131n OpenSearch ile entegrasyonunu detayl\u0131 bir \u015fekilde inceleyecektir. Bu g\u00fc\u00e7l\u00fc kombinasyonun nas\u0131l bir araya getirilebilece\u011fini, mimari avantajlar\u0131n\u0131 ve ger\u00e7ek d\u00fcnya senaryolar\u0131ndaki uygulamalar\u0131n\u0131 ke\u015ffedece\u011fiz.<\/p>\n
IoT ekosisteminin temelinde, sens\u00f6rler, akt\u00fcat\u00f6rler ve di\u011fer ba\u011fl\u0131 cihazlardan gelen verilerin toplanmas\u0131, iletilmesi ve i\u015flenmesi yatar. Ancak bu s\u00fcre\u00e7, bir dizi benzersiz zorlukla doludur:<\/p>\n
* \u00d6l\u00e7eklenebilirlik:<\/strong> Milyonlarca hatta milyarlarca cihazdan gelen veriyi e\u015f zamanl\u0131 olarak y\u00f6netmek, geleneksel sistemler i\u00e7in b\u00fcy\u00fck bir y\u00fckt\u00fcr. Sistem, cihaz say\u0131s\u0131 artt\u0131k\u00e7a kolayca geni\u015fleyebilmelidir. Bu zorluklar\u0131n \u00fcstesinden gelmek i\u00e7in, hem veri iletimi hem de veri analizi i\u00e7in \u00f6zel olarak tasarlanm\u0131\u015f robust ve esnek \u00e7\u00f6z\u00fcmlere ihtiya\u00e7 vard\u0131r. \u0130\u015fte bu noktada MQTT ve OpenSearch gibi teknolojiler devreye girer.<\/p>\n MQTT (Message Queuing Telemetry Transport), k\u0131s\u0131tl\u0131 a\u011f ko\u015fullar\u0131nda \u00e7al\u0131\u015fan cihazlar i\u00e7in tasarlanm\u0131\u015f, hafif, publish\/subscribe tabanl\u0131 bir mesajla\u015fma protokol\u00fcd\u00fcr. IoT d\u00fcnyas\u0131nda veri iletimi i\u00e7in fiili standart haline gelmi\u015ftir.<\/p>\n * Hafiflik:<\/strong> K\u00fc\u00e7\u00fck kod ayak izine sahiptir ve minimum bant geni\u015fli\u011fi kullan\u0131r, bu da onu k\u0131s\u0131tl\u0131 kaynaklara sahip IoT cihazlar\u0131 i\u00e7in ideal k\u0131lar. MQTT’nin bu \u00f6zellikleri, milyarlarca cihaz\u0131n g\u00fcvenilir ve verimli bir \u015fekilde veri aktar\u0131m\u0131 yapmas\u0131n\u0131 sa\u011flayarak IoT projelerinin temelini olu\u015fturur.<\/p>\n Coreflux, end\u00fcstriyel IoT ve ger\u00e7ek zamanl\u0131 veri ak\u0131\u015f\u0131 senaryolar\u0131 i\u00e7in \u00f6zel olarak tasarlanm\u0131\u015f y\u00fcksek performansl\u0131 bir MQTT broker’\u0131d\u0131r. Geleneksel MQTT broker’lar\u0131n\u0131n \u00f6tesine ge\u00e7erek, geli\u015fmi\u015f \u00f6zellikler ve sa\u011flam bir mimari sunar.<\/p>\n * Y\u00fcksek Performans ve \u00d6l\u00e7eklenebilirlik:<\/strong> Coreflux, binlerce hatta milyonlarca e\u015fzamanl\u0131 ba\u011flant\u0131y\u0131 ve saniyede y\u00fcksek mesaj hacmini y\u00f6netebilecek \u015fekilde optimize edilmi\u015ftir. K\u00fcmelenme (clustering) yetenekleri sayesinde yatayda kolayca \u00f6l\u00e7eklenebilir. Coreflux, \u00f6zellikle end\u00fcstriyel ve kritik IoT uygulamalar\u0131nda, mesaj g\u00fcvenilirli\u011fi, \u00f6l\u00e7eklenebilirlik ve g\u00fcvenlik a\u00e7\u0131s\u0131ndan y\u00fcksek beklentileri kar\u015f\u0131lamak \u00fczere in\u015fa edilmi\u015ftir. Geli\u015fmi\u015f y\u00f6netim ve entegrasyon yetenekleri, onu karma\u015f\u0131k IoT ekosistemleri i\u00e7in ideal bir se\u00e7im haline getirir. Geleneksel MQTT broker’lar\u0131n\u0131n temel i\u015flevselli\u011finin \u00f6tesine ge\u00e7erek, veri ak\u0131\u015f\u0131n\u0131 daha ak\u0131ll\u0131, daha g\u00fcvenli ve daha y\u00f6netilebilir hale getirir.<\/p>\n OpenSearch, da\u011f\u0131t\u0131k, a\u00e7\u0131k kaynakl\u0131 bir arama ve analitik motorudur. Elasticsearch’ten \u00e7atallanm\u0131\u015f olup, \u00f6zellikle b\u00fcy\u00fck veri k\u00fcmeleri \u00fczerinde ger\u00e7ek zamanl\u0131 arama, analitik ve g\u00f6rselle\u015ftirme yetenekleri sunar. IoT verileri i\u00e7in m\u00fckemmel bir \u00e7\u00f6z\u00fcm sunar.<\/p>\n * OpenSearch Motoru:<\/strong> Verileri indeksleyen, depolayan ve sorgulayan \u00e7ekirdek bile\u015fendir. Da\u011f\u0131t\u0131k yap\u0131s\u0131 sayesinde yatayda \u00f6l\u00e7eklenebilir ve y\u00fcksek kullan\u0131labilirlik sunar. * Ger\u00e7ek Zamanl\u0131 Analitik:<\/strong> OpenSearch, verileri indekslerken ayn\u0131 anda sorgulamaya olanak tan\u0131r. Bu, IoT sens\u00f6rlerinden gelen ak\u0131\u015f verileri \u00fczerinde anl\u0131k analizler yap\u0131lmas\u0131na imkan verir. OpenSearch, IoT verilerinin ke\u015ffedilmesi, analiz edilmesi ve g\u00f6rselle\u015ftirilmesi i\u00e7in kapsaml\u0131 ve g\u00fc\u00e7l\u00fc bir platform sa\u011flayarak, i\u015fletmelerin operasyonel verimlili\u011fi art\u0131rmas\u0131na, kestirimci bak\u0131m yapmas\u0131na ve yeni i\u015f f\u0131rsatlar\u0131 yaratmas\u0131na yard\u0131mc\u0131 olur.<\/p>\n Coreflux MQTT Broker ve OpenSearch’\u00fcn entegrasyonu, IoT projeleri i\u00e7in g\u00fc\u00e7l\u00fc, \u00f6l\u00e7eklenebilir ve ger\u00e7ek zamanl\u0131 bir veri ak\u0131\u015f\u0131 ve analitik omurgas\u0131 olu\u015fturur. Bu entegrasyon, cihazdan i\u00e7g\u00f6r\u00fcye kadar kesintisiz bir yol sa\u011flar.<\/p>\n Tipik bir entegrasyon mimarisi a\u015fa\u011f\u0131daki ad\u0131mlar\u0131 i\u00e7erir:<\/p>\n 1. Cihazdan Coreflux’a:<\/strong> IoT cihazlar\u0131 (sens\u00f6rler, akt\u00fcat\u00f6rler) verilerini MQTT protokol\u00fc \u00fczerinden Coreflux MQTT Broker’a yay\u0131nlar. Bu veri genellikle JSON format\u0131nda, cihaz kimli\u011fi, zaman damgas\u0131 ve sens\u00f6r okumalar\u0131 gibi bilgiler i\u00e7erir. * U\u00e7tan Uca Ger\u00e7ek Zamanl\u0131l\u0131k:<\/strong> Cihazdan analitik panosuna kadar t\u00fcm veri ak\u0131\u015f\u0131 ger\u00e7ek zamanl\u0131ya yak\u0131nd\u0131r. Coreflux ve OpenSearch ile u\u00e7tan uca bir IoT analitik \u00e7\u00f6z\u00fcm\u00fc olu\u015fturmak i\u00e7in izlenmesi gereken genel ad\u0131mlar \u015funlard\u0131r:<\/p>\n * Ortam Se\u00e7imi:<\/strong> Coreflux, fiziksel sunuculara, sanal makinelere, konteynerlere (Docker, Kubernetes) veya bulut platformlar\u0131na (AWS, Azure, GCP) da\u011f\u0131t\u0131labilir. * Cihaz Geli\u015ftirme:<\/strong> IoT cihazlar\u0131 veya sim\u00fclat\u00f6rleri, Coreflux’a ba\u011flanacak MQTT istemcilerini i\u00e7erir. Bu istemciler, sens\u00f6r verilerini belirli MQTT konular\u0131na (\u00f6rne\u011fin, * G\u00fcvenlik:<\/strong> Cihazlar\u0131n Coreflux’a g\u00fcvenli bir \u015fekilde ba\u011flanmas\u0131 i\u00e7in kimlik do\u011frulama (kullan\u0131c\u0131 ad\u0131\/parola) ve \u015fifreleme (TLS) ayarlar\u0131 yap\u0131land\u0131r\u0131l\u0131r.<\/p>\n Bu ad\u0131mda, Coreflux’tan gelen verileri al\u0131p OpenSearch’e g\u00f6nderecek bir “veri boru hatt\u0131” olu\u015fturulur. Logstash bu i\u015f i\u00e7in pop\u00fcler bir se\u00e7enektir.<\/p>\n * Logstash Kurulumu:<\/strong> Logstash, OpenSearch ile ayn\u0131 sunucuda veya ayr\u0131 bir sunucuda kurulabilir. * Logstash’i Ba\u015flatma:<\/strong> Yap\u0131land\u0131rma dosyas\u0131 ile Logstash ba\u015flat\u0131l\u0131r.<\/p>\n * OpenSearch Kurulumu:<\/strong> OpenSearch, tek bir d\u00fc\u011f\u00fcmde veya birden fazla d\u00fc\u011f\u00fcmle k\u00fcme olarak kurulabilir. Y\u00fcksek kullan\u0131labilirlik ve \u00f6l\u00e7eklenebilirlik i\u00e7in k\u00fcme kurulumu \u00f6nerilir. Docker veya Kubernetes ile da\u011f\u0131t\u0131m yayg\u0131nd\u0131r. * OpenSearch Dashboards Kurulumu:<\/strong> OpenSearch Dashboards, OpenSearch ile birlikte gelir veya ayr\u0131 bir bile\u015fen olarak kurulabilir. Coreflux ve OpenSearch entegrasyonu, \u00e7e\u015fitli sekt\u00f6rlerde g\u00fc\u00e7l\u00fc IoT \u00e7\u00f6z\u00fcmleri sunar:<\/p>\n * Ak\u0131ll\u0131 \u015eehirler:<\/strong> Trafik sens\u00f6rlerinden gelen verileri analiz ederek trafik ak\u0131\u015f\u0131n\u0131 optimize etmek, hava kalitesi sens\u00f6rlerinden gelen verilerle kirlilik seviyelerini izlemek ve ak\u0131ll\u0131 ayd\u0131nlatma sistemlerini y\u00f6netmek i\u00e7in kullan\u0131labilir. Bu senaryolar\u0131n her birinde, Coreflux g\u00fcvenilir ve \u00f6l\u00e7eklenebilir bir veri toplama omurgas\u0131 sa\u011flarken, OpenSearch bu verilerden anlaml\u0131 i\u00e7g\u00f6r\u00fcler elde etmek i\u00e7in gerekli analitik g\u00fcc\u00fc sunar.<\/p>\n B\u00fcy\u00fck \u00f6l\u00e7ekli IoT projelerinde performans ve \u00f6l\u00e7eklenebilirlik, sistemin ba\u015far\u0131s\u0131 i\u00e7in kritik \u00f6neme sahiptir. Coreflux ve OpenSearch, bu alanlarda g\u00fc\u00e7l\u00fc yetenekler sunar.<\/p>\n * K\u00fcmelenme (Clustering):<\/strong> Coreflux, birden fazla broker d\u00fc\u011f\u00fcm\u00fcn\u00fc bir araya getirerek bir k\u00fcme olu\u015fturabilir. Bu, hem y\u00fcksek kullan\u0131labilirlik (bir d\u00fc\u011f\u00fcm ar\u0131zalan\u0131rsa di\u011ferleri devral\u0131r) hem de yatay \u00f6l\u00e7eklenebilirlik (daha fazla mesaj hacmini y\u00f6netmek i\u00e7in d\u00fc\u011f\u00fcm ekleme) sa\u011flar. * Sharding ve Replika:<\/strong> OpenSearch, verileri “shard” ad\u0131 verilen par\u00e7alara b\u00f6ler ve bu shard’lar\u0131 k\u00fcmedeki farkl\u0131 d\u00fc\u011f\u00fcmlere da\u011f\u0131t\u0131r. Her shard’\u0131n birden fazla kopyas\u0131 (“replika”) tutularak veri kayb\u0131 \u00f6nlenir ve sorgu performans\u0131 art\u0131r\u0131l\u0131r. * U\u00e7tan Uca \u015eifreleme:<\/strong> Cihazdan Coreflux’a (MQTT\/TLS), Coreflux’tan veri i\u015fleme katman\u0131na (TLS\/HTTPS) ve veri i\u015fleme katman\u0131ndan OpenSearch’e (HTTPS) kadar t\u00fcm ileti\u015fim kanallar\u0131nda \u015fifreleme kullan\u0131lmal\u0131d\u0131r. IoT ve analitik alanlar\u0131 s\u00fcrekli geli\u015fmektedir. Coreflux ve OpenSearch entegrasyonunu daha da g\u00fc\u00e7lendirecek baz\u0131 gelecek trendleri \u015funlard\u0131r:<\/p>\n * Edge Computing Entegrasyonu:<\/strong> Coreflux’un edge cihazlarda \u00e7al\u0131\u015fabilme yetene\u011fi, verilerin kayna\u011fa daha yak\u0131n i\u015flenmesine olanak tan\u0131r. Bu, gecikmeyi azalt\u0131r, bant geni\u015fli\u011fi kullan\u0131m\u0131n\u0131 optimize eder ve buluta g\u00f6nderilen veri miktar\u0131n\u0131 azalt\u0131r. OpenSearch’in hafif versiyonlar\u0131 veya edge analitik \u00e7\u00f6z\u00fcmleri ile entegrasyonlar \u00f6nem kazanacakt\u0131r. IoT projeleri, ba\u015far\u0131l\u0131 olmak i\u00e7in sa\u011flam bir veri altyap\u0131s\u0131na ihtiya\u00e7 duyar. Coreflux MQTT Broker ve OpenSearch’\u00fcn entegrasyonu, bu ihtiyac\u0131 kar\u015f\u0131lamak i\u00e7in g\u00fc\u00e7l\u00fc, \u00f6l\u00e7eklenebilir ve g\u00fcvenli bir \u00e7\u00f6z\u00fcm sunar. Coreflux, milyonlarca cihazdan gelen veriyi g\u00fcvenilir bir \u015fekilde toplarken, OpenSearch bu verileri ger\u00e7ek zamanl\u0131 olarak analiz etme, arama yapma ve g\u00f6rselle\u015ftirme yetene\u011fi sa\u011flar.<\/p>\n Bu kombinasyon, i\u015fletmelerin IoT verilerinden maksimum de\u011feri elde etmelerini, operasyonel verimlili\u011fi art\u0131rmalar\u0131n\u0131, kestirimci bak\u0131m gibi proaktif stratejiler geli\u015ftirmelerini ve nihayetinde rekabet avantaj\u0131 sa\u011flamalar\u0131n\u0131 m\u00fcmk\u00fcn k\u0131lar. Ak\u0131ll\u0131 \u015fehirlerden end\u00fcstriyel otomasyona, ak\u0131ll\u0131 tar\u0131mdan sa\u011fl\u0131k hizmetlerine kadar geni\u015f bir uygulama yelpazesinde, Coreflux ve OpenSearch entegrasyonu, IoT projelerinizi h\u0131zland\u0131rarak dijital d\u00f6n\u00fc\u015f\u00fcm yolculu\u011funuzda \u00f6nemli bir rol oynayacakt\u0131r. Bu g\u00fc\u00e7l\u00fc ara\u00e7lar\u0131 do\u011fru bir \u015fekilde da\u011f\u0131t\u0131p yap\u0131land\u0131rarak, IoT’nin vaat etti\u011fi potansiyeli tam olarak ger\u00e7ekle\u015ftirebilirsiniz.<\/body><\/p>\n","protected":false},"excerpt":{"rendered":"IoT Projelerinizi ve Analitiklerinizi H\u0131zland\u0131r\u0131n: OpenSearch’\u00fc Coreflux MQTT Broker ile Da\u011f\u0131tma\nIoT (Nesnelerin \u0130nterneti) teknolojileri, g\u00fc","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"csco_page_header_type":"","csco_page_load_nextpost":"","csco_page_subscribe_form":"","csco_page_contact_form":"","footnotes":""},"categories":[1],"tags":[],"class_list":{"0":"post-35060","1":"post","2":"type-post","3":"status-publish","4":"format-standard","6":"category-genel","7":"cs-entry","8":"cs-video-wrap"},"yoast_head":"\n
\n* Ger\u00e7ek Zamanl\u0131 \u0130\u015fleme:<\/strong> Bir\u00e7ok IoT uygulamas\u0131 (\u00f6rne\u011fin, end\u00fcstriyel kontrol, ak\u0131ll\u0131 \u015fehir y\u00f6netimi), anl\u0131k kararlar almay\u0131 gerektirdi\u011finden, verilerin ger\u00e7ek zamanl\u0131 veya ger\u00e7ek zamanl\u0131ya yak\u0131n i\u015flenmesi \u015fartt\u0131r.
\n* Veri \u00c7e\u015fitlili\u011fi ve Hacmi:<\/strong> IoT cihazlar\u0131, farkl\u0131 formatlarda (JSON, CSV, ikili veriler vb.) ve de\u011fi\u015fken h\u0131zlarda veri \u00fcretir. Bu heterojen veriyi tek bir platformda toplamak ve anlaml\u0131 hale getirmek karma\u015f\u0131kt\u0131r.
\n* G\u00fcvenlik:<\/strong> Cihazdan buluta kadar veri ak\u0131\u015f\u0131n\u0131n her noktas\u0131nda g\u00fcvenlik sa\u011flamak hayati \u00f6neme sahiptir. Yetkisiz eri\u015fim, veri ihlalleri veya manip\u00fclasyonu ciddi sonu\u00e7lar do\u011furabilir.
\n* A\u011f K\u0131s\u0131tlamalar\u0131:<\/strong> IoT cihazlar\u0131 genellikle d\u00fc\u015f\u00fck bant geni\u015fli\u011fine sahip, karars\u0131z a\u011flarda veya pil g\u00fcc\u00fcyle \u00e7al\u0131\u015f\u0131r. Bu durum, veri iletim protokollerinin hafif ve verimli olmas\u0131n\u0131 gerektirir.
\n* Da\u011f\u0131t\u0131k Yap\u0131:<\/strong> IoT cihazlar\u0131 co\u011frafi olarak geni\u015f bir alana yay\u0131lm\u0131\u015f olabilir. Bu da\u011f\u0131t\u0131k yap\u0131, veri toplama ve y\u00f6netimini zorla\u015ft\u0131r\u0131r.<\/p>\nMQTT’nin IoT’deki Rol\u00fc<\/h3>\n
Neden MQTT?<\/h4>\n
\n* Publish\/Subscribe Modeli:<\/strong> Cihazlar do\u011frudan birbirleriyle ileti\u015fim kurmak yerine, bir “broker” arac\u0131l\u0131\u011f\u0131yla mesaj al\u0131\u015fveri\u015finde bulunur. Cihazlar belirli “konulara” (topics) abone olur veya bu konulara mesaj yay\u0131nlar. Bu, gev\u015fek ba\u011fl\u0131 bir mimari sa\u011flayarak sistemin \u00f6l\u00e7eklenebilirli\u011fini art\u0131r\u0131r.
\n* G\u00fcvenilir Mesaj Teslimat\u0131:<\/strong> MQTT, \u00fc\u00e7 farkl\u0131 hizmet kalitesi (QoS) seviyesi sunar:
\n * QoS 0 (At Most Once): Mesaj bir kereden fazla g\u00f6nderilmez, teslimat garantisi yoktur.
\n * QoS 1 (At Least Once): Mesaj en az bir kez teslim edilir, m\u00fckerrer mesajlar olabilir.
\n * QoS 2 (Exactly Once): Mesaj tam olarak bir kez teslim edilir, en y\u00fcksek g\u00fcvenilirlik seviyesidir.
\n* D\u00fc\u015f\u00fck G\u00fc\u00e7 T\u00fcketimi:<\/strong> K\u00fc\u00e7\u00fck mesaj ba\u015fl\u0131klar\u0131 ve verimli ileti\u015fim mekanizmalar\u0131 sayesinde cihazlar\u0131n pil \u00f6mr\u00fcn\u00fc uzat\u0131r.
\n* G\u00fcvenlik:<\/strong> TLS\/SSL kullanarak \u015fifreleme ve kullan\u0131c\u0131 ad\u0131\/\u015fifre ile kimlik do\u011frulama gibi g\u00fcvenlik \u00f6zellikleri sunar.<\/p>\nCoreflux MQTT Broker’a Derinlemesine Bak\u0131\u015f<\/h3>\n
Temel \u00d6zellikler ve Avantajlar<\/h4>\n
\n* Geli\u015fmi\u015f G\u00fcvenlik:<\/strong> TLS\/SSL \u015fifrelemesi, kullan\u0131c\u0131 ad\u0131\/\u015fifre kimlik do\u011frulamas\u0131, ACL’ler (Eri\u015fim Kontrol Listeleri) ve entegre kimlik y\u00f6netimi sistemleri ile kapsaml\u0131 g\u00fcvenlik sa\u011flar. Bu, hassas IoT verilerinin g\u00fcvenli bir \u015fekilde iletilmesini garanti eder.
\n* Mesaj Depolama ve Kal\u0131c\u0131l\u0131k:<\/strong> Mesajlar\u0131n kal\u0131c\u0131 olarak depolanmas\u0131 yetene\u011fi, broker’\u0131n yeniden ba\u015flat\u0131lmas\u0131 durumunda bile mesaj kayb\u0131n\u0131 \u00f6nler. Ayr\u0131ca, gecikmeli veya \u00e7evrimd\u0131\u015f\u0131 aboneler i\u00e7in mesajlar\u0131n saklanmas\u0131n\u0131 sa\u011flar.
\n* K\u00f6pr\u00fcleme (Bridging):<\/strong> Coreflux, di\u011fer MQTT broker’lar\u0131 veya farkl\u0131 protokoller (\u00f6rne\u011fin, Kafka) ile k\u00f6pr\u00fc kurabilir. Bu, veri ak\u0131\u015f\u0131n\u0131 farkl\u0131 sistemler aras\u0131nda entegre etmek i\u00e7in b\u00fcy\u00fck esneklik sunar.
\n* Geni\u015fletilebilirlik:<\/strong> Eklenti mimarisi ve API’leri sayesinde \u00f6zel i\u015f mant\u0131klar\u0131 veya entegrasyonlar kolayca eklenebilir.
\n* Y\u00f6netim ve \u0130zleme:<\/strong> Kapsaml\u0131 y\u00f6netim aray\u00fczleri ve izleme ara\u00e7lar\u0131, broker’\u0131n performans\u0131n\u0131, ba\u011flant\u0131lar\u0131 ve mesaj ak\u0131\u015f\u0131n\u0131 kolayca denetlemeyi sa\u011flar.
\n* Edge Computing Deste\u011fi:<\/strong> Coreflux, hem bulutta hem de edge cihazlarda da\u011f\u0131t\u0131labilecek \u015fekilde tasarlanm\u0131\u015ft\u0131r, bu da veri i\u015flemenin kayna\u011fa daha yak\u0131n yap\u0131lmas\u0131n\u0131 sa\u011flar.<\/p>\nNeden Coreflux Tercih Edilmeli?<\/h4>\n
OpenSearch: IoT Analitikleri \u0130\u00e7in G\u00fc\u00e7l\u00fc Bir Platform<\/h3>\n
Temel Bile\u015fenler<\/h4>\n
\n* OpenSearch Dashboards:<\/strong> OpenSearch’te depolanan verileri ke\u015ffetmek, g\u00f6rselle\u015ftirmek ve panolar olu\u015fturmak i\u00e7in kullan\u0131lan bir web aray\u00fcz\u00fcd\u00fcr. Grafikler, tablolar ve co\u011frafi haritalar gibi \u00e7e\u015fitli g\u00f6rselle\u015ftirme se\u00e7enekleri sunar.
\n* OpenSearch Data Prepper:<\/strong> Veri al\u0131m boru hatlar\u0131n\u0131 olu\u015fturmak i\u00e7in kullan\u0131lan, esnek bir veri i\u015fleme arac\u0131d\u0131r. Verileri zenginle\u015ftirme, filtreleme ve d\u00f6n\u00fc\u015ft\u00fcrme yetenekleri sunar. (Elastic Stack’teki Logstash’e benzer bir rol \u00fcstlenir.)<\/p>\nNeden IoT \u0130\u00e7in OpenSearch?<\/h4>\n
\n* \u00d6l\u00e7eklenebilirlik:<\/strong> Da\u011f\u0131t\u0131k mimarisi sayesinde, OpenSearch k\u00fcmesi, artan veri hacmi ve sorgu y\u00fck\u00fcyle ba\u015fa \u00e7\u0131kmak i\u00e7in kolayca geni\u015fletilebilir. Milyarlarca IoT olay\u0131n\u0131 depolayabilir ve analiz edebilir.
\n* Esnek \u015eema (Schema-on-read):<\/strong> IoT verileri genellikle yap\u0131land\u0131r\u0131lmam\u0131\u015f veya yar\u0131 yap\u0131land\u0131r\u0131lm\u0131\u015f oldu\u011fundan, OpenSearch’in esnek \u015fema yakla\u015f\u0131m\u0131, veri al\u0131m\u0131n\u0131 kolayla\u015ft\u0131r\u0131r.
\n* G\u00fc\u00e7l\u00fc Arama ve Sorgulama:<\/strong> Tam metin arama, co\u011frafi konum tabanl\u0131 sorgular, zaman serisi analizi ve karma\u015f\u0131k toplama (aggregation) fonksiyonlar\u0131 ile IoT verilerinden derinlemesine i\u00e7g\u00f6r\u00fcler elde etmeyi sa\u011flar.
\n* G\u00f6rselle\u015ftirme:<\/strong> OpenSearch Dashboards, teknik olmayan kullan\u0131c\u0131lar\u0131n bile IoT verilerini kolayca ke\u015ffetmelerini ve anlaml\u0131 panolar olu\u015fturmalar\u0131n\u0131 sa\u011flar. Sens\u00f6r verilerini, cihaz durumunu ve anormallikleri g\u00f6rsel olarak izlemek i\u00e7in idealdir.
\n* A\u00e7\u0131k Kaynak:<\/strong> A\u00e7\u0131k kaynakl\u0131 olmas\u0131, topluluk deste\u011fi, esneklik ve vendor ba\u011f\u0131ml\u0131l\u0131\u011f\u0131n\u0131n azalmas\u0131 gibi avantajlar sunar.<\/p>\nCoreflux ve OpenSearch Entegrasyonu: Mimari Genel Bak\u0131\u015f<\/h3>\n
Veri Ak\u0131\u015f Mimarisi<\/h4>\n
\n2. Coreflux’tan Veri \u0130\u015fleme Katman\u0131na:<\/strong> Coreflux, ald\u0131\u011f\u0131 mesajlar\u0131 bir sonraki veri i\u015fleme katman\u0131na iletir. Bu katman genellikle \u015fu ara\u00e7lardan biri veya bir kombinasyonu olabilir:
\n * Logstash:<\/strong> Esnek bir veri toplama boru hatt\u0131 arac\u0131d\u0131r. Coreflux’tan MQTT input eklentisi ile veri alabilir, veriyi filtreleyebilir, d\u00f6n\u00fc\u015ft\u00fcrebilir (\u00f6rne\u011fin, \u015fema uyumlulu\u011fu i\u00e7in) ve OpenSearch’e output olarak g\u00f6nderebilir.
\n * Apache Kafka (veya benzeri bir mesaj kuyru\u011fu):<\/strong> Y\u00fcksek hacimli ve ger\u00e7ek zamanl\u0131 veri ak\u0131\u015flar\u0131 i\u00e7in bir arac\u0131 olarak kullan\u0131labilir. Coreflux, MQTT-Kafka k\u00f6pr\u00fcs\u00fc arac\u0131l\u0131\u011f\u0131yla verileri Kafka’ya iletebilir. Kafka’dan sonra bir t\u00fcketici (\u00f6rne\u011fin, Kafka Connect, Flink, Spark Streaming) verileri i\u015fleyip OpenSearch’e yazar.
\n * Sunucusuz Fonksiyonlar (AWS Lambda, Azure Functions):<\/strong> Coreflux, bir webhook veya do\u011frudan entegrasyon ile bu fonksiyonlar\u0131 tetikleyebilir. Fonksiyonlar, veriyi i\u015fleyip do\u011frudan OpenSearch’e yazabilir.
\n * Coreflux Data Prepper:<\/strong> Coreflux’un kendi veri i\u015fleme arac\u0131, do\u011frudan entegrasyon i\u00e7in kullan\u0131labilir.
\n3. Veri \u0130\u015fleme ve D\u00f6n\u00fc\u015ft\u00fcrme:<\/strong> Bu katmanda veriler, OpenSearch’e yaz\u0131lmadan \u00f6nce temizlenir, zenginle\u015ftirilir (\u00f6rne\u011fin, co\u011frafi konum bilgisi eklenmesi), filtrelenir ve OpenSearch indeks \u015femas\u0131na uygun hale getirilir.
\n4. OpenSearch’e Yazma:<\/strong> \u0130\u015flenen veriler, OpenSearch k\u00fcmesindeki uygun indekslere yaz\u0131l\u0131r. Zaman serisi verileri i\u00e7in genellikle zaman tabanl\u0131 indeksler (\u00f6rne\u011fin, iot-data-2023-10-26<\/code>) kullan\u0131l\u0131r.
\n5. OpenSearch Dashboards ile G\u00f6rselle\u015ftirme ve Analiz:<\/strong> OpenSearch’e yaz\u0131lan veriler, OpenSearch Dashboards kullan\u0131larak ger\u00e7ek zamanl\u0131 olarak izlenebilir, analiz edilebilir ve g\u00f6rselle\u015ftirilebilir. \u00d6zel panolar, alarmlar ve raporlar olu\u015fturulabilir.<\/p>\nEntegrasyonun Faydalar\u0131<\/h4>\n
\n* Y\u00fcksek \u00d6l\u00e7eklenebilirlik:<\/strong> Hem Coreflux hem de OpenSearch, yatayda kolayca \u00f6l\u00e7eklenebildi\u011fi i\u00e7in, milyonlarca cihaz ve milyarlarca veri noktas\u0131 sorunsuz bir \u015fekilde y\u00f6netilebilir.
\n* Veri G\u00fcvenilirli\u011fi:<\/strong> MQTT’nin QoS seviyeleri ve Coreflux’un kal\u0131c\u0131l\u0131k \u00f6zellikleri sayesinde mesaj kayb\u0131 minimize edilir.
\n* Esnek Veri \u0130\u015fleme:<\/strong> Aradaki veri i\u015fleme katman\u0131, farkl\u0131 veri formatlar\u0131n\u0131 ve i\u015f mant\u0131klar\u0131n\u0131 destekleyerek esneklik sa\u011flar.
\n* G\u00fc\u00e7l\u00fc Analitik ve G\u00f6rselle\u015ftirme:<\/strong> OpenSearch’in analitik g\u00fcc\u00fc ve Dashboards’\u0131n g\u00f6rselle\u015ftirme yetenekleri sayesinde IoT verilerinden maksimum de\u011fer elde edilir.
\n* Azalt\u0131lm\u0131\u015f Karma\u015f\u0131kl\u0131k:<\/strong> Mod\u00fcler yap\u0131s\u0131 sayesinde her bile\u015fen kendi uzmanl\u0131k alan\u0131nda en iyi performans\u0131 g\u00f6sterirken, entegrasyon noktalar\u0131 net bir \u015fekilde tan\u0131mlanm\u0131\u015ft\u0131r.<\/p>\nU\u00e7tan Uca Bir \u00c7\u00f6z\u00fcm Olu\u015fturma Ad\u0131mlar\u0131<\/h3>\n
1. Coreflux MQTT Broker Kurulumu<\/h4>\n
\n* Kurulum:<\/strong> Coreflux’un resmi dok\u00fcmantasyonuna g\u00f6re kurulum ad\u0131mlar\u0131 izlenir. Genellikle bir i\u015fletim sistemi \u00fczerine ikili dosyalar\u0131n indirilmesi veya Docker imaj\u0131n\u0131n \u00e7ekilmesiyle ba\u015flar.
\n* Yap\u0131land\u0131rma:<\/strong> MQTT portlar\u0131 (varsay\u0131lan 1883, TLS i\u00e7in 8883), g\u00fcvenlik ayarlar\u0131 (kullan\u0131c\u0131lar, parolalar, ACL’ler, TLS sertifikalar\u0131), kal\u0131c\u0131l\u0131k ayarlar\u0131 ve k\u00f6pr\u00fcleme (e\u011fer kullan\u0131lacaksa) yap\u0131land\u0131r\u0131l\u0131r.
\n* Test:<\/strong> Bir MQTT istemcisi (\u00f6rne\u011fin, mosquitto_pub<\/code>\/mosquitto_sub<\/code>, MQTT Explorer) kullanarak Coreflux’a ba\u011flan\u0131l\u0131p mesaj yay\u0131nlama ve abone olma i\u015flemleri test edilir.<\/p>\n2. Veri Toplama ve Y\u00f6nlendirme (MQTT \u0130stemcileri)<\/h4>\n
sensor\/oda1\/sicaklik<\/code>, cihaz\/fabrikam\/makineX\/durum<\/code>) d\u00fczenli aral\u0131klarla yay\u0131nlar.
\n* Veri Format\u0131:<\/strong> Verilerin genellikle JSON format\u0131nda olmas\u0131, OpenSearch’e indeksleme ve Dashboards’ta g\u00f6rselle\u015ftirme i\u00e7in esneklik sa\u011flar. \u00d6rne\u011fin:<\/p>\n{\n \"deviceId\": \"oda1\",\n \"timestamp\": \"2023-10-26T10:30:00Z\",\n \"temperature\": 23.5,\n \"humidity\": 60.2\n }<\/code><\/pre>\n3. Veri \u0130\u015fleme ve D\u00f6n\u00fc\u015ft\u00fcrme (Logstash \u00d6rne\u011fi)<\/h4>\n
\n* Logstash Yap\u0131land\u0131rmas\u0131 (.conf<\/code> dosyas\u0131):<\/strong><\/p>\ninput {\n mqtt {\n host => \"coreflux-broker-ip\"\n port => 1883\n topic => \"sensor\/#\" # T\u00fcm sensor konular\u0131na abone ol\n client_id => \"logstash_client\"\n # username => \"your_user\"\n # password => \"your_password\"\n }\n }\n filter {\n json {\n source => \"message\" # MQTT mesaj\u0131n\u0131n i\u00e7eri\u011fi varsay\u0131lan olarak \"message\" alan\u0131na gelir\n remove_field => [\"message\"]\n }\n date {\n match => [\"timestamp\", \"ISO8601\"]\n target => \"@timestamp\" # OpenSearch i\u00e7in standart zaman damgas\u0131 alan\u0131\n }\n mutate {\n convert => { \"temperature\" => \"float\" }\n convert => { \"humidity\" => \"float\" }\n }\n }\n output {\n opensearch {\n hosts => [\"https:\/\/opensearch-node-ip:9200\"]\n index => \"iot-data-%{+YYYY.MM.dd}\" # G\u00fcnl\u00fck indeksler\n user => \"admin\"\n password => \"admin\"\n ssl => true\n ssl_certificate_verification => false # \u00dcretim ortam\u0131nda true olmal\u0131, CA sertifikas\u0131 belirtilmeli\n }\n stdout { codec => rubydebug } # Hata ay\u0131klama i\u00e7in\n }<\/code><\/pre>\n4. OpenSearch Kurulumu ve Yap\u0131land\u0131rmas\u0131<\/h4>\n
\n* G\u00fcvenlik (Security Plugin):<\/strong> OpenSearch, g\u00fcvenlik eklentisi ile gelir. Kullan\u0131c\u0131lar, roller ve izinler yap\u0131land\u0131r\u0131l\u0131r. Logstash’in OpenSearch’e yazabilmesi i\u00e7in uygun bir kullan\u0131c\u0131 (\u00f6rne\u011fin, logstash_writer<\/code>) ve indekslere yazma izni olan bir rol tan\u0131mlan\u0131r.
\n* \u0130ndeks \u015eablonlar\u0131 (Index Templates):<\/strong> IoT verileri i\u00e7in indeks \u015fablonlar\u0131 olu\u015fturmak \u00f6nemlidir. Bu \u015fablonlar, alan t\u00fcrlerini (mapping), indeks ayarlar\u0131n\u0131 (shard say\u0131s\u0131, replika say\u0131s\u0131) ve ya\u015fam d\u00f6ng\u00fcs\u00fc politikalar\u0131n\u0131 (ILM) tan\u0131mlar. Bu, OpenSearch’in verileri daha verimli depolamas\u0131n\u0131 ve sorgulamas\u0131n\u0131 sa\u011flar. \u00d6rne\u011fin, temperature<\/code> alan\u0131n\u0131n float<\/code> olarak tan\u0131mlanmas\u0131 gibi.<\/p>\n5. OpenSearch Dashboards ile Veri G\u00f6rselle\u015ftirme<\/h4>\n
\n \u0130ndeks Deseni Olu\u015fturma:<\/strong> OpenSearch Dashboards’a eri\u015fildikten sonra, iot-data-<\/em><\/code> gibi bir indeks deseni olu\u015fturularak OpenSearch’teki IoT verileri ke\u015ffedilebilir hale getirilir.
\n* Ke\u015fif ve G\u00f6rselle\u015ftirme:<\/strong>
\n * Discover:<\/strong> Verileri ham haliyle sorgulamak ve filtrelemek i\u00e7in kullan\u0131l\u0131r.
\n * Visualize:<\/strong> \u00c7e\u015fitli grafik t\u00fcrleri (\u00e7izgi grafikler, \u00e7ubuk grafikler, pasta grafikler, metrikler) kullanarak sens\u00f6r verileri, cihaz durumu, ortalama s\u0131cakl\u0131klar veya anormallikler gibi metrikler g\u00f6rselle\u015ftirilir.
\n * Dashboard:<\/strong> Birden fazla g\u00f6rselle\u015ftirme, tek bir ekranda toplanarak kapsaml\u0131 bir IoT izleme panosu olu\u015fturulur. \u00d6rne\u011fin, bir panoda t\u00fcm odalar\u0131n s\u0131cakl\u0131k grafi\u011fi, nem seviyeleri ve son olaylar g\u00f6sterilebilir.
\n* Alarm Olu\u015fturma:<\/strong> OpenSearch Alerting eklentisi kullan\u0131larak belirli ko\u015fullar (\u00f6rne\u011fin, s\u0131cakl\u0131k belirli bir e\u015fi\u011fi a\u015farsa) i\u00e7in alarmlar tan\u0131mlanabilir ve e-posta, Slack veya webhook arac\u0131l\u0131\u011f\u0131yla bildirimler g\u00f6nderilebilir.<\/p>\nGer\u00e7ek D\u00fcnya Uygulama Senaryolar\u0131<\/h3>\n
\n* End\u00fcstriyel IoT (IIoT):<\/strong> \u00dcretim hatt\u0131ndaki makinelerden (PLC’ler, SCADA sistemleri) ger\u00e7ek zamanl\u0131 telemetri verileri toplanarak kestirimci bak\u0131m yap\u0131labilir, \u00fcretim verimlili\u011fi art\u0131r\u0131labilir ve ar\u0131za s\u00fcreleri azalt\u0131labilir. Anormal titre\u015fim veya s\u0131cakl\u0131k art\u0131\u015flar\u0131 an\u0131nda tespit edilip m\u00fcdahale edilebilir.
\n* Ak\u0131ll\u0131 Tar\u0131m:<\/strong> Toprak nemi, hava s\u0131cakl\u0131\u011f\u0131, nem oran\u0131 ve bitki sa\u011fl\u0131\u011f\u0131 sens\u00f6rlerinden gelen verilerle sulama sistemleri optimize edilebilir, hastal\u0131klar erken te\u015fhis edilebilir ve mahsul verimlili\u011fi art\u0131r\u0131labilir.
\n* Sa\u011fl\u0131k Hizmetleri:<\/strong> Hastalar\u0131n giyilebilir cihazlar\u0131ndan (kalp at\u0131\u015f h\u0131z\u0131, kan bas\u0131nc\u0131) gelen verilerle uzaktan hasta takibi yap\u0131labilir, acil durumlarda otomatik uyar\u0131lar g\u00f6nderilebilir ve hastane varl\u0131klar\u0131n\u0131n (tekerlekli sandalyeler, ekipman) konumu izlenebilir.
\n* Ak\u0131ll\u0131 Binalar:<\/strong> Enerji t\u00fcketimini izlemek, HVAC sistemlerini optimize etmek, doluluk oranlar\u0131n\u0131 analiz etmek ve g\u00fcvenlik sistemlerini entegre etmek i\u00e7in kullan\u0131labilir.<\/p>\nPerformans ve \u00d6l\u00e7eklenebilirlik Hususlar\u0131<\/h3>\n
Coreflux \u00d6l\u00e7eklenebilirli\u011fi<\/h4>\n
\n* Mesaj Kal\u0131c\u0131l\u0131\u011f\u0131:<\/strong> Mesajlar\u0131n diskte kal\u0131c\u0131 olarak depolanmas\u0131, broker yeniden ba\u015flat\u0131ld\u0131\u011f\u0131nda veya bir kesinti durumunda mesaj kayb\u0131n\u0131 \u00f6nler.
\n* Kaynak Optimizasyonu:<\/strong> Coreflux, d\u00fc\u015f\u00fck gecikme s\u00fcresi ve y\u00fcksek verim i\u00e7in optimize edilmi\u015f bir mimariye sahiptir.<\/p>\nOpenSearch Cluster Yap\u0131land\u0131rmas\u0131<\/h4>\n
\n* D\u00fc\u011f\u00fcm Rolleri:<\/strong> OpenSearch k\u00fcmeleri, belirli rollere sahip d\u00fc\u011f\u00fcmlerden olu\u015fabilir:
\n * Master D\u00fc\u011f\u00fcmler:<\/strong> K\u00fcme y\u00f6netiminden sorumludur.
\n * Veri D\u00fc\u011f\u00fcmleri:<\/strong> \u0130ndekslenmi\u015f verileri depolar ve sorgu isteklerini i\u015fler.
\n * Ingest D\u00fc\u011f\u00fcmler:<\/strong> Veri al\u0131m boru hatlar\u0131n\u0131 (Data Prepper gibi) \u00e7al\u0131\u015ft\u0131r\u0131r.
\n * Koordinat\u00f6r D\u00fc\u011f\u00fcmler:<\/strong> \u0130stemci isteklerini al\u0131r ve bunlar\u0131 k\u00fcmedeki ilgili d\u00fc\u011f\u00fcmlere y\u00f6nlendirir.
\n* Ya\u015fam D\u00f6ng\u00fcs\u00fc Y\u00f6netimi (ILM):<\/strong> IoT verileri genellikle zaman serisi oldu\u011fundan, eski verilerin otomatik olarak daha ucuz depolama katmanlar\u0131na ta\u015f\u0131nmas\u0131 veya silinmesi i\u00e7in ILM politikalar\u0131 uygulanabilir. Bu, depolama maliyetlerini d\u00fc\u015f\u00fcr\u00fcr ve performans\u0131 optimize eder.
\n* Donan\u0131m Se\u00e7imi:<\/strong> Y\u00fcksek I\/O performans\u0131 i\u00e7in SSD’ler, yeterli RAM ve CPU, OpenSearch k\u00fcmesinin performans\u0131n\u0131 do\u011frudan etkiler.<\/p>\nG\u00fcvenlik Yakla\u015f\u0131mlar\u0131<\/h4>\n
\n* Kimlik Do\u011frulama ve Yetkilendirme:<\/strong> Hem Coreflux hem de OpenSearch i\u00e7in g\u00fc\u00e7l\u00fc kimlik do\u011frulama mekanizmalar\u0131 (kullan\u0131c\u0131 ad\u0131\/parola, sertifikalar, OAuth\/OpenID Connect entegrasyonu) ve ayr\u0131nt\u0131l\u0131 yetkilendirme (ACL’ler, rol tabanl\u0131 eri\u015fim kontrol\u00fc – RBAC) uygulanmal\u0131d\u0131r.
\n* A\u011f Segmentasyonu:<\/strong> IoT cihazlar\u0131, broker ve analitik platform, g\u00fcvenlik duvarlar\u0131 ve VLAN’lar arac\u0131l\u0131\u011f\u0131yla a\u011fda izole edilmelidir.
\n* Veri Maskeleme\/Anonimle\u015ftirme:<\/strong> Hassas veriler, OpenSearch’e yaz\u0131lmadan \u00f6nce maskelenmeli veya anonimle\u015ftirilmelidir.<\/p>\nGelecek Trendleri ve \u0130novasyonlar<\/h3>\n
\n* Yapay Zeka ve Makine \u00d6\u011frenimi (AI\/ML):<\/strong> OpenSearch, ML eklentileri arac\u0131l\u0131\u011f\u0131yla anomali tespiti, kestirimci analitik ve desen tan\u0131ma gibi geli\u015fmi\u015f ML yetenekleri sunar. Bu, IoT verilerinden daha derinlemesine i\u00e7g\u00f6r\u00fcler elde etmek ve otomatik karar alma s\u00fcre\u00e7lerini desteklemek i\u00e7in kritik olacakt\u0131r.
\n* Sunucusuz Mimari:<\/strong> AWS Lambda, Azure Functions gibi sunucusuz hizmetler, veri i\u015fleme katman\u0131n\u0131 daha esnek ve maliyet etkin hale getirebilir. Coreflux’tan do\u011frudan sunucusuz fonksiyonlar\u0131 tetikleme yetenekleri yayg\u0131nla\u015facakt\u0131r.
\n* Blockchain ve Da\u011f\u0131t\u0131k Defter Teknolojileri (DLT):<\/strong> IoT veri b\u00fct\u00fcnl\u00fc\u011f\u00fcn\u00fc ve g\u00fcvenli\u011fini sa\u011flamak i\u00e7in blockchain tabanl\u0131 \u00e7\u00f6z\u00fcmler, \u00f6zellikle tedarik zinciri veya kritik altyap\u0131 senaryolar\u0131nda Coreflux ve OpenSearch ile entegre edilebilir.
\n* Dijital \u0130kizler (Digital Twins):<\/strong> Fiziksel varl\u0131klar\u0131n sanal kopyalar\u0131n\u0131 olu\u015fturarak ger\u00e7ek zamanl\u0131 izleme, sim\u00fclasyon ve optimizasyon sa\u011flamak, Coreflux’tan gelen ger\u00e7ek zamanl\u0131 verilerle beslenen OpenSearch taraf\u0131ndan desteklenecektir.<\/p>\nSonu\u00e7<\/h3>\n