IoT Platform:TimeSeries modelindeki OTS örneklerine veri iletme

Önkoşullar

• DataSource adlı bir veri kaynağı oluşturun ve bu veri kaynağına bir TSL iletişim konusu ekleyin. Daha fazla bilgi için bkz. Veri kaynağı ekleme.

• Bir OTS örneği ve verileri almak için kullanılacak bir tablo oluşturun. Daha fazla bilgi için bkz. OTS belgelerindeki "TimeSeries modeli" bölümü.

  Önemli

  IoT Platform Enterprise Edition örneği kullanıyorsanız, OTS örneğinin dağıtıldığı bölge IoT Platform örneğinizin bulunduğu bölgeyle aynı olmalıdır.

Arka plan bilgileri

TimeSeries modeli; IoT cihaz izleme, cihaz verisi toplama ve makine izleme gibi senaryolarda üretilen zaman serisi verilerini depolamak için kullanılır. TimeSeries modeli, zaman serisi meta verilerinin otomatik olarak dizine eklenmesini ve çeşitli bileşik koşullara dayalı zaman serisi sorgularını destekler. Daha fazla bilgi için bkz. TimeSeries modeli.

Sınırlamalar

Yalnızca Çin (Şanghay) bölgesindeki Enterprise Edition örnekleri, yeni sürüm veri iletme özelliğini kullanarak verileri TimeSeries modelindeki OTS örneklerine iletmenize olanak tanır.

Veri hedefi oluşturma

1. IoT Platform konsolu üzerinde oturum açın.

2. Genel Bakış sekmesinde yönetmek istediğiniz örneği bulun ve Instance Details sayfasına gitmek için örnek adına tıklayın.

   

3. Sol gezinme bölmesinde Message Forwarding > Data Forwarding seçeneklerini belirleyin.

4. Data Forwarding sayfasında sağ üst köşedeki Go to New Version seçeneğine tıklayın.

   Not

   Bu işlemi daha önce yaptıysanız otomatik olarak Data Forwarding sayfasının yeni sürümüne yönlendirilirsiniz.

5. Data destination sekmesine tıklayın ve ardından Create data destination seçeneğine tıklayın.

6. Create Data Destination iletişim kutusunda bir veri hedefi adı girin. Örnek: DataPurpose. Parametreleri yapılandırın ve OK seçeneğine tıklayın.

   Aşağıdaki tabloda parametreler açıklanmaktadır.

   Not

   Yalnızca JSON formatındaki veriler iletilebilir.

   Parameter	Description
   Operation	Store Data to Tablestore seçeneğini belirleyin.
   Region	OTS'nin etkinleştirildiği bölgeyi seçin.
   Instance	Bir OTS örneği seçin. TimeSeries modelinde bir OTS örneği oluşturmak üzere OTS konsoluna gitmek için Create Instance seçeneğine tıklayabilirsiniz. Daha fazla bilgi için bkz. TimeSeries modeli örneği oluşturma.
   Storage Class	TimeSeries Model seçeneğini belirleyin.
   Data Table	Verileri almak için kullanmak istediğiniz zaman serisi tablosunu seçin. Zaman serisi tablosu oluşturmak üzere OTS konsoluna gitmek için Create Data Table seçeneğine tıklayabilirsiniz. Daha fazla bilgi için bkz. Zaman serisi tablosu oluşturma.
   Role	IoT Platform'a zaman serisi tablosuna veri yazma izni verin. RAM rolü yoksa RAM konsolunda bir RAM rolü ve yetkilendirme ilkesi oluşturmak için Create RAM Role seçeneğine tıklayın. RAM rolü oluşturma.

Ayrıştırıcıyı yapılandırma ve başlatma

1. DataParser gibi bir ayrıştırıcı oluşturun. Daha fazla bilgi için bkz. Adım 1: Ayrıştırıcı oluşturma.

2. Resolver Details sayfasında veri kaynağını ilişkilendirin.

   1. Yapılandırma sihirbazında Data Source altında Associate Data Source seçeneğine tıklayın.

   2. İletişim kutusunda Data Source açılır listesinden DataSource'u seçin ve OK seçeneğine tıklayın.

3. Resolver Details sayfasında veri hedeflerini ilişkilendirebilirsiniz.

   1. Yapılandırma sihirbazında Data Destination seçeneğine tıklayın. Ardından Data Destination listesinin sağ üst köşesindeki Associate Data Destination seçeneğine tıklayın.

   2. Açılan iletişim kutusunda Data Destination açılır listesinden DataPurpose'u seçin ve OK seçeneğine tıklayın.

   3. Veri hedefi listesinde Data Destination ID değerini bulun ve not edin. Örneğin: 1000.

      Bu Data Destination ID değerine ayrıştırma betiğinde ihtiyacınız olacaktır.

4. parser details sayfasında Parser Script sekmesine tıklayın.

5. Kod düzenleyicide bir betik girin. Betiği değiştirme hakkında daha fazla bilgi için bkz. Betik sözdizimi.

   İşlev parametreleri hakkında daha fazla bilgi için bkz. İşlev listesi.

   // Call the payload() function to obtain the data that is submitted by devices and convert the data into the JSON format. 
   var data = payload("json");
   // Obtain the submitted property values. 
   var h = data.items.Humidity.value;
   var t = data.items.Temperature.value;
   
   var datasource = deviceName();
   var fields = {"temperature":t, "humidity":h};
   var tags = {};
   tags.put("region", "cn-shanghai");
   var metricName = "property";
   var timeInUs = timestamp()*1000;
   
   // Call the writeTableStoreTS method to write the temperature and humidity values to the corresponding columns based on the point in time at which the values are submitted. 
   writeTableStoreTs(1000, timeInUs, metricName, tags, fields, datasource);

   metricName parametresini Temperature veya Humidity olarak ayarlayıp ilgili verileri de yazabilirsiniz. Örnek kod:

   writeTableStoreTs(1000, [
       {
           "timeInUs": timestamp() * 1000,
           "metricName": "Temperature",
           "tags":tags,
           "fields":{"temperature": t},
           "dataSource": deviceName()
       },
       {
           "timeInUs": timestamp() * 1000,
           "metricName": "Humidity",
           "tags":tags,
           "fields":{"humidity": h},
           "dataSource": deviceName()
       },
   ]);

6. Debugging seçeneğine tıklayın. Açılan iletişim kutusunda bir ürün ve cihaz seçin, bir konu belirtin ve betiğin beklendiği gibi çalışıp çalışmadığını kontrol etmek için yük verisi (payload) girin.

   Aşağıdaki şekilde parametreler gösterilmektedir.

   Aşağıdaki bilgilere benzer bir çıktı döndürülürse betik beklendiği gibi çalışır.

7. Publish seçeneğine tıklayın.

8. Data Forwarding sayfasındaki Resolver sekmesine dönün ve DataParser ayrıştırıcısı için Start seçeneğine tıklayın.

9. Veriler gönderildikten sonra OTS konsolunda oturum açın. Verileri almak için kullanılan tablonun Data Editor sayfasına gidin ve belirtilen verilerin alınıp alınmadığını kontrol edin. Daha fazla bilgi için bkz. Zaman serisi verilerini sorgulama.

   SQL sorgu özelliğini kullanarak OTS'deki veriler üzerinde karmaşık sorgular ve analizler yapabilirsiniz. Daha fazla bilgi için bkz. SQL kullanarak zaman serisi verilerini sorgulama.