Matriks Analist

Matriks Analist, büyük veri altyapısı üzerine inşa edilmiş, kolay ölçeklenebilir, mikro servis mimarisi ile kurgulanmış, yeni nesil finansal içerik sağlama sistemidir. Şu anda Matriks tarafından geliştirilen pek çok uygulamanın yanısıra büyük kurumlara ait bazı web siteleri ve mobil uygulamalara da bu altyapı üzerinden veri sağlanmaktadır.

Matriks Analist altyapısı üzerinden gerçek zamanlı ve 15 dk gecikmeli veriler MQTT protokolü ile stream olarak, tarihsel ve hesaplanmış veriler ise Rest servisler aracılığı ile sağlanmaktadır. Bunun yanı sıra QStream adını verdiğimiz servis ile geçmiş tarihteki bir güne ait verileri de stream olarak sağlamak mümkün olmaktadır.

MQTT Servisleri:

MQTT publish/subscribe mekanizmasına dayanan bir veri iletim protokolüdür. Mqtt servislerimiz Websocket ve Tcp protokollerini desteklemektedir. Client, her bir enstrüman ve veri tipi için ayrı ayrı subscriptionlar kurarak veriyi alır. Publish/subscribe mekanizması sayesinde kullanıcı bütün veri yerine sadece ihtiyacı olan veriyi alarak, bant genişliğinden ve kaynak tüketiminden tasarruf sağlamış olur. Bu subscriptionlar üzerinden iletilen her bir mesaj ProtocolBuffer ile kodlanmaktadır. Bu sayede iletilen veri boyutu küçültülerek daha düşük bandwidth tüketimi sağlanmaktadır.

MQTT ile sağlanan içerikler:

• Market Verileri (BIST, VIOP, Yurtdışı Endeksleri, Pariteler, Kripto Paralar vb.)
• Gerçekleşen İşlemler
• Derinlik
• Emir Defteri
• Haberler
• Yükselen/Düşen/Hacimliler (Hisse, Varant, Vadeli ve Opsiyon)
• Varant ve Opsiyonlar için hesaplanmış veriler (Volatilite, kaldıraç, delta, gama vb.)
• Fiyat ve Haber Alarmları

Rest Servisler:

Tarihsel veriler ya da hesaplanarak üretilmiş içerikler rest servisler aracılığı ile JSON formatında sağlanmaktadır.

Rest Servisler ile sağlanan içerikler:

• Sembol bazında ve Kurum bazında gerçekleşen İşlemler
• Grafik Verileri (1-5-10-15-30 Dakikalık, 1-2-4 Saatlik, Günlük, Haftalık, Yıllık periyotlarda)
• Aracı Kurum Dağılımı
• Takas Verileri
• Kademe Analizi
• Karşılaştırmalı Getiri Hesaplama
• Sermaye Artırımları
• Şirket Kartları
• Bilançolar, Gelir Tablosu, Nakit Akışı
• Haberler

QStream:

QStream, sorgulanabilir bir tarihsel veri aktarım servisidir. Piyasa simülasyonları ve backtestler için tasarlanmıştır. QStream’de her bir kullanıcıya özel ayrı instancelar çalışmaktadır. QStream’in sorgu sözdizimi, SQL’in veri sorgulamadaki büyük başarısı örnek alınarak benzer şekilde tasarlanmıştır. Veriler, TCP üzerinden nanomsg PAIR protokolü ile iletilir. QStream üzerinden iletilen mesajlar Mqtt’de olduğu gibi ProtocolBuffer ile kodlanmıştır ve veri formatı Mqtt servisleri ile uyumludur. Veriler istenilen günü canlandıracak şekilde aynı sırayla ve aynı hızda akar. Sorgu esnasında, veri akış hızı değiştirilebilmektedir. Veri akmaya başladıktan sonra akışı durdurma (pause) ve yeniden devam etme (resume) mümkündür.

QStream ile sağlanan içerikler:

• Market Verileri (BIST, VIOP, Yurtdışı Endeksleri, Pariteler, Kripto Paralar vb.)
• Gerçekleşen İşlemler
• Derinlik
• Emir Defteri
• Seans saatleri
• Zaman bilgisi (timestamp)

Güvenlik Katmanı

Tüm servisler kullanıcılarını JWT/JWS tokenler ile tanırlar. Böylece iş ortakları ile federatif kullanıcı paylaşımı olanağı sağlanmış olur. Kural tabanlı bir çıkarım motoru, sahip olduğu lisanslara göre kullanıcıların servis ve içerik erişimini denetler.

Teknolojik Altyapı

Sistemin bütün bileşenleri Docker+Kubernetes ortamında çalışmaktadır. Bunun bir sonucu olarak hem kaynakların optimum seviyede kullanımı sağlanırken hem de kesintisiz deployment ve kaynak tüketimlerine göre servis sayılarını otomatik artırıp/azaltma yeteneklerine sahip olabilmekteyiz. Yatay genişletilebilir bir altyapı kurgulanmış olması, artan yük durumlarında hızla ve kolayca ekosistemi genişletebilme ve yük kapasitesini artırabilme olanağı sağlamaktadır.

Veri Saklama

Gerçekleşen işlem verisinden derinliğe, bar verisinden aracı kurum dağılımlarına piyasaların tüm hareketlerini, Cassandra veri tabanı demetinde saklamaktayız. Matriks Haber Merkezi tarafından yayınlanan haberler Elasticsearch arama motorunda değerlendirilmektedir. Redis ve Memcached önbellek (cache) sistemleri ise, piyasaların anlık resmini tutmak ve işlemleri hızlandırmak için kullanılmaktadır.