Topik ini menjelaskan cara mengintegrasikan Platform IoT dengan platform big data Alibaba Cloud. Dengan integrasi ini, Anda dapat menggunakan platform big data Alibaba Cloud untuk memproses, menganalisis, dan menampilkan data perangkat secara real-time.
Prasyarat
- Layanan Alibaba Cloud terkait telah diaktifkan, dan instans serta sumber daya komputasi yang diperlukan telah dibeli. Saat menggunakan platform big data Alibaba Cloud untuk memproses data perangkat dari Platform IoT, Anda mungkin memerlukan layanan seperti ApsaraDB RDS for MySQL, IoT Platform.
- Anda sudah familiar dengan prosedur konfigurasi dan catatan penggunaan layanan Alibaba Cloud.
Informasi latar belakang
- Skenario: Gunakan dasbor DataV untuk menampilkan data perangkat dari produk Platform IoT secara real-time.
- Proses:
- Platform IoT mengumpulkan data perangkat.
- Platform IoT meneruskan data perangkat suatu produk ke DataHub menggunakan mesin aturan.
- DataHub mengirimkan data perangkat ke Realtime Compute for Apache Flink untuk diproses dan menulis hasilnya ke ApsaraDB RDS for MySQL. Jika data tidak perlu diproses, Anda dapat menyinkronkan data langsung dari DataHub ke ApsaraDB RDS for MySQL menggunakan DataConnector.
- DataV menggunakan tabel database ApsaraDB RDS for MySQL sebagai sumber data dan menampilkan data perangkat dalam tabel secara real-time.
Prosedur
- Buat database ApsaraDB RDS for MySQL untuk menyimpan data perangkat.Untuk informasi lebih lanjut, lihat ApsaraDB RDS for MySQL.
- Masuk ke Konsol ApsaraDB RDS.
- Di halaman Instances, klik Create Instance untuk membeli instans ApsaraDB RDS for MySQL.Catatan Wilayah instans ApsaraDB RDS for MySQL harus sama dengan wilayah Platform IoT dan proyek DataHub Anda.
- Di halaman Instances, temukan instans yang dibeli dan klik Manage di kolom Actions.
- Di panel navigasi kiri, klik Accounts. Di halaman Accounts, klik Create Account dan konfigurasikan parameternya.
- Di panel navigasi kiri, klik Databases. Di halaman Databases, klik Create Database dan konfigurasikan parameter-parameternya.
- Di panel navigasi kiri, klik Data Security. Di halaman Data Security, klik Create Whitelist untuk mengonfigurasi daftar putih alamat IP untuk instans ApsaraDB RDS for MySQL. Untuk informasi lebih lanjut, lihat Konfigurasi Daftar Putih Alamat IP.
- Di panel navigasi kiri, klik Basic Information untuk melihat informasi dasar tentang instans.
Jika Anda ingin menyinkronkan data ke DataHub, DataV, atau Realtime Compute for Apache Flink, informasi instans tersebut diperlukan.
- Di bilah navigasi atas halaman Basic Information, klik Log On to Database. Di kotak dialog Masuk ke instans, masukkan informasi akun untuk masuk ke database.
- Buat tabel di dalam database. Contohnya, buat tabel bernama mytable. Tabel ini berisi dua bidang. Berikut adalah deskripsi bidang-bidang tersebut.
Tabel 1. mytable Bidang Tipe Deskripsi d_data varchar(32) Waktu. device_num int Jumlah perangkat aktif.
- Di konsol Platform IoT, buat produk, perangkat, dan aturan penerusan data.
- Masuk ke Konsol Platform IoT.
Di halaman Overview, klik All environment. Di tab Semua Lingkungan, temukan instans yang ingin Anda kelola dan klik ID instans atau nama instans.
- Di panel navigasi kiri, pilih . Di halaman Produk, klik Buat Produk dan konfigurasikan parameter. Untuk informasi lebih lanjut, lihat Buat Produk.
- Setelah Anda membuat produk, Anda dapat masuk ke halaman Product Details produk tersebut dan mengonfigurasi produk berdasarkan kebutuhan bisnis Anda. Misalnya, Anda dapat membuat kategori topik atau mendefinisikan model Bahasa Spesifikasi Hal (TSL). Untuk informasi lebih lanjut, lihat Apa itu topik? atau Apa itu model TSL?
- Di panel navigasi kiri, pilih . Di halaman Perangkat, klik Tambah Perangkat dan konfigurasikan parameter. Untuk informasi lebih lanjut, lihat Buat Perangkat.
- Di panel navigasi kiri, pilih . Di halaman Penerusan Data, klik Buat Aturan dan konfigurasikan parameter.
- Di halaman Penerusan Data, temukan aturan dan klik <View di kolom Tindakan.
- Di bagian Data Processing halaman Data Forwarding Rule, klik Write SQL. Di kotak dialog Tulis SQL, tulis pernyataan SQL untuk aturan tersebut. Lalu, debug pernyataan SQL tersebut. Untuk informasi lebih lanjut, lihat Pernyataan SQL.
- Di bagian Data Forwarding, klik Add Operation. Di kotak dialog Tambah Operasi, konfigurasikan parameter. Operasi ini digunakan untuk meneruskan data perangkat ke topik di DataHub. Untuk informasi lebih lanjut, lihat Konfigurasi Aturan Penerusan Data.
- Setelah konfigurasi selesai, masuk ke halaman Data Forwarding. Temukan aturan dan klik Start di kolom Tindakan untuk mengaktifkan aturan.
Setelah Anda mengaktifkan aturan, gunakan perangkat simulasi untuk mengirim pesan dan periksa apakah pesan tersebut dapat diteruskan ke DataHub. Di halaman Device Log, Anda dapat melihat log perangkat simulasi. Di konsol DataHub, Anda dapat melihat perubahan ukuran data shard dari topik ke mana data perangkat diteruskan. Anda juga dapat menggunakan fitur pengambilan sampel data untuk melihat isi pesan di shard. - Konfigurasikan perangkat dan hubungkan perangkat ke Platform IoT.Contoh ini menunjukkan cara menggunakan Link SDK for Java untuk mengonfigurasi perangkat. Klik Demo SDK for Java untuk mengunduh kode contoh.
Setelah mengembangkan SDK perangkat, instal SDK tersebut pada perangkat fisik. Setelah menyalakan perangkat dan menghubungkannya ke Platform IoT, perangkat dapat melaporkan data ke platform. Platform IoT meneruskan data ke DataHub menggunakan mesin aturan. Setelah diproses oleh Realtime Compute for Apache Flink, data yang telah diproses ditulis ke ApsaraDB RDS for MySQL.
- Lakukan pengujian. Setelah konfigurasi selesai, jumlah perangkat aktif diperbarui secara real-time di dasbor setiap kali perangkat terhubung ke Platform IoT dan mengirim pesan.