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.

Note

Veri akışları, ilk Azure IoT İşlemleri sürümlerinden yalnızca önizleme Data Processor bileşeninin yerini alır. --include-dp üzerindeki az iot ops init parametresi kaldırıldı ve artık gerekli değil. Veri akışı bileşenleri otomatik olarak dağıtılır.

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.
  • Destinations: Mesajları aktardığınız yer, dinamik konu yönlendirme desteği dahil.
  • 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.

Veri arabelleğe alma ve disk kalıcılığı

Bir veri akışı hedef uç noktaya ileti gönderdiğinde, hedef veya ağ kullanılamaz hale gelebilir. Teslim tamamlanamadıysa veri akışı kaynak iletiyi kabul etmez. MQTT aracısı iletiyi abone kuyruğunda tutar ve veri akışı teslimi tekrar dener.

Hedef kesintisi davranışı, aracı abone kuyrukları, disk destekli mesaj tamponu, aracı kalıcılığı ve veri akışı hakkında bilgi için bkz. requestDiskPersistence.

İlgili içerik

  • Last updated on