Memproses data dari hub peristiwa Anda menggunakan Azure Stream Analytics

Layanan Azure Stream Analytics memudahkan untuk menelan, memproses, dan menganalisis data streaming dari Azure Event Hubs, memungkinkan wawasan canggih untuk mendorong tindakan real-time. Integrasi ini memungkinkan Anda untuk dengan cepat membuat saluran analitik jalur panas. Anda dapat menggunakan portal Azure untuk memvisualisasikan data masuk dan menulis kueri Analitik Stream. Setelah kueri Anda siap, Anda bisa memindahkannya ke produksi hanya dengan beberapa klik.

Keuntungan Utama

Berikut adalah manfaat utama dari Azure Event Hubs dan integrasi Azure Stream Analytics:

  • Mempratinjau data – Anda dapat mempratinjau data masuk dari hub acara di portal Azure.
  • Uji kueri Anda - Siapkan kueri transformasi dan uji secara langsung di portal Azure. Untuk sintaks bahasa kueri, lihat Dokumentasi Aliran Bahasa Kueri Analitik.
  • Menerapkan kueri Anda ke produksi - Anda dapat menerapkan kueri ke dalam produksi dengan membuat dan memulai pekerjaan Azure Stream Analytics.

Alur end-to-end

Penting

Jika Anda bukan anggota dengan peran pemilik atau kontributor di tingkat langganan Azure, Anda harus menjadi anggota dengan peran Penguji Kueri Azure Stream Analytics di tingkat langganan Azure untuk berhasil menyelesaikan langkah-langkah di bagian ini. Peran ini memungkinkan Anda untuk melakukan kueri pengujian tanpa membuat pekerjaan analitik aliran terlebih dahulu. Untuk petunjuk terkait menetapkan peran kepada pengguna, lihat Menetapkan peran AD kepada pengguna.

  1. Masuk ke portal Azure.

  2. Navigasi ke ruang nama Hub Peristiwa Anda lalu navigasi ke hub acara, yang memiliki data masuk.

  3. Pilih Data Proses pada halaman hub acara.

    Process data tile

  4. Pilih Jelajahi di Aktifkan wawasan real-time dari acara petak peta.

    Select Stream Analytics

  5. Anda melihat halaman kueri dengan nilai yang sudah diatur untuk bidang berikut ini:

    1. Hub peristiwa Anda sebagai input untuk kueri.

    2. Contoh kueri SQL dengan pernyataan SELECT.

    3. Alias output untuk merujuk ke hasil pengujian kueri Anda.

      Query editor

      Catatan

      Saat Anda menggunakan fitur ini untuk pertama kalinya, halaman ini meminta izin Anda untuk membuat grup konsumen dan kebijakan untuk hub acara Anda untuk mempratinjau data masuk.

  6. Pilih Buat di panel Pratinjau input seperti yang diperlihatkan dalam gambar sebelumnya.

  7. Anda akan langsung melihat snapshot data masuk terbaru di tab ini.

    • Jenis serialisasi dalam data Anda terdeteksi secara otomatis (JSON/CSV). Anda juga dapat mengubahnya secara manual ke JSON/CSV/AVRO.

    • Anda bisa melakukan pratinjau data masuk dalam format tabel atau format mentah.

    • Jika data Anda yang ditampilkan bukan yang terkini, pilih Refresh untuk melihat kejadian terbaru.

      Berikut adalah contoh data dalam format tabel: Results in the table format

      Berikut adalah contoh data dalam format mentah:

      Results in the raw format

  8. Pilih Uji kueri untuk melihat snapshot hasil pengujian kueri Anda di tabHasil Tes. Anda juga dapat mengunduh hasilnya.

    Test query results

  9. Tulis kueri Anda sendiri untuk mentransformasi data. LihatReferensi Bahasa Pemrograman Kueri Analitik Stream.

  10. Setelah Anda menguji kueri dan Anda ingin memindahkannya ke produksi, pilih Terapkan kueri. Untuk menerapkan kueri, buat tugas Azure Stream Analytics tempat Anda dapat mengatur output untuk pekerjaan Anda, dan memulai pekerjaan. Untuk membuat tugas Stream Analytics, tentukan nama untuk pekerjaan tersebut, lalu pilih Buat.

    Create an Azure Stream Analytics job

    Catatan

    Kami menyarankan agar Anda membuat grup konsumen dan kebijakan untuk setiap pekerjaan Azure Stream Analytics baru yang Anda buat dari sini. Grup konsumen hanya mengizinkan lima pembaca bersamaan, jadi menyediakan kelompok konsumen khusus untuk setiap pekerjaan akan menghindari kesalahan yang mungkin timbul karena melebihi batas itu. Kebijakan khusus memungkinkan Anda memutar kunci atau mencabut izin tanpa memengaruhi sumber daya lain.

  11. Tugas Stream Analytics Anda sekarang dibuat di mana kueri Anda sama dengan yang Anda uji, dan input adalah hub peristiwa Anda.

  12. Untuk menyelesaikan pipeline, atur output kueri, dan pilih Mulai untuk memulai pekerjaan.

    Catatan

    Sebelum memulai pekerjaan, jangan lupa untuk mengganti outputalias dengan nama output yang Anda buat di Azure Stream Analytics.

    Set output and start the job

Batasan yang diketahui

Saat menguji kueri Anda, hasil pengujian membutuhkan waktu sekitar 6 detik untuk dimuat. Kami sedang berupaya meningkatkan kinerja pengujian. Namun, saat diterapkan dalam produksi, Azure Stream Analytics akan memiliki latensi subdetik.

Unit streaming

Pekerjaan Azure Stream Analytics Anda default ke tiga unit streaming (SU). Untuk menyesuaikan pengaturan ini,pilih Skalakan di menu sebelah kiri di halaman tugas Stream Analytics di portal Azure. Untuk mempelajari selengkapnya tentang unit streaming, lihat Memahami dan menyesuaikan Unit Streaming.

Scale streaming units

Langkah berikutnya

Untuk mempelajari selengkapnya tentang kueri Analitik Stream, lihat Bahasa Kueri Analisis Streaming