Mematerialkan data di Azure Cosmos DB menggunakan editor Analisis Aliran tanpa kode

Artikel ini menjelaskan cara menggunakan editor tanpa kode untuk membuat pekerjaan Azure Stream Analytics dengan mudah. Proses ini terus membaca dari Event Hubs Anda dan melakukan agregasi seperti hitungan, jumlah, dan rata-rata. Anda memilih bidang untuk dikelompokkan selama jendela waktu, kemudian tugas tersebut menulis hasil secara berkelanjutan ke Azure Cosmos DB.

Prasyarat

  • Sumber daya Azure Event Hubs dan Azure Cosmos DB Anda harus dapat diakses publik dan tidak boleh berada di belakang firewall atau diamankan di azure Virtual Network.
  • Data di Azure Event Hubs Anda harus diserialisasikan dalam format JSON, CSV, atau Avro.

Buat Tugas Analitik Aliran

Ikuti langkah-langkah berikut untuk mengembangkan pekerjaan Stream Analytics untuk me-materialisasikan data di Azure Cosmos DB.

  1. Di portal Azure, temukan dan pilih instans Azure Event Hubs Anda.
  2. Di bawah Fitur, pilih Proses Data. Kemudian, pilih Mulai di kartu berjudul Materialisasi Data di Azure Cosmos DB.
    Cuplikan layar yang menunjukkan Memulai Proses Materialisasi Aliran Data.
  3. Masukkan nama untuk pekerjaan Anda dan pilih Buat.
  4. Tentukan jenis Serialisasi data Anda di Event Hub dan Metode autentikasi yang akan digunakan pekerjaan untuk menyambungkan ke Event Hubs. Kemudian pilih Sambungkan.
  5. Jika koneksi berhasil dan Anda memiliki aliran data yang mengalir ke instans Azure Event Hubs, Anda akan segera melihat dua hal:
    • Bidang yang ada dalam payload input Anda. Pilih simbol tiga titik di samping bidang secara opsional menghapus, mengganti nama, atau mengubah jenis data bidang.
      Cuplikan layar yang menunjukkan bidang pusat aktivitas dari input untuk Anda tinjau.
    • Sampel data input Anda di panel bawah di bawah Pratinjau data yang secara otomatis di-refresh secara berkala. Anda dapat memilih Jeda pratinjau streaming jika Anda lebih suka memiliki tampilan statis data input sampel Anda.
      Cuplikan layar yang menunjukkan sampel data input.
  6. Pada langkah berikutnya, Anda menentukan bidang dan agregat yang ingin Anda hitung, seperti Rata-rata dan Hitungan. Anda juga dapat menentukan bidang yang ingin Anda Kelompokkan Menurut bersama dengan jendela waktu. Kemudian Anda dapat memvalidasi hasil langkah di bagian Pratinjau data.
    Cuplikan layar yang menunjukkan area Pengelompokan.
  7. Pilih database Cosmos DB dan kontainer tempat Anda ingin menulis hasil.
  8. Mulai pekerjaan Analisis Aliran dengan memilih Mulai.
    Cuplikan layar yang menunjukkan definisi tempat Anda memilih Mulai.
    Untuk memulai pekerjaan, Anda harus menentukan:
    • Jumlah Unit Streaming (SU) yang dijalankan pekerjaan. SU mewakili jumlah komputasi dan memori yang dialokasikan untuk pekerjaan. Kami menyarankan agar Anda memulai dengan tiga dan menyesuaikan sesuai kebutuhan.
    • Penanganan kesalahan data output memungkinkan Anda menentukan perilaku yang Anda inginkan saat output pekerjaan ke tujuan Anda gagal karena kesalahan data. Secara default, pekerjaan Anda mencoba kembali hingga operasi tulis berhasil. Anda juga dapat memilih untuk menghilangkan peristiwa output.
  9. Setelah Anda memilih Mulai, pekerjaan mulai berjalan dalam waktu dua menit. Lihat pekerjaan di bawah bagian Data Proses di tab pekerjaan Analisis Aliran. Anda dapat menjelajahi metrik pekerjaan dan menghentikan dan memulai ulang sesuai kebutuhan.

Pertimbangan saat menggunakan fitur Replikasi Geografis Azure Event Hubs

Azure Event Hubs baru-baru ini meluncurkan fitur Geo-Replikasi dalam versi pratinjau publik. Fitur ini berbeda dari Geo Disaster Recovery Azure Event Hubs.

Ketika jenis failover adalah Forced dan konsistensi replikasi adalah Asynchronous, pekerjaan Azure Stream Analytics tidak menjamin output persis satu kali ke output Azure Event Hubs.

Azure Stream Analytics, sebagai produsen dengan output dengan event hub, mungkin mengamati penundaan watermark pada pekerjaan selama durasi failover dan selama pembatasan oleh Event Hubs jika lag replikasi antara primer dan sekunder mencapai lag maksimum yang dikonfigurasi.

Azure Stream Analytics, sebagai konsumen dengan Event Hubs sebagai Input, mungkin mengamati penundaan watermark pada pekerjaan selama proses failover dan mungkin melewati data atau menemukan data duplikat setelah failover selesai.

Karena peringatan ini, mulai ulang pekerjaan Azure Stream Analytics dengan waktu mulai yang sesuai tepat setelah failover Azure Event Hubs selesai. Selain itu, karena fitur Geo-replikasi Azure Event Hubs sedang dalam pratinjau publik, saat ini jangan gunakan pola ini untuk pekerjaan Stream Analytics dalam lingkungan produksi. Perilaku Azure Stream Analytics saat ini akan meningkat sebelum fitur Replikasi Geografis Azure Event Hubs tersedia secara umum dan dapat digunakan dalam pekerjaan produksi Azure Stream Analytics.

Langkah berikutnya

Sekarang Anda tahu cara menggunakan editor tanpa kode Azure Stream Analytics untuk mengembangkan pekerjaan yang membaca dari Azure Event Hubs dan menghitung agregat seperti hitungan, rata-rata, dan menulisnya ke sumber daya Azure Cosmos DB Anda.

  • Last updated on