Bagikan melalui

Panduan Memulai Cepat: Membuat proyek Azure Stream Analytics dengan menggunakan Visual Studio Code

Dalam panduan memulai cepat ini, Anda membuat, menjalankan, dan menyerahkan pekerjaan Azure Stream Analytics (ASA) dengan menggunakan ekstensi Alat ASA untuk Visual Studio Code di komputer lokal Anda. Anda belajar membangun tugas ASA yang membaca data streaming real-time dari IoT Hub dan memfilter kejadian dengan suhu lebih besar dari 27°. Hasil output dikirim ke file dalam penyimpanan blob. Data input yang digunakan dalam panduan mulai cepat ini dihasilkan oleh simulator online Raspberry Pi.

Catatan

Alat Visual Studio Code tidak mendukung pekerjaan di wilayah Tiongkok Timur, Tiongkok Utara, Jerman Tengah, dan Jerman Timur Laut.

Prasyarat

Menginstal ekstensi Alat Azure Stream Analytics

  1. Buka Visual Studio Code (VS Code).

  2. Dari Ekstensi di panel kiri, cari stream analytics dan pilih Instal pada Azure Stream Analytics Tools extension.

    Cuplikan layar yang menampilkan halaman Ekstensi Visual Studio Code dengan opsi untuk menginstal ekstensi Azure Stream Analytics.

  3. Setelah diinstal, pilih ikon Azure pada bilah aktivitas dan masuk ke Azure.

    Cuplikan layar yang menampilkan cara masuk ke Azure.

  4. Setelah masuk, Anda dapat melihat langganan di bawah akun Azure Anda.

Catatan

Ekstensi Alat ASA secara otomatis memasukkan Anda setiap kali Anda membuka Visual Studio Code. Jika akun Anda memiliki autentikasi dua faktor, gunakan autentikasi telepon daripada menggunakan PIN. Untuk keluar dari akun Azure Anda, tekan Ctrl + Shift + P dan masukkan Azure: Sign Out.

Menyiapkan data masukan

Sebelum menentukan pekerjaan Stream Analytics, siapkan data input. Solusi ini menyerap data sensor real-time ke IoT Hub, yang kemudian Anda konfigurasi sebagai input pekerjaan. Untuk menyiapkan data input yang diperlukan oleh pekerjaan, selesaikan langkah-langkah berikut:

  1. Masuk ke portal Azure.

  2. Pilih Buat sumber daya. Pada halaman Buat sumber daya, pilih Internet of Things>IoT Hub.

    Cuplikan layar yang menampilkan menu IoT Hub di halaman Buat sumber daya.

  3. Pada halaman IoT Hub, ikuti langkah-langkah berikut:

    1. Untuk Langganan, pilih langganan Azure Anda.
    2. Untuk Grup sumber daya, Pilih grup sumber daya yang ada atau buat yang baru.
    3. Untuk nama hub IoT: Masukkan nama untuk hub IoT Anda.
    4. Untuk Wilayah, pilih wilayah terdekat.
    5. Untuk Tingkat, pilih Gratis, jika masih tersedia di langganan Anda. Untuk informasi selengkapnya, lihat Harga IoT Hub.
    6. Untuk Batas pesan harian, pertahankan nilai default.
    7. Pilih Berikutnya: Jaringan di bagian bawah halaman.

    Cuplikan layar memperlihatkan halaman IoT Hub untuk pembuatan.

  4. Pilih Tinjau + kreasikan. Tinjau informasi IoT Hub Anda dan pilih Buat. IoT Hub Anda mungkin memerlukan waktu beberapa menit untuk dibuat. Anda dapat memantau kemajuan di panel Pemberitahuan .

  5. Setelah sumber daya (IoT hub) dibuat, pilih Buka sumber daya untuk masuk ke halaman IoT Hub.

  6. Pada halaman IoT Hub, pilih Perangkat di menu sebelah kiri, lalu pilih + Tambahkan perangkat.

    Cuplikan layar yang menampilkan tombol Tambahkan perangkat di halaman Perangkat.

  7. Masukkan ID Perangkat dan pilih Simpan.

    Cuplikan layar memperlihatkan halaman Buat perangkat.

  8. Setelah membuat perangkat, Anda akan melihat perangkat di daftar perangkat IoT . Pilih tombol Refresh di halaman jika Anda tidak melihatnya.

    Cuplikan layar yang menampilkan daftar perangkat.

  9. Pilih perangkat Anda dari daftar.

  10. Pada halaman perangkat, pilih tombol salin di samping String Koneksi Utama, dan simpan ke notepad untuk digunakan nanti.

    Cuplikan layar yang menampilkan tombol salin di samping string koneksi perangkat.

