Entegrasyonlar · Apache Kafka
Tesisteki olaylar Kafka konularınıza akar.
Veri altyapısı zaten olay tabanlı çalışan ekipler için: Proxus tesis okumalarını ve işlem akışlarınızın gönderdiği alarmları ve hesaplanan değerleri bir Kafka konusuna yayınlar. Endüstriyel veri, şirketteki diğer bütün verilerle aynı omurgadan akar.
- Yayınlanan
- Okunan değerler ve işlem akışlarıyla alarm kurallarının gönderdikleri (alarmlar, hesaplanan değerler)
- Veri hacmi
- Değiştiğinde yalnızca değişen değerleri, Yalnızca işlem akışları yalnızca bir işlem akışının seçtiklerini gönderir
- Kesintiye karşı
- Kafka kümesine ulaşılamazsa veri Edge Gateway’de bekler
- Mesaj
- Key = veri noktası adı, value = okunan değer; cihaz adı, kimliği ve okunma zamanı başlıklarda
Veri yolu
Hangi veri nereden geçer, nerede durur?
Her hedef için, değer değiştiğinde ya da her okumada yayınlanır
Saha
- PLC'ler, CNC'ler, robotlar
- OPC UA sunucuları
- Sayaçlar ve SCADA
Proxus
- Hattın başında toplama
- Veri ağacında düzenleme
- Ara bellek ve aktarım
Apache Kafka
- konu ve bölüm
- okuyucu grupları
- akış işleme
Nasıl çalışır?
Veri makineden Apache Kafka hedefine dört adımda ulaşır.
- 01
Veri toplanır ve adlandırılır
Sinyaller makinelerden okunur, ölçeklenir ve veri noktası adı alır.
- 02
Neyin olay olduğu belirlenir
Edge Gateway’deki alarm kuralları ve anomali tespiti ham değer değişimlerini olaylara dönüştürür; bir işlem akışı bunları hedefe gönderir.
- 03
Konuya yayınlanır
Bir veri hedefi, tanımladığınız konuya seçtiğiniz stratejiyle yazar.
- 04
Her uygulama okuyabilir
Kafka’dan okuyan mevcut uygulamalar endüstriyel veriyi de diğer veriler gibi okur.
Neler kazanırsınız?
Ekipler Apache Kafka bağlantısını neden Proxus üzerinden kuruyor?
-
Tek omurga
Endüstriyel veri, kendine ayrı bir taşıma yolu gereken istisna olmaktan çıkar.
-
Key, veri noktası adıdır
Her mesajın key’i veri noktası adıdır; bölümleme ve log compaction veri noktası bazında çalışır, uygulamalar da değeri ayrıştırmadan veri noktasına göre süzer.
-
Okunma zamanı korunur
Bekleyen değerler okundukları zamanla, Timestamp başlığında gider; geç gelen mesajlar da doğru sıraya oturur.
-
Önce konu kontrol edilir
Bağlantıyı test et, yayına başlamadan önce kümeden sunucu listesini ister ve konunun var olup olmadığını kontrol eder.
Kullanım alanları
Sahada en sık görülen kullanımlar.
-
Olay tabanlı MES ve planlama
Veritabanını sorgulamak yerine makine olaylarına anında tepki verin.
-
Akan veri analitiği
Akış işleme motorlarını endüstriyel okumalar ve olaylarla besleyin.
-
Çok sayıda uygulamaya dağıtım
Bir kez yayınlanan veriyi birbirinden bağımsız birçok uygulama okur; makinelere ek yük binmez.
- Hedefler
- Apache Kafka konuları; RabbitMQ, MQTT ve Sparkplug B de desteklenir
- Veri içeriği
- Her değer için bir mesaj: key = veri noktası adı, value = metin olarak okunan değer; DeviceName, DeviceId ve Timestamp (okunma zamanı) başlıkları
- Aktarım stratejisi
- Doğrudan aktar, Değiştiğinde ya da Yalnızca işlem akışları (yalnızca bir işlem akışının gönderdiği)
- Güvenlik
- SASL ve TLS (Ssl ya da SaslSsl); Kafka sunucusunun adı doğrulanır
- Ayarladığınız alanlar
- BootstrapServers, Topic, ClientId; SecurityProtocol, SaslMechanism, SaslUsername, SaslPassword. Bağlantıyı test et, adresi ve kimlik bilgilerini merkez sunucudan ya da seçtiğiniz Edge Gateway’den veri yazmadan doğrular.
Sahadan örnekler
Bu tesislerde üretimde çalışıyor.
-
İmalat
Dijital fabrikada veri yönetimi
MEXT Dijital Fabrika
Başarı hikâyesini okuyun -
Madencilik ve enerji
Maden sahası, araç filosu ve güneş santrali tek platformda
Kaltun Madencilik
Bu kurulumu sorun -
Enerji
Sahada şebeke izleme
CK Enerji
Bu kurulumu sorun -
İmalat
Oracle ERP ile entegre ortak veri modeli (UNS)
Pilenpak
Bu kurulumu sorun
Sık sorulanlar
Bağlantıyı kurmadan önce bilmeniz gerekenler.
- Proxus mevcut mesajlaşma sistemimizin yerini mi alıyor?
- Hayır. Proxus, mevcut Kafka kümenize veri hedefi olarak yazar; kümenin işletmesi platform ekibinizde kalır.
- Bir mesajın içinde neler var?
- Her mesajda bir değer: key olarak veri noktası adı, value olarak okunan değer; cihaz adı, cihaz kimliği ve okunma zamanı DeviceName, DeviceId ve Timestamp başlıklarında.
- Küme erişilemez olursa ne olur?
- Edge Gateway veriyi yerelde saklar, Kafka sunucularına yeniden ulaşınca gönderir.
- Her okuma yerine yalnızca olayları gönderebilir miyiz?
- Evet. Edge Gateway’deki alarm kuralları ve anomali tespiti ham değişiklikleri olaya dönüştürür; hedefi Yalnızca işlem akışları yaparsanız yalnızca işlem akışlarınızın gönderdikleri yayınlanır. Değiştiğinde stratejisi de değişmeyen değerlerin tekrar tekrar gönderilmesini önler.
Diğer entegrasyonlar
- Mesajlaşma ve olay akışı
MQTT & Sparkplug B Her Edge Gateway’in yerleşik MQTT sunucusunda ortak veri modeline (UNS) abone olun, kendi MQTT sunucunuza yayınlayın ve kendi değerlerini gönderen cihazlardan veri toplayın. MQTT & Sparkplug B entegrasyonu - Bulut
Microsoft Azure Tesis verisini Azure IoT Hub’a gönderin ya da toplu olarak Azure Data Lake Storage Gen2’ye yazın. Microsoft Azure entegrasyonu - Mesajlaşma ve olay akışı
Splunk Endüstriyel okumaları ve olayları Splunk HTTP Event Collector’a gönderin. Splunk entegrasyonu
Bir sonraki adım
Verinin Apache Kafka hedefinize ulaştığını kendi gözünüzle görün.
Bir makine ve bir Kafka konusuyla gelin. Makineyi bağlayalım, okumalarını gözünüzün önünde konuya yayınlayalım ve küme kapalıyken Edge Gateway’in ne yaptığını gösterelim.
- 01
Keşif görüşmesi
Ekipmanlarınızı, protokollerinizi, tesislerinizi ve verinin ulaşması gereken sistemleri konuşuruz.
- 02
Teknik demo
Genel bir tanıtım yerine, tesisinize benzeyen bir senaryo üzerinde canlı demo yaparız.
- 03
Pilot planı
Kurulum ve güvenlik sorularını baştan yanıtlar, ilk hat ya da tesis için kapsamı birlikte belirleriz.
- 04
Yaygınlaştırma
Aynı şablonlarla yeni hatlar ve tesisler devreye girer.