Aracılığıyla paylaş

JOIN Başvuru Verileri

✅ Azure Stream Analytics ✅ Fabric Olay Akışı

Normal bir senaryoda, akış verilerini çok düşük gecikme süresiyle hesaplamak için bir olay işleme altyapısı kullanırız. Kullanıcıların çoğu durumda sistem hakkında daha akıllı kararlar almak için kalıcı geçmiş verileri veya yavaş değişen veri kümesini (başvuru verileri) gerçek zamanlı olay akışıyla ilişkilendirmesi gerekir. Örneğin, olay akışımı IP Adreslerini konumlara eşleyen statik bir veri kümesine birleştirin. Stream Analytics'te desteklenen ve zamana bağlı bir sınırın gerekli olmadığı tek JOIN budur. Başvuru verileri, cihaza özgü eşik değerlerine sahip olmak için de kullanılabilir.

Örnek

Ticari bir araç Ücretli Şirket'e kayıtlıysa, denetim için durdurulmadan ücretli standdan geçebilirler. Süresi dolan tüm ticari araçları belirlemek için bir ticari araç kayıt arama tablosu kullanacağız.

SELECT I1.EntryTime, I1.LicensePlate, I1.TollId, R.RegistrationId  
FROM Input1 I1 TIMESTAMP BY EntryTime  
JOIN Registration R  
ON I1.LicensePlate = R.LicensePlate  
WHERE R.Expired = '1'

Başvuru VeriSI JOIN'in Özellikleri

  • Başvuru Verileri JOIN'in kullanılması, Başvuru Verileri için bir giriş kaynağının tanımlanmasını gerektirir.
  • Başvuru verileri JOIN, JOIN işlecinin sağ tarafında başvuru verileriyle birlikte iç JOIN (varsayılan) ve sol dış JOIN için desteklenir.
  • Veri türleri, birleştirme koşulunun (ON yan tümcesi) değerlendirilmesinde önemli bir özelliktir. Farklı veri türlerindeki (1.0 ve "1") benzer değerler eşleşmeyebilir. Anahtarların açıkça ortak bir türe dönüştürülmesi önerilir.
  • Başvuru verileri statik (yalnızca bir kez yüklenir) veya dinamik (düzenli olarak yenilenir) olabilir. Ancak, dinamik durumda bile başvuru verileri zaman ilerlemesini sağlamaz, bu nedenle çıkışları üretmek için sol taraftaki akışın yeni olaylar alması gerekir. Daha fazla bilgi için bkz. Azure Stream Analytics'te zaman nasıl ilerler .

Performansla ilgili dikkat edilmesi gerekenler

Performans düşüşlerini önlemek için başvuru birleştirme önkoşulları (ON yan tümcesi) basit anahtar eşitlikleri (ON s.myKey = r.myKey) aracılığıyla tanımlanmalıdır. Karmaşık ifadelerin veya eşitsizliklerin kullanılması, dahili olarak çapraz birleşimlere ve ardından filtrelere (tam tarama ve arama) neden olur ve bu da genel gecikme süresini önemli ölçüde etkileyebilir.

Mümkün olduğunda, bu karmaşık ifadeleri sorgu adımının WHERE yan tümcesine taşıyın veya aynı Başvuru Verilerini daha basit koşullarla birden çok kez birleştirin.

Ayrıca Bkz.

  • Last updated on