Veri akışlarıyla verileri işleme ve yönlendirme

Veri akışları, verileri taşımak, dönüştürmek ve zenginleştirmek için veri yollarının kurulumunu basitleştirir. Veri akışlarını kullanarak çeşitli veri kaynaklarını bağlayabilir ve veri işlemleri gerçekleştirebilirsiniz. Veri akışı bileşeni, Azure Arc uzantısı olarak dağıttığınız Azure IoT İşlemleri parçasıdır. İşlem deneyimi web kullanıcı arabirimini, Azure CLI veya Azure Resource Manager şablonlarını kullanarak bir veri akışı yapılandırabilirsiniz.

Aşağıdakiler gibi çeşitli kullanım örnekleri için yapılandırmalar yazabilirsiniz:

  • Verileri dönüştürün ve MQTT'ye geri gönderin.
  • Verileri dönüştürün ve buluta gönderin.
  • Dönüştürme olmadan buluta veya kenara veri gönderme.

Veri akışları, IoT İşlemleri örneğini dağıttığınız 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

Bu bölümde veri akışlarının temel özellikleri açıklanmaktadı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: İletileri nereden aldığınız.
  • Hedefler: MQTT uç noktaları için ileti içeriğine dayalı dinamik konu yönlendirme desteği de dahil olmak üzere iletileri boşalttığınız yer.
  • Dönüştürmeler (isteğe bağlı):Veri işleme işlemleri için yapılandırma.

Dönüştürme özellikleri

Çeşitli işlemleri gerçekleştirmek için işleme aşamasında verilere dönüştürmeler uygulayabilirsiniz. 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ürün.
  • Değerleri standartlaştırma: Özellik değerlerini kullanıcı tanımlı bir aralığa ölçeklendirin.
  • Verileri bağlamsallaştırma: Zenginleştirme ve içgörüleri yönlendirmek için iletilere başvuru verileri ekleyin.

Tip

Koşullu yönlendirme, zamana dayalı toplama ve birleştirilebilir dönüştürme işlem hatları gibi daha zengin işleme özellikleri için bkz. Veri akışı grafikleri.

Yapılandırma ve dağıtım

İşlem deneyimi web kullanıcı arabirimini, Azure CLI veya Azure Resource Manager şablonlarını kullanarak yapılandırmayı belirtin. 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.
  • Scalable configuration: Ölçeklenebilir ve yönetilebilir yapılandırmalar için Azure araçlarını 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 Kaydı tarafından sağlanan şema kayıt defteri, bulutta ve uç nokta ile senkronize bir depodur. Ş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 şemaları işlem deneyimi web kullanıcı arabirimine yükleyebilirsiniz.

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, sistem veri akışı ile hedef uç nokta arasındaki bağlantı kaybı sırasında iletileri depolar. Ö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, MQTT aracısı abone ileti kuyruğu iletileri depolar. Bağlantı geri yüklendiğinde, veri akışı abone ileti kuyruğundaki iletileri Azure Event Hubs 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.

İlgili içerik

  • Last updated on