Akış ve Olaylar

Bir olay kaybolmamalıdır.

Bir sipariş, bir makine durumu veya bir stok değişikliği başka süreçleri tetiklemelidir. Olay sözleşmelerini tasarlar, platformu ve bağlantıları hayata geçiririz. Böylece alıcılar yük zirvelerinde veya geçici arızalarda bile güvenilir şekilde tepki verebilir.

Üstlendiklerimiz Projenizi görüşün

Şemalar ve sorumlularla olay kataloğu · OTOKO® tarafından planlama ve uygulama

OTOKO®'ya verdiğiniz görev

Sizin için üstlendiklerimiz.

Bir olay, gerçekleşmiş bir değişikliği tanımlar; bir komut ise bir eylem talep eder. Bu ayrım, sorumlulukların karışmamasına yardımcı olur. Tanımlayıcıları, zaman damgasını, şemayı ve gereken bağlamı biz tanımlarız. Sıralama, genel bir sırayı toptan taahhüt etmek yerine, örneğin bir sipariş gibi iş açısından anlamlı birim için değerlendirilir. Makine bağlantısında protokoller, ağ sınırları ve izin verilen müdahaleler işletim sorumlularıyla birlikte kararlaştırılır.

Olası hizmet kapsamı

AsyncAPI'de şemalarla ve Schema Registry ile olay kataloğu
Şifreleme, erişim kontrolü ve kiracı ayrımıyla Kafka veya RabbitMQ kümelerinin kurulması
Debezium, Kafka Connect ve makine verileri için MQTT köprüleri üzerinden kaynakların bağlanması
Sıra, idempotanlık, yeniden deneme ve Event Sourcing için işleme desenleri
Gecikme, verim ve tüketici gruplarının izlenmesiyle işletim

Somut kapsamı, sizin katkınızı ve kabul kriterlerini başlamadan önce belirleriz.

Anlaşılır teknik anlatım

Görevi şöyle hayata geçiriyoruz.

Mükerrer ve gecikmiş mesajları planlamaya dahil etmek

Kesintilerden sonra mesajlar birden fazla kez teslim edilebilir. Bu nedenle tüketiciler, daha önce işlenmiş olayları nasıl tanıyacaklarına veya iş açısından zararsız şekilde nasıl tekrarlayacaklarına dair kurallar alır. Gecikmiş olaylar ve sonradan yapılan düzeltmeler ayrı olarak değerlendirilir. Saklamayı, yeniden oynatmayı ve erişim korumasını biz planlarız. Bir olay platformu otomatik olarak değişmez bir arşiv değildir; saklama ve silme gereksinimlerinin bilinçli şekilde uygulanması gerekir. Şema değişiklikleri, mevcut tüketicilerle uyumluluk açısından kontrol edilir.

Mesaj birikimini ve telafi sürecini test etmek

Kabul testi arızalanan bir tüketiciyi, büyüyen bir mesaj birikimini ve kontrollü yeniden başlatmayı kapsar. Dashboard'lar yalnızca alınan mesaj sayısını değil, gecikmeyi ve hataları da gösterir. Başlangıç için olay türlerine, beklenen hacimlere, azami gecikmeye ve sıralama veya mükerrer işlemeye iş açısından nasıl yaklaşıldığına ihtiyaç vardır.

OTOKO®'nun Köln ofisindeki toplantı odası

Doğrulanabilir bir sonuç

Bununla çalışmaya devam edersiniz.

Şemalar ve sorumlularla olay kataloğu
Kod olarak, çalışmaya hazır olay platformu
Desenler ve örneklerle işleme ilkesi

Devir, uygulamayı ve dokümantasyonu bir araya getirir. Üzerinde anlaşılan vakaları birlikte kontrol eder ve kalan görevleri kayıt altına alırız.

Projeniz ayrıntılarıyla

İş olaylarını güvenilir şekilde dağıtmak ve değerlendirmek.

Değişikliklere tepki vermesi gereken süreçler için olay tabanlı bağlantılar geliştiririz. Bu sırada yalnızca iletimi değil, olayların anlamını, sırasını ve yeniden işlenmesini de planlarız.

Olayları iş düzeyinde ifadeler olarak tanımlamak

Bir olay, örneğin onaylanmış bir sipariş gibi bir şeyin gerçekleştiğini bildirir. Tanımlayıcı, zaman bilgisi, iş bağlamı ve sürüm kuralları üzerinde anlaşırız. Tüketiciler, aynı mesajı daha önce işleyip işlemediklerini ve bir olayın kendi amaçları için yeterli bilgi içerip içermediğini anlayabilmelidir.

Sıralama genellikle yalnızca belirli bir iş nesnesi kapsamında gereklidir. Bu gereksinim, partisyonlamayı ve paralelliği etkiler. Küresel bir sıralama veya iş düzeyinde tam olarak bir kez işleme konusunda genel vaatlerde bulunmak yerine, hedef sistem dahil tüm zincirin garantilerini inceleriz.

Mesaj birikimini, yeniden denemeleri ve veri saklamayı yönetmek

Yavaş bir tüketici, fark edilmeden giderek daha fazla geride kalmamalıdır. Gecikmeleri izler, kapasitenin nasıl artırılacağını veya işlemenin nasıl önceliklendirileceğini planlarız. Hatalı mesajlar için bir çözüm yolu tanımlanır; böylece tek bir sorunlu kayıt, tüm işlemeyi kalıcı olarak bloke etmez.

Tekrarlanabilir olay işleme, onarımlar ve yeni tüketiciler için değerlidir ancak saklama ve veri koruma kurallarına ihtiyaç duyar. Hangi geçmiş olayların erişilebilir kalacağını ve hedef veri kümesinin nasıl yeniden oluşturulacağını belirleriz. Kabul testi, kesintileri, yinelenen teslimatı ve bir tüketicinin yeniden başlatılmasını açıkça ele alır.

Örnek proje senaryosu

Hizmetin günlük işlere katkısı.

Örnek: Onaylanmış bir sipariş, sevkiyat hazırlığını ve bir müşteri bildirimini tetikler. Her iki tüketici de bağımsız olarak işlem yapar. Bildirim başarısız olursa sipariş korunur; yeniden başlatmanın ardından kayıt tanımlayıcısı sayesinde aynı mesajın kontrolsüz şekilde birden çok kez gönderilmesi engellenir.

Bu örnek olası bir süreci açıklar ve bir müşteri referansı değildir.

İlk adımdan önce

Akış ve Olaylar hakkında sorularınız.

Bir broker, iş düzeyinde tam olarak bir kez işlemeyi garanti eder mi?

Tek başına değil. Platformun verdiği güvenceler belirli sınırlar içinde geçerlidir. Dış sistemlerde değişiklik yapıldığı anda uygulamanın mükerrer işlemeyi ve yeniden denemeleri uygun şekilde ele alması gerekir.

Makine verileri, üretime doğrudan erişim olmadan bağlanabilir mi?

Genellikle gateway'ler veya mevcut dışa aktarma yolları mümkündür. Somut yol, üretim ortamından sorumlu kişilerle birlikte kontrol edilir ve onaylanır.

Projeniz

Hangi görevi çözmek istiyorsunuz?

Mevcut durumunuzu ve istediğiniz sonucu tanımlayın. Seçilen hizmet, iletişim talebinize aktarılır.

Bu hizmeti talep edin

Menü

Bir olay kaybolmamalıdır.

Sizin için üstlendiklerimiz.

Olası hizmet kapsamı

Görevi şöyle hayata geçiriyoruz.

Mükerrer ve gecikmiş mesajları planlamaya dahil etmek

Mesaj birikimini ve telafi sürecini test etmek

Bununla çalışmaya devam edersiniz.

İş olaylarını güvenilir şekilde dağıtmak ve değerlendirmek.

Olayları iş düzeyinde ifadeler olarak tanımlamak

Mesaj birikimini, yeniden denemeleri ve veri saklamayı yönetmek

Hizmetin günlük işlere katkısı.

Akış ve Olaylar hakkında sorularınız.

Hangi görevi çözmek istiyorsunuz?

İş Ortaklarımız

Sizin için üstlendiklerimiz.

Olası hizmet kapsamı

Görevi şöyle hayata geçiriyoruz.

Mükerrer ve gecikmiş mesajları planlamaya dahil etmek

Mesaj birikimini ve telafi sürecini test etmek

Bununla çalışmaya devam edersiniz.

Olayları iş düzeyinde ifadeler olarak tanımlamak

Mesaj birikimini, yeniden denemeleri ve veri saklamayı yönetmek

Hizmetin günlük işlere katkısı.

Akış ve Olaylar hakkında sorularınız.

Uygun sonraki adımlar.

Hangi görevi çözmek istiyorsunuz?

İş Ortaklarımız