Penerusan Data ke Instance OTS Model Kolom Lebar - IoT Platform

Anda dapat menggunakan fitur penerusan data dari mesin aturan untuk meneruskan data ke instance Tablestore (OTS) model kolom lebar. Topik ini menjelaskan proses penerusan data. Dalam contoh ini, topik komunikasi Thing Specification Language (TSL) digunakan sebagai topik sumber.

Prasyarat

Sebuah instance IoT Platform yang datanya dapat diteruskan ke instance OTS model kolom lebar telah dibuat di wilayah yang mendukung penerusan data ke instance OTS model kolom lebar. Untuk informasi lebih lanjut, lihat Wilayah.
Sebuah sumber data bernama DataSource telah dibuat dan topik komunikasi TSL ditambahkan ke sumber data. Untuk informasi lebih lanjut, lihat Buat Sumber Data.
Sebuah instance OTS dan tabel yang digunakan untuk menerima data telah dibuat. Untuk informasi lebih lanjut, lihat Dokumentasi OTS.
Penting
Jika Anda menggunakan instance IoT Platform Edisi Perusahaan, wilayah tempat instance OTS berada harus sama dengan wilayah tempat instance IoT Platform berada.

Informasi Latar Belakang

Model Kolom Lebar: Model ini mirip dengan model Bigtable atau HBase. Model ini cocok untuk berbagai skenario, seperti pemrosesan metadata dan data besar. Model ini mendukung berbagai fitur, seperti versi data, waktu hidup (TTL), penambahan otomatis kolom kunci utama, pembaruan bersyarat, transaksi lokal, penghitung atomik, dan filter. Untuk informasi lebih lanjut, lihat Model Kolom Lebar.

Catatan Penggunaan

Anda dapat menggunakan versi baru atau sebelumnya dari fitur penerusan data untuk meneruskan data ke OTS. Untuk informasi lebih lanjut tentang cara menggunakan versi sebelumnya dari fitur penerusan data, lihat Teruskan Data ke OTS.

Buat Tujuan Data

Masuk ke Konsol IoT Platform.
Di halaman Overview, klik All environment. Di tab Semua Lingkungan, temukan instance yang ingin Anda kelola dan klik ID instance atau nama instance.
Di panel navigasi di sebelah kiri, pilih Message Forwarding > Data Forwarding.
Di pojok kanan atas halaman Data Forwarding, klik Go to New Version untuk beralih ke versi baru.
Catatan
Jika Anda telah melakukan langkah ini, halaman Data Forwarding versi baru akan muncul setelah Anda memilih Penerusan Pesan > Penerusan Data.
Klik Data Destination. Di tab Tujuan Data, klik Create Data Destination.

Di kotak dialog Create Data Destination, masukkan nama tujuan data. Dalam contoh ini, DataPurpose digunakan. Konfigurasikan parameter dan klik OK.

Catatan

Anda hanya dapat meneruskan data dalam format JSON.

选择操作

Parameter	Deskripsi
Operasi	Pilih Store Data to Tablestore.
Wilayah	Pilih wilayah tempat instance OTS Anda berada.
Instance	Pilih instance OTS. Anda dapat mengklik Create Instance untuk pergi ke konsol OTS dan membuat instance OTS. Untuk informasi lebih lanjut, lihat Dokumentasi OTS.
Kelas Penyimpanan	Pilih Wide Column Model.
Tabel Data	Pilih tabel OTS yang digunakan untuk menerima data. Anda dapat mengklik Create Data Table untuk pergi ke konsol OTS dan membuat tabel OTS.
Peran	Otorisasi IoT Platform untuk menulis data ke OTS. Jika Anda tidak memiliki peran Resource Access Management (RAM), klik Create RAM Role untuk pergi ke konsol RAM, buat peran RAM, dan kemudian berikan izin kepada peran tersebut. Untuk informasi lebih lanjut, lihat Buat Peran RAM.

Konfigurasikan dan Mulai Parser

Buat parser bernama DataParser. Untuk informasi lebih lanjut, lihat Buat Parser.
Di halaman Parser Details, asosiasikan parser dengan sumber data yang telah dibuat.
1. Di langkah Data Source wizard, klik Associate Data Source.
2. Di kotak dialog yang muncul, pilih DataSource dari daftar drop-down Data Source, lalu klik OK.
Di halaman Parser Details, asosiasikan parser dengan tujuan data yang telah dibuat.
1. Klik Data Destination di wizard. Di bagian Data Destination, klik Associate Data Destination.
2. Di kotak dialog yang muncul, pilih DataPurpose dari daftar drop-down Data Destination, lalu klik OK.
3. Di bagian Tujuan Data, lihat dan simpan data destination ID. Dalam contoh ini, ID adalah 1000.
  Saat menulis skrip parser, Anda harus menggunakan data destination ID.
Di halaman parser details, klik Parser Script.

Di editor kode, masukkan skrip. Untuk informasi lebih lanjut tentang cara memodifikasi skrip, lihat Sintaks Skrip.

Untuk informasi lebih lanjut tentang parameter fungsi, lihat Fungsi.

// Gunakan fungsi payload() untuk mendapatkan data yang dikirim oleh perangkat dan mengubah data menjadi format JSON.
var data = payload("json");
// Dapatkan nilai properti yang dikirim.
var h = data.items.Humidity.value;
var t = data.items.Temperature.value;
// Tambahkan kunci utama deviceName dan id ke tabel. Anda dapat menggunakan metode writeTableStore() untuk menulis nilai kelembaban dan suhu ke kolom menggunakan format kolom:nilai.
writeTableStore(1000, {"deviceName":deviceName(), "id":timestamp(), "temperature":t, "humidity":h});

Klik Debugging. Di kotak dialog yang muncul, pilih produk dan perangkat, tentukan topik, lalu masukkan data payload untuk memeriksa apakah skrip berjalan sesuai harapan.
Gambar berikut menunjukkan parameter.
Hasil berikut menunjukkan bahwa skrip berjalan sesuai harapan.
Klik Publish.
Pergi ke tab Parser halaman Data Forwarding. Temukan parser DataParser dan klik Start di kolom Aksi untuk memulai parser.
Setelah data didorong, masuk ke konsol OTS. Pergi ke tab Query Data tabel yang digunakan untuk menerima data dan periksa apakah data yang ditentukan telah diterima.