Menjalankan simulator IoT

  1. Buka Simulator Online Raspberry Pi Azure IoT.

  2. Ganti placeholder di baris 15 dengan string koneksi perangkat Azure IoT Hub yang Anda simpan di bagian sebelumnya.

  3. Pilih Jalankan. Output menunjukkan data sensor dan pesan yang dikirim ke IoT Hub Anda.

    Cuplikan layar yang menampilkan halaman **Raspberry Pi Azure IoT Online Simulator** dengan sampel kueri.

    Penting

    Pilih Reset setelah beberapa menit untuk mengatur ulang string koneksi.

Membuat penyimpanan blob

  1. Dari sudut kiri atas portal Microsoft Azure, pilih Buat akun penyimpanan>Penyimpanan>Sumber Daya.

    Cuplikan layar yang menampilkan menu Buat akun penyimpanan.

  2. Di panel Buat akun penyimpanan, masukkan nama akun penyimpanan, lokasi, dan grup sumber daya. Pilih lokasi dan grup sumber daya yang sama dengan IoT Hub yang Anda buat. Lalu pilih Tinjau dan Buat untuk membuat akun penyimpanan.

    Cuplikan layar yang menampilkan halaman Buat akun penyimpanan.

  3. Pada halaman Akun penyimpanan, pilih Kontainer di menu sebelah kiri, lalu pilih + Kontainer pada bilah perintah.

    Cuplikan layar yang menampilkan halaman Kontainer.

  4. Dari halaman Kontainer baru, berikan nama untuk kontainer Anda, biarkan Tingkat akses publik tetap Privat (tanpa akses anonim), lalu pilih OK.

    Cuplikan layar yang menampilkan pembuatan halaman kontainer blob.

Membuat proyek Analisis Aliran

  1. Di Visual Studio Code, pilih Tampilkan>Palet Perintah, dan masukkan ASA: Buat Proyek Baru.

    Cuplikan layar yang menampilkan pemilihan ASA: Buat Proyek Baru di palet perintah.

  2. Masukkan nama proyek Anda, seperti myASAproj, dan pilih folder untuk proyek Anda.

    Cuplikan layar saat memasukkan nama proyek ASA.

  3. Visual Studio Code menambahkan proyek ASA ke ruang kerja Anda. Ini terdiri dari tiga folder: Input, Output, dan Fungsi. Ini juga memiliki skrip kueri (*.asaql), file JobConfig.json, dan file konfigurasiasaproj.json.

    Cuplikan layar yang menampilkan file proyek Analisis Aliran di Visual Studio Code.

    File asaproj.json berisi input, output, dan pengaturan konfigurasi pekerjaan untuk mengirimkan pekerjaan Stream Analytics ke Azure.

    Catatan

    Saat Anda menambahkan input dan output dari palet perintah, jalur yang sesuai ditambahkan ke asaproj.json secara otomatis. Jika Anda menambahkan atau menghapus input atau output pada disk secara langsung, Anda perlu menambahkan atau menghapusnya secara manual dari asaproj.json. Anda dapat menempatkan input dan output di satu tempat dan kemudian mereferensikannya dalam pekerjaan yang berbeda dengan menentukan jalur di setiap file asaproj.json .

Tentukan kueri transformasi

  1. Buka file myASAproj.asaql dan tambahkan kueri berikut:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

    Cuplikan layar yang menampilkan kueri transformasi.

Mengonfigurasi input pekerjaan

  1. Klik kanan folder Input di proyek Azure Stream Analytics Anda. Kemudian pilih ASA: Tambahkan Input dari menu konteks.

    Cuplikan layar yang menampilkan menu ASA: Tambahkan input di Visual Studio Code.

    Atau tekan Ctrl+Shift+P untuk membuka palet perintah dan masukkan ASA: Tambahkan Input.

  2. Pilih IoT Hub untuk jenis input.

    Cuplikan layar yang menampilkan pilihan hub IoT Anda di palet perintah Visual Studio Code.

  3. Pilih Pilih dari langganan Azure dari menu drop-down, lalu tekan ENTER.

  4. Masukkan Input untuk nama, lalu tekan ENTER.

  5. Di folder Input , Anda akan melihat file Input.json dibuat.

  6. Dalam file JSON, konfirmasikan bahwa Input adalah Nama yang ditentukan.

  7. Di editor JSON untuk Input.json, pilih Pilih dari langganan Anda, lalu pilih langganan Azure Anda yang memiliki hub IoT.

    Cuplikan layar memperlihatkan editor JSON dengan tautan Pilih dari langganan Anda.

  8. Di editor JSON, pilih Pilih IoT Hub, lalu pilih hub IoT yang Anda buat.

    Cuplikan layar memperlihatkan editor JSON dengan tautan Pilih IoT Hub.

  9. Secara default, SharedAccessPolicyName harus diatur ke iothubowner. Jika tidak, pilih tautan Pilih Nama Kebijakan Akses Bersama, lalu pilih iothubowner dari daftar drop-down.

  10. Nilai SharedAccessPolicyKey harus diatur secara otomatis.

  11. Pilih Pratinjau data untuk melihat apakah data input berhasil dikonfigurasi untuk pekerjaan Anda. Ini akan mengambil sampel IoT Hub Anda dan ditampilkan di jendela pratinjau.

    Cuplikan layar yang menampilkan pratinjau data input di hub IoT Anda.

Mengonfigurasi output pekerjaan

  1. Klik kanan Output di penjelajah, dan pilih ASA: Tambahkan Output.
  2. Pilih Data Lake Storage Gen2/Blob Storage untuk jenis sink di daftar drop-down.
  3. Pilih Pilih dari langganan Azure.
  4. Masukkan Output untuk nama alias dan tekan ENTER. Nama output ini digunakan untuk pernyataan INTO dalam kueri.
  5. Di editor JSON untuk Output.json, pilih Pilih dari langganan Anda, lalu pilih langganan Azure Anda yang memiliki akun Azure Storage.
  6. Jika Anda perlu mengubah akun penyimpanan yang diisi secara otomatis, pilih Pilih akun Penyimpanan, lalu pilih akun Azure Storage Anda. Nama akun penyimpanan secara otomatis terdeteksi jika dibuat dalam langganan yang sama.
  7. Jika Anda perlu mengubah nama kontainer, pilih Pilih kontainer, dan pilih kontainer blob yang Anda buat.

Cuplikan layar yang menampilkan konfigurasi output untuk pekerjaan Analisis Aliran.

Mengkompilasi skrip dan mengirimkannya ke Azure

Kompilasi skrip memeriksa sintaks dan membuat templat Azure Resource Manager untuk penyebaran otomatis.

  1. Klik kanan file skrip di jendela penjelajah, arahkan ke ASA: Kompilasi Skrip, lalu pilih ASA: TEMPLAT ARM V2 (disarankan).

    Cuplikan layar kompilasi opsi skrip dari penjelajah Azure Stream Analytics di Visual Studio Code.

  2. Setelah kompilasi, Anda akan melihat folder Sebarkan di bawah proyek Anda dengan dua templat Azure Resource Manager. Kedua file ini digunakan untuk penyebaran otomatis.

    Cuplikan layar templat penyebaran yang dihasilkan di folder proyek.

  3. Pilih Kirim ke Azure di editor kueri.

    Cuplikan layar tombol Kirim pekerjaan untuk mengirimkan pekerjaan Azure Stream Analytics ke Azure.

  4. Di jendela Kirim , ikuti langkah-langkah berikut:

    1. Pilih langganan Azure Anda.

    2. Pilih grup sumber daya Azure.

    3. Pilih wilayah tempat Anda ingin membuat pekerjaan Azure Stream Analytics.

    4. Lalu pilih Kirim.

      Cuplikan layar opsi Kirim.

  5. Pilih Terbitkan ke Azure dan selesaikan. Tunggu hingga membuka tab baru Tampilan Pekerjaan Cloud yang memperlihatkan status pekerjaan Anda.

    Cuplikan layar tombol terbitkan ke Azure di Visual Studio Code.

Mulai pekerjaan Analisis Aliran dan periksa output

  1. Pada tab Tampilan Pekerjaan Cloud, pilih Mulai untuk menjalankan pekerjaan Anda di cloud.

    Cuplikan layar tombol Mulai pekerjaan di halaman Tampilan cloud.

  2. Pada jendela Mulai pekerjaan streaming, pilih OK. Proses ini mungkin perlu waktu beberapa menit untuk diselesaikan.

    Cuplikan layar jendela Mulai pekerjaan streaming.

  3. Jika pekerjaan Anda berhasil dimulai, status pekerjaan berubah menjadi Berjalan. Anda melihat diagram logis yang menunjukkan bagaimana pekerjaan ASA Anda berjalan.

    Cuplikan layar status pekerjaan yang berjalan di Visual Studio Code.

  4. Untuk melihat hasil output, buka penyimpanan blob di ekstensi Visual Studio Code atau di portal Microsoft Azure.

    Cuplikan layar file output dalam kontainer Blob.

    Unduh dan buka file untuk melihat output.

    {"messageId":11,"deviceId":"Raspberry Pi Web Client","temperature":28.165519323167562,"humidity":76.875393581654379,"EventProcessedUtcTime":"2022-09-01T22:53:58.1015921Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:52:57.6250000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:52:57.6290000Z"}}
{"messageId":14,"deviceId":"Raspberry Pi Web Client","temperature":29.014941877871451,"humidity":64.93477299527828,"EventProcessedUtcTime":"2022-09-01T22:53:58.2421545Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:53:03.6100000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:53:03.6140000Z"}}
{"messageId":17,"deviceId":"Raspberry Pi Web Client","temperature":28.032846241745975,"humidity":66.146114343897338,"EventProcessedUtcTime":"2022-09-01T22:53:58.2421545Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:53:19.5960000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:53:19.5830000Z"}}
{"messageId":18,"deviceId":"Raspberry Pi Web Client","temperature":30.176185593576143,"humidity":72.697359909427419,"EventProcessedUtcTime":"2022-09-01T22:53:58.2421545Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:53:21.6120000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:53:21.6140000Z"}}
{"messageId":20,"deviceId":"Raspberry Pi Web Client","temperature":27.851894248213021,"humidity":71.610229530268214,"EventProcessedUtcTime":"2022-09-01T22:53:58.2421545Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:53:25.6270000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:53:25.6140000Z"}}
{"messageId":21,"deviceId":"Raspberry Pi Web Client","temperature":27.718624694772238,"humidity":66.540445035685153,"EventProcessedUtcTime":"2022-09-01T22:53:58.2421545Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:53:48.0820000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:53:48.0830000Z"}}
{"messageId":22,"deviceId":"Raspberry Pi Web Client","temperature":27.7849054424326,"humidity":74.300662748167085,"EventProcessedUtcTime":"2022-09-01T22:54:09.3393532Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:54:09.2390000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:54:09.2400000Z"}}
{"messageId":28,"deviceId":"Raspberry Pi Web Client","temperature":30.839892925680324,"humidity":76.237611741451786,"EventProcessedUtcTime":"2022-09-01T22:54:47.8053253Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:54:47.6180000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:54:47.6150000Z"}}
{"messageId":29,"deviceId":"Raspberry Pi Web Client","temperature":30.561040300759053,"humidity":78.3845172058103,"EventProcessedUtcTime":"2022-09-01T22:54:49.8070489Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:54:49.6030000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:54:49.5990000Z"}}
{"messageId":31,"deviceId":"Raspberry Pi Web Client","temperature":28.163585438418679,"humidity":60.0511571297096,"EventProcessedUtcTime":"2022-09-01T22:55:25.1528729Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:55:24.9050000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:55:24.9120000Z"}}
{"messageId":32,"deviceId":"Raspberry Pi Web Client","temperature":31.00503387156985,"humidity":78.68821066044552,"EventProcessedUtcTime":"2022-09-01T22:55:43.2652127Z","PartitionId":3,"EventEnqueuedUtcTime":"2022-09-01T22:55:43.0480000Z","IoTHub":{"MessageId":null,"CorrelationId":null,"ConnectionDeviceId":"MyASAIoTDevice","ConnectionDeviceGenerationId":"637976642928634103","EnqueuedTime":"2022-09-01T22:55:43.0520000Z"}}

Membersihkan sumber daya

Saat Anda tidak lagi memerlukan sumber daya, hapus grup sumber daya, pekerjaan Azure Stream Analytics, dan semua sumber daya terkait. Menghapus pekerjaan akan menghentikan penagihan untuk unit streaming yang digunakan pekerjaan. Jika Anda berencana untuk menggunakan pekerjaan di masa mendatang, Anda dapat menghentikannya dan memulai ulang nanti ketika Anda membutuhkannya. Jika Anda ingin berhenti menggunakan pekerjaan ini, hapus semua sumber daya yang dibuat dalam mulai cepat ini dengan menggunakan langkah-langkah berikut:

  1. Dari menu sebelah kiri di portal Microsoft Azure, pilih Grup sumber daya lalu pilih nama sumber daya yang Anda buat.

  2. Pada halaman grup sumber daya Anda, pilih Hapus. Masukkan nama sumber daya untuk dihapus di kotak teks, lalu pilih Hapus.

Langkah berikutnya

Untuk mempelajari selengkapnya tentang ekstensi Alat ASA untuk Visual Studio Code, lihat artikel berikut ini:

  • Last updated on