Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Veri akışları, verileri taşımak, dönüştürmek ve zenginleştirmek için veri yollarının kurulumunu basitleştirerek çeşitli veri kaynaklarını bağlamanıza ve veri işlemleri gerçekleştirmenize olanak tanır. Veri akışı bileşeni, Azure Arc uzantısı olarak dağıtılan Azure IoT İşlemleri'nin bir parçasıdır. Veri akışı yapılandırması Kubernetes özel kaynak tanımları (CRD) aracılığıyla gerçekleştirilir.
Aşağıdakiler gibi çeşitli kullanım örnekleri için yapılandırmalar yazabilirsiniz:
- Verileri dönüştürme ve MQTT'ye geri gönderme
- Verileri dönüştürme ve buluta gönderme
- Dönüştürme olmadan buluta veya kenara veri gönderme
Veri akışları IoT İşlemleri örneğinin dağıtıldığı bölgeyle sınırlı değildir. Farklı bölgelerdeki bulut uç noktalarına veri göndermek için veri akışlarını kullanabilirsiniz.
Temel özellikler
Veri akışlarının temel özellikleri aşağıdadır.
Veri işleme ve yönlendirme
Veri akışları iletilerin alımını, işlenmesini ve belirtilen havuzlara yönlendirilmesini sağlar. Şunları belirtebilirsiniz:
- Kaynaklar: İletilerin alındığı yer
- Hedefler: MQTT uç noktaları için ileti içeriğine dayalı dinamik konu yönlendirme desteği de dahil olmak üzere iletilerin boşaltıldığı yer
- Dönüştürmeler (isteğe bağlı): Veri işleme işlemleri için yapılandırma
Dönüştürme özellikleri
Dönüştürmeler, çeşitli işlemleri gerçekleştirmek için işleme aşamasında verilere uygulanabilir. Bu işlemler şunları içerebilir:
- Yeni özellikleri hesaplama: İletideki mevcut özelliklere göre
- Özellikleri yeniden adlandırma: Verileri standartlaştırmak veya netleştirmek için
- Birimleri dönüştürme: Değerleri farklı ölçü birimlerine dönüştürme
- Değerleri standartlaştırma: Özellik değerlerini kullanıcı tanımlı bir aralığa ölçeklendirme
- Verileri bağlamsallaştırma: Zenginleştirme ve içgörüleri yönlendirmek için iletilere başvuru verileri ekleme
Yapılandırma ve dağıtım
Yapılandırma Kubernetes CRD'leri kullanılarak belirtilir. Bu yapılandırmaya bağlı olarak, veri akışı operatörü yüksek kullanılabilirlik ve güvenilirlik sağlamak için veri akışı örnekleri oluşturur.
Fayda -ları
- Basitleştirilmiş kurulum: Veri kaynaklarını ve hedeflerini kolayca bağlayın.
- Esnek dönüşümler: Çok çeşitli veri işlemleri gerçekleştirin.
- Ölçeklenebilir yapılandırma: Ölçeklenebilir ve yönetilebilir yapılandırmalar için Kubernetes CRD'lerini kullanın.
- Yüksek kullanılabilirlik: Kubernetes yerel kaynağı güvenilirliği sağlar.
Veri akışlarını kullanarak veri yollarınızı verimli bir şekilde yönetebilirsiniz. Verilerin operasyonel gereksinimlerinizi karşılayacak şekilde doğru bir şekilde gönderilmesini, dönüştürülmesini ve zenginleştirilmesini sağlayabilirsiniz.
Şema kayıt dizini
Azure Cihaz Kayıt Defteri tarafından sağlanan şema kayıt defteri, bulut ve uçta eşitlenmiş bir saklama sistemi olarak hizmet verir. Şema kayıt defteri uç varlıklarından gelen iletilerin tanımlarını depolar ve ardından uçta bu şemalara erişmek için bir API'yi kullanıma sunar. OPC UA bağlayıcısı gibi güneye giden bağlayıcılar ileti şemaları oluşturabilir ve bunları şema kayıt defterine ekleyebilir veya müşteriler şemaları işlem deneyimi web kullanıcı arabirimine yükleyebilir.
Veri akışları, iletiyi hedef uç nokta tarafından beklenen biçime dönüştürmek için ileti şemalarını kullanır.
Daha fazla bilgi için bkz. İleti şemalarını anlama.
Yerel MQTT aracılık sunucusu uç nokta mesaj depolama
Yerel MQTT aracısını bir veri akışında kaynak uç nokta olarak kullandığınızda, iletiler veri akışı ile hedef uç nokta arasındaki bağlantı kaybı sırasında depolanır. Örnek bir senaryo olarak, kaynak uç nokta olarak varsayılan yerel MQTT aracısını ve hedef uç nokta olarak Azure Event Hubs'ı kullanarak bir veri akışı oluşturduğunuzu varsayalım. Veri akışı ile Azure Event Hubs arasındaki bağlantı kesilirse, iletiler MQTT aracısı abone iletisi kuyruğunda depolanır. Bağlantı geri yüklendiğinde, veri akışı abone ileti kuyruğundaki iletileri Azure Event Hubs'a gönderir.
Yerel MQTT aracısı ileti kuyruğu varsayılan olarak bellekte depolanır. MQTT aracısını, disk destekli ileti arabelleği yapılandırmasını kullanarak iletileri diskte depolamak üzere yapılandırabilirsiniz. MQTT aracı yapılandırması hakkında daha fazla bilgi için bkz . Yüksek kullanılabilirlik, ölçeklendirme ve bellek kullanımı için aracı ayarlarını yapılandırma. Disk destekli ileti arabelleği hakkında daha fazla bilgi için bkz. Disk destekli ileti arabelleği davranışını yapılandırma.