Mengintegrasikan MongoDB dan Amazon Kinesis untuk Stream Pintar, Tahan Lama

Mengintegrasikan MongoDB dan Amazon Kinesis untuk streaming data masa nyata

Artikel ini menunjukkan cara mengintegrasikan MongoDB dan Amazon Kinesis untuk membuat aliran data yang mantap dan real-time bertindak balas terhadap peristiwa langsung. Ini dicapai menggunakan pencetus jahitan MongoDB, yang memulakan tindakan kinesis AWS apabila perubahan data yang berkaitan berlaku dalam MongoDB.

Integrasi ini membolehkan pelbagai aplikasi, termasuk analisis masa nyata tingkah laku pengguna, cadangan produk peribadi, dan pengesanan penipuan. Data yang disimpan di MongoDB dan disiarkan ke kinesis kemudiannya boleh diproses oleh perkhidmatan hiliran seperti Amazon Kinesis Data Analytics untuk pengesanan anomali atau pengagregatan data.

Prasyarat:

Contoh Atlas MongoDB:

contoh Atlas (mis., Menggunakan pangkalan data bernama
1. dan koleksi yang dinamakan untuk data aplikasi e-dagang). Lihat panduan MongoDB Atlas Bermula untuk bantuan. AWS AWS dan Kinesis Stream: streamdata akaun AWS dengan aliran kinesis yang dikonfigurasikan (clickdata dalam contoh ini) untuk menghantar data ke aplikasi hiliran (seperti Kinesis Analytics).
Aplikasi stitch MongoDB:
2. aplikasi jahitan (dibuat dalam atlas). stitchStream
Integrasi langkah demi langkah:

Buat koleksi: Dalam aplikasi Stitch, buat koleksi (pangkalan data: , koleksi:

). Gunakan templat yang menyekat akses kepada data khusus pengguna (tentukan medan ID Pengguna).

1. streamdata Konfigurasi jahitan untuk AWS: clickdata Konfigurasi jahitan untuk berkomunikasi dengan AWS Kinesis dengan menambahkan perkhidmatan AWS dan peraturan yang dinamakan "Kinesis" yang membenarkan semua tindakan kinesis.

2. Buat fungsi streaming kinesis: Buat fungsi jahitan () untuk menghantar dokumen ke aliran kinesis. Tampal kod berikut:

<code class="language-javascript">exports = function(event){
 const awsService = context.services.get('aws');
 try{
   awsService.kinesis().PutRecord({
     Data: JSON.stringify(event.fullDocument),
     StreamName: "stitchStream",
     PartitionKey: "1"
      }).then(function(response) {
        return response;
      });
 }
 catch(error){
  console.log(JSON.parse(error));
 }
};</code>

4. Uji fungsi: Uji fungsi menggunakan konsol jahitan, menyediakan sampel event objek:

<code class="language-javascript">event = {
   "operationType": "replace",
   "fullDocument": { /* ...sample document... */ },
   "ns": { "db": "streamdata", "coll": "clickdata" }
};
exports(event);</code>

5. Konfigurasi pencetus jahitan: Buat pencetus jahitan untuk melaksanakan fungsi putKinesisRecord secara automatik pada memasukkan, mengemas kini, dan menggantikan operasi dalam koleksi clickdata.

6. Uji pencetus: Sahkan data streaming ke aliran kinesis menggunakan papan pemuka Amazon Kinesis.

7. Fungsi lanjutan: Gunakan perkhidmatan seperti Amazon Kinesis Data Analytics untuk pemprosesan selanjutnya (pengesanan anomali, agregasi, dll.).

Panduan terperinci ini membolehkan anda mengintegrasikan dengan lancar MongoDB dan Amazon Kinesis, memanfaatkan kuasa kedua-dua platform untuk pemprosesan dan analisis data masa nyata. Ingatlah untuk berunding dengan sumber yang disediakan untuk bantuan dan penyelesaian masalah selanjutnya.

Atas ialah kandungan terperinci Mengintegrasikan MongoDB dan Amazon Kinesis untuk Stream Pintar, Tahan Lama. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